CN113765793A - 数据传输方法及装置、存储介质、电子设备 - Google Patents
数据传输方法及装置、存储介质、电子设备 Download PDFInfo
- Publication number
- CN113765793A CN113765793A CN202110631760.2A CN202110631760A CN113765793A CN 113765793 A CN113765793 A CN 113765793A CN 202110631760 A CN202110631760 A CN 202110631760A CN 113765793 A CN113765793 A CN 113765793A
- Authority
- CN
- China
- Prior art keywords
- service node
- data transmission
- node information
- information
- data
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/12—Shortest path evaluation
- H04L45/123—Evaluation of link metrics
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/02—Topology update or discovery
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/24—Multipath
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D30/00—Reducing energy consumption in communication networks
- Y02D30/70—Reducing energy consumption in communication networks in wireless communication networks
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本公开属于数据处理技术领域,涉及一种数据传输方法及装置、存储介质、电子设备。该方法包括:接收业务数据,并获取与业务数据对应的目标仓信息以及当前服务节点信息;确定目标仓信息对应的目标服务节点信息,并对当前服务节点信息和目标服务节点信息进行匹配得到节点匹配结果;基于节点匹配结果,对当前服务节点信息和目标服务节点信息进行链路路径计算得到数据传输路径;基于目标仓信息,按照数据传输路径传输业务数据。本公开通过数据传输路径保证了可用的数据传输服务,提升了数据传输的时效性和有效性。并且,该数据传输路径能够动态规划,保证了服务节点异常或者传输路径异常情况下的通信高可用性提升了数据传输方式的鲁棒性和灵活性。
Description
技术领域
本公开涉及数据处理技术领域,尤其涉及一种数据传输方法与数据传输装置、计算机可读存储介质及电子设备。
背景技术
现今的物流体系中,全球化仓配体系已经是较为普及的方式,可以实现全球购物、全球仓配的购物需求。同时,系统的全球化部署也是未来的需求,保证全球化系统部署系统间数据交互的高效,是系统实现过程中的较大难题。
一般的,通过各个中心服务节点进行数据下传和回传的直调。但是,由于距离较远或跨国网络,请求的时效无法保证时效,很多时候需要重试。并且,在全球各地都存在物理仓库时,会存在一个地区多个仓库的情况,此时的数据下发到仓库系统是较为困难的。
鉴于此,本领域亟需开发一种新的数据传输方法及装置。
需要说明的是,在上述背景技术部分公开的信息仅用于加强对本公开的背景的理解,因此可以包括不构成对本领域普通技术人员已知的现有技术的信息。
发明内容
本公开的目的在于提供一种数据传输方法、数据传输装置、计算机可读存储介质及电子设备,进而至少在一定程度上克服由于相关技术的限制而导致的数据传输时效性低的技术问题。
本公开的其他特性和优点将通过下面的详细描述变得显然,或部分地通过本公开的实践而习得。
根据本发明实施例的第一个方面,提供一种数据传输方法,所述方法包括:接收业务数据,并获取与所述业务数据对应的目标仓信息以及当前服务节点信息;
确定所述目标仓信息对应的目标服务节点信息,并对所述当前服务节点信息和所述目标服务节点信息进行匹配得到节点匹配结果;
基于所述节点匹配结果,对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径;
基于所述目标仓信息,按照所述数据传输路径传输所述业务数据。
在本发明的一种示例性实施例中,所述对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径,包括:
确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息;
根据所述当前服务节点信息、所述通信服务节点信息和所述目标服务节点信息生成候选传输路径,并在所述候选传输路径中确定数据传输路径。
在本发明的一种示例性实施例中,所述在所述候选传输路径中确定数据传输路径,包括:
分别获取与所述当前服务节点信息、所述通信服务节点信息和所述目标服务节点信息对应的通信强度信息;
对所述通信强度信息进行计算得到所述候选传输路径的路径通信耗时,并根据所述路径通信耗时在所述候选传输路径中确定数据传输路径。
在本发明的一种示例性实施例中,所述确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息,包括:
获取预先配置好的全局网状节点信息;
基于所述全局网状节点信息,确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息。
在本发明的一种示例性实施例中,所述按照所述数据传输路径传输所述业务数据,包括:
对所述数据传输路径进行路由检测得到检测耗时;
基于所述检测耗时,按照所述数据传输路径传输所述业务数据。
在本发明的一种示例性实施例中,所述对所述数据传输路径进行路由检测得到检测耗时,包括:
获取检测数据,并以预设时长为间隔在所述数据传输路径中传输所述检测数据得到检测耗时。
在本发明的一种示例性实施例中,所述基于所述检测耗时,按照所述数据传输路径传输所述业务数据,包括:
若所述检测耗时为检测超时,更新所述全局网状节点信息;
基于更新后的所述全局节点信息,对所述当前服务节点信息和所述目标服务节点信息重新进行链路路径计算得到另一数据传输路径,以按照所述另一数据传输路径传输所述业务数据。
根据本发明实施例的第二个方面,提供一种数据传输装置,所述装置包括:信息获取模块,被配置为接收业务数据,并获取与所述业务数据对应的目标仓信息以及当前服务节点信息;
信息匹配模块,被配置为确定所述目标仓信息对应的目标服务节点信息,并对所述当前服务节点信息和所述目标服务节点信息进行匹配得到节点匹配结果;
路径计算模块,被配置为基于所述节点匹配结果,对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径;
数据传输模块,被配置为基于所述目标仓信息,按照所述数据传输路径传输所述业务数据。
根据本发明实施例的第三个方面,提供一种电子设备,包括:处理器和存储器;其中,存储器上存储有计算机可读指令,所述计算机可读指令被所述处理器执行时实现上述任意示例性实施例的数据传输方法。
根据本发明实施例的第四个方面,提供一种计算机可读存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现上述任意示例性实施例中的数据传输方法。
由上述技术方案可知,本发明示例性实施例中的数据传输方法、数据传输装置、计算机存储介质及电子设备至少具备以下优点和积极效果:
在本公开的示例性实施例提供的方法及装置中,确定当前服务节点信息和目标服务节点信息之后,经过链路路径计算确定最优的数据传输路径,通过数据传输路径保证了可用的数据传输服务,提升了数据传输的时效性和有效性。并且,该数据传输路径能够通过动态检测的方式动态规划,保证了服务节点异常或者传输路径异常情况下的通信高可用性提升了数据传输方式的鲁棒性和灵活性。
应当理解的是,以上的一般描述和后文的细节描述仅是示例性和解释性的,并不能限制本公开。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本公开的实施例,并与说明书一起用于解释本公开的原理。显而易见地,下面描述中的附图仅仅是本公开的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。
图1示意性示出本公开示例性实施例中一种数据传输方法的流程示意图;
图2示意性示出本公开示例性实施例中链路路径计算的方法的流程示意图;
图3示意性示出本公开示例性实施例中确定通信服务节点信息的方法的流程示意图;
图4示意性示出本公开示例性实施例中全局网状节点信息形成的通信示意图;
图5示意性示出本公开示例性实施例中通信服务节点的规划配置图;
图6示意性示出本公开示例性实施例中各服务节点间的通信链路的配置示意图;
图7示意性示出本公开示例性实施例中确定数据传输路径的方法的流程示意图;
图8示意性示出本公开示例性实施例中按照数据传输路径传输业务数据的方法的流程示意图;
图9示意性示出本公开示例性实施例中进一步按照数据传输路径传输业务数据的方法的流程示意图;
图10示意性示出本公开示例性实施例中传输业务数据和数据传输路径的结构示意图;
图11示意性示出本公开示例性实施例中应用场景下的数据传输方法的流程示意图;
图12示意性示出本公开示例性实施例中一种数据传输装置的结构示意图;
图13示意性示出本公开示例性实施例中一种用于实现数据传输方法的电子设备;
图14示意性示出本公开示例性实施例中一种用于实现数据传输方法的计算机可读存储介质。
具体实施方式
现在将参考附图更全面地描述示例实施方式。然而,示例实施方式能够以多种形式实施,且不应被理解为限于在此阐述的范例;相反,提供这些实施方式使得本公开将更加全面和完整,并将示例实施方式的构思全面地传达给本领域的技术人员。所描述的特征、结构或特性可以以任何合适的方式结合在一个或更多实施方式中。在下面的描述中,提供许多具体细节从而给出对本公开的实施方式的充分理解。然而,本领域技术人员将意识到,可以实践本公开的技术方案而省略所述特定细节中的一个或更多,或者可以采用其它的方法、组元、装置、步骤等。在其它情况下,不详细示出或描述公知技术方案以避免喧宾夺主而使得本公开的各方面变得模糊。
本说明书中使用用语“一个”、“一”、“该”和“所述”用以表示存在一个或多个要素/组成部分/等;用语“包括”和“具有”用以表示开放式的包括在内的意思并且是指除了列出的要素/组成部分/等之外还可存在另外的要素/组成部分/等;用语“第一”和“第二”等仅作为标记使用,不是对其对象的数量限制。
此外,附图仅为本公开的示意性图解,并非一定是按比例绘制。图中相同的附图标记表示相同或类似的部分,因而将省略对它们的重复描述。附图中所示的一些方框图是功能实体,不一定必须与物理或逻辑上独立的实体相对应。
针对相关技术中存在的问题,本公开提出了一种数据传输方法。图1示出了数据传输方法的流程图,如图1所示,数据传输方法至少包括以下步骤:
步骤S110.接收业务数据,并获取与业务数据对应的目标仓信息以及当前服务节点信息。
步骤S120.确定目标仓信息对应的目标服务节点信息,并对当前服务节点信息和目标服务节点信息进行匹配得到节点匹配结果。
步骤S130.基于节点匹配结果,对当前服务节点信息和目标服务节点信息进行链路路径计算得到数据传输路径。
步骤S140.基于目标仓信息,按照数据传输路径传输业务数据。
在本公开的示例性实施例中,确定当前服务节点信息和目标服务节点信息之后,经过链路路径计算确定最优的数据传输路径,通过数据传输路径保证了可用的数据传输服务,提升了数据传输的时效性和有效性。并且,该数据传输路径能够通过动态检测的方式动态规划,保证了服务节点异常或者传输路径异常情况下的通信高可用性提升了数据传输方式的鲁棒性和灵活性。
下面对数据传输方法的各个步骤进行详细说明。
在步骤S110中,接收业务数据,并获取与业务数据对应的目标仓信息以及当前服务节点信息。
在本公开的示例性实施例中,该业务数据是要向仓库下传的数据,可以包括订单数据和商品数据等业务明细数据。
在接收该业务数据时,可以根据发送该业务数据的请求获取与业务数据对应的目标仓信息。该目标仓信息为业务数据要下传的仓库的信息,可以是要下传仓库的仓库号等标识信息,也可以是其他可以表征该下传仓库的信息,本示例性实施例对此不做特殊限定。
在下传业务数据的过程中,可以首先将业务数据下传到距离最近的服务节点。因此,当前服务节点信息即为表征与业务数据距离最近的服务节点的信息,可以是该服务节点的名称,也可以是该服务节点的标识,还可以是其他信息,本示例性实施例对此不做特殊限定。
在步骤S120中,确定目标仓信息对应的目标服务节点信息,并对当前服务节点信息和目标服务节点信息进行匹配得到节点匹配结果。
在本公开的一种示例性实施例中,该目标服务节点信息为辐射目标仓信息表征的仓库的服务节点的信息,该信息可以是服务节点的名称,也可以是该服务节点的标识,还可以是其他信息,本示例性实施例对此不做特殊限定。
对当前服务节点信息和目标服务节点信息进行匹配可以是将当前服务节点信息和目标服务节点信息进行比较,得到当前服务节点信息和目标服务节点信息相同或者不同的比较结果作为节点匹配结果。
举例而言,当当前服务节点信息为服务节点的标识,且该标识为A,而目标服务节点信息也为服务节点的标识,且标识为B时,将当前服务节点信息与目标服务节点信息进行匹配得到当前服务节点信息与目标服务节点信息不同的节点匹配结果;当当前服务节点信息为服务节点的标识,且该标识为A,而目标服务节点信息也为服务节点的标识,且标识也为A时,将当前服务节点信息与目标服务节点信息进行匹配得到当前服务节点信息与目标服务节点信息相同的节点匹配结果。
在步骤S130中,基于节点匹配结果,对当前服务节点信息和目标服务节点信息进行链路路径计算得到数据传输路径。
在本公开的一种示例性实施例中,在得到节点匹配结果,且节点匹配结果为当前服务节点信息与目标服务节点信息不同时,可以对当前服务节点信息和目标服务节点信息进行链路路径计算。
在可选的实施例中,图2示出了链路路径计算的方法的流程示意图,如图2所示,该方法至少包括以下步骤:在步骤S210中,确定与当前服务节点信息和目标服务节点信息对应的通信服务节点信息。
在可选的实施例中,图3示出了确定通信服务节点信息的方法的流程示意图,如图3所示,该方法至少包括以下步骤:在步骤S310中,获取预先配置好的全局网状节点信息。
在物流仓储的场景中,每个大洲都会建立很多仓库,用来给周边的城市进行商品配送。除此之外,也可能是美国的仓库将商品出库邮寄到中国买家,此时就需要在附近部署通信服务节点,用来辐射周边的仓库。并且,为了从中国向美国的仓库下单,就需要通过中国的通信服务节点向美国的通信服务节点进行数据传输。
基于此,可以根据各个通信节点之间进行数据传输的方式预先配置通信服务节点得到全局网状节点信息。
图4示出了全局网状节点信息形成的通信示意图,如图4所示,中国的通信服务节点可以辐射一定范围的国内仓库,还可以与其他大洲的国家的通信服务节点建立通信关系。
图5示出了通信服务节点的规划配置图,如图5所示,根据全球各地区部署的通信服务节点情况,可以通过各通信服务节点的所在地区进行通信绑定,亦即配置通信服务节点间的通信链路。各个子服务节点都可以与中心服务节点进行通信,定时从中心服务节点拉取全球的全局网状节点信息。
同时,各个子服务节点中都会包含自身辐射的仓库列表,该仓库列表就是该子服务节点负责进行数据下传和回传的仓库列表。若其他国家或者区域向下单到某个仓,需要将业务数据传输到该仓库的子服务节点。
并且,中心服务节点和各个子服务节点中均包括节点网络检测模块、通信模块和数据服务模块,并无差异。
图6示出了各服务节点间的通信链路的配置示意图,如图6所示,中心服务节点可以与图5中的其他各个子服务节点进行通信,包括服务节点A、服务节点B、服务节点C和服务节点D。而服务节点A除了可以与中心服务节点进行通信外,只可以与服务节点B进行通信。其他节点配置与服务节点A的配置方式类似。
值得说明的是,子服务节点之间的通信链路配置可以以两个子服务节点之间的距离为依据,也可以以其他数据传输过程中的影响因素为依据,本示例性实施例对此不做特殊限定。
在步骤S320中,基于全局网状节点信息,确定与当前服务节点信息和目标服务节点信息对应的通信服务节点信息。
在获取到中心服务节点存储的全局网状节点信息之后,可以在该全局网状节点信息中查询当前服务节点信息与目标服务节点信息的通信链路都包括哪些子服务节点,以将该子服务节点的标识或者名称确定为通信服务节点信息。
在本示例性实施例中,根据预先配置好的全局网状节点信息可以确定通信服务节点信息,为后续的数据传输路径的确定提供了数据基础,也保证了数据传输路径的确定准确性。
在步骤S220中,根据当前服务节点信息、通信服务节点信息和目标服务节点信息生成候选传输路径,并在候选传输路径中确定数据传输路径。
在全局网状节点信息中查询到与当前服务节点信息和目标服务节点信息对应的通信服务节点信息之后,按照全局网状节点信息中存储的通信服务节点信息的通信链路可以生成对应的候选传输路径。
进一步的,可以在候选传输路径中确定数据传输路径。
在可选的实施例中,图7示出了确定数据传输路径的方法的流程示意图,如图7所示,该方法至少包括以下步骤:在步骤S710中,分别获取与当前服务节点信息、通信服务节点信息和目标服务节点信息对应的通信强度信息。
该通信强度信息可以是能够反映各个服务节点的通信信号强度的信息。举例而言,该通信强度信息可以是RSSI(Received Signal Strength Indication,接收的信号强度指示),是无线发送层的部分,同来判定链接质量以及是否增大广播发送强度。该通信强度信息也可以是指一个数据块(帧、分组或报文段等)从链路或者网络的一端传送到另一端所需要的时间。
其中,信号强度和传输时间呈负相关的关系,即信号强度越弱,传输时间越长;通信时间越强,传输时间越短。
在步骤S720中,对通信强度信息进行计算得到候选传输路径的路径通信耗时,并根据路径通信耗时在候选传输路径中确定数据传输路径。
在得到当前服务节点信息、通信服务节点信息和目标服务节点信息的通信强度信息之后,可以对通信强度信息进行计算得到候选传输路径对应的路径通信耗时。
进一步的,当候选传输路径为多个时,可以得到多个路径通信耗时。因此,可以将多个路径通信耗时进行比较,从中选择路径通信耗时最小的一条候选传输路径作为数据传输路径。
在本示例性实施例中,根据候选传输路径确定数据传输路径,确定方式完整准确,且能够从通信速度和强度方面保障数据传输的效率,能够保证高可用的数据传输服务。
在步骤S140中,基于目标仓信息,按照数据传输路径传输业务数据。
在确定数据传输路径之后,可以根据目标仓信息确定数据传输路径中的各个服务节点是否为包含目标仓库的服务节点,以将业务数据传输到目标仓信息表征的目标仓库中。并且,为了保证业务数据的准确传输,还可以对数据传输路径进行路由检测。
在可选的实施例中,图8示出了按照数据传输路径传输业务数据的方法的流程示意图,如图8所示,该方法至少包括以下步骤:在步骤S810中,对数据传输路径进行路由检测得到检测耗时。
在可选的实施例中,获取检测数据,并以预设时长为间隔在数据传输路径中传输检测数据得到检测耗时。
为了保障检测耗时的检测准确性,可以将检测数据设置为是大小不同的数据。举例而言,较大的检测数据的大小可以是5k,或者5k等,较小的检测数据的大小可以是1k,也可以根据实际情况确定检测数据的大小,本示例性实施例对此不做特殊限定。
进一步的,为对数据传输路径中的各个服务节点进行路由检测,可以定时向与自身直接关联的服务节点传输检测数据得到对应的检测耗时,并定时将该检测耗时上报给中心服务节点,作为各服务节点的权重,以为后续数据传输路径提供参考信息。
具体的,该路由检测方式可以参考表1:
源节点 | 目标节点 | 执行频率 | 报文大小 | 耗时平均值 |
中心服务节点 | 服务节点A | 30秒 | 1K | 10ms |
中心服务节点 | 服务节点B | 30秒 | 1K | 15ms |
中心服务节点 | 服务节点C | 30秒 | 1K | 18ms |
中心服务节点 | 服务节点D | 30秒 | 1K | 16ms |
服务节点C | 服务节点D | 30秒 | 1K | 12ms |
… | … | … | … | .. |
表1
在步骤S820中,基于检测耗时,按照数据传输路径传输业务数据。
在可选的实施例中,图9示出了进一步按照数据传输路径传输业务数据的方法的流程示意图,如图9所示,该方法至少包括以下步骤:在步骤S910中,若检测耗时为检测超时,更新全局网状节点信息。
当数据传输路径中的服务节点出现异常时,在路由检测过程中会检测到该服务节点不可用,此时会显示路由检测的检测耗时为检测耗时。并且,还会上报中心服务节点进行异常节点剔除,中心服务节点会通知全局网状节点信息中包括的其他服务节点,以更新全局网状节点信息。
当数据传输路径中的某个服务节点和中心服务节点间的通信网络出现问题,比如光缆断掉等,就会出现由于部分通信链路不可达导致的检测超时。同样的,也会上传到中心服务节点,中心服务节点也会通知全局网状节点信息中包括的其他服务节点,以更新全局网状节点信息。
具体的,可以参考图5所示的规划配置图,中心服务节点到服务节点C之间的通信链路断掉,整个全局网状节点信息会摘除该链路。此时,如果中心服务节点想要与服务节点C进行数据传输,就必须经过数据服务节点D,再到达服务节点C。
在步骤S920中,基于更新后的全局节点信息,对当前服务节点信息和目标服务节点信息重新进行链路路径计算得到另一数据传输路径,以按照另一数据传输路径传输业务数据。
在全局节点信息更新之后,可以按照步骤S130中的链路路径计算方法重新得到另一数据传输路径,以按照新的另一传输路径传输业务数据。
该业务数据传输过程中,可以以数据报文的形式进行传输,并且还可以将数据传输路径的信息同时进行传输。
图10示出了传输业务数据和数据传输路径的结构示意图,如图10所示,将业务数据和数据传输路径构造成如图所示的传输结构,该传输结构中包括传输业务数据和数据传输路径,以按照数据传输路径传输业务数据。
在本示例性实施例中,根据更新后的全局网状节点信息还可以对数据传输路径进行更新,数据传输路径的确定更加灵活和动态,保证服务节点或者通信链路异常后的通信高可用。
值得说明的是,当按照原本的数据通信路径传输业务数据时,也可以构造成如图10所示的传输结构。
下面结合一应用场景对本公开实施例中的数据传输方法做出详细说明。
图11示出了应用场景下的数据传输方法的流程示意图,如图11所示,在步骤S1110中,当前节点接到向某个仓发送数据的请求。
当前服务节点可以接受订单系统,或者是仓内订单系统回传数据的请求,该请求为向目标仓库发送业务数据的请求。通过该请求中包括的目标仓信息,可以获取到该仓库的目标服务节点信息。
其中,该目标仓信息为业务数据要下传的仓库的信息,可以是要下传仓库的仓库号等标识信息,也可以是其他可以表征该下传仓库的信息,本示例性实施例对此不做特殊限定。
当前服务节点信息可以是当前服务节点的名称或者标识,还可以是其他信息,本示例性实施例对此不做特殊限定。
在步骤S1120中,当前节点根据目标仓信息获取对应的服务节点。
与目标仓信息对应的服务节点信息即为目标服务节点信息。该目标服务节点信息为辐射目标仓信息表征的仓库的服务节点的信息,该信息可以是服务节点的名称,也可以是该服务节点的标识,还可以是其他信息,本示例性实施例对此不做特殊限定。
在步骤S1130中,是否为当前节点。
对当前服务节点信息和目标服务节点信息进行匹配可以是将当前服务节点信息和目标服务节点信息进行比较,得到当前服务节点信息和目标服务节点信息相同或者不同的比较结果作为节点匹配结果。
举例而言,当当前服务节点信息为服务节点的标识,且该标识为A,而目标服务节点信息也为服务节点的标识,且标识为B时,将当前服务节点信息与目标服务节点信息进行匹配得到当前服务节点信息与目标服务节点信息不同的节点匹配结果;当当前服务节点信息为服务节点的标识,且该标识为A,而目标服务节点信息也为服务节点的标识,且标识也为A时,将当前服务节点信息与目标服务节点信息进行匹配得到当前服务节点信息与目标服务节点信息相同的节点匹配结果。
在步骤S1140中,获取节点链路网状。
在得到节点匹配结果,且节点匹配结果为当前服务节点信息与目标服务节点信息不同的节点匹配结果时,可以获取预先配置好的全局网状节点信息。
在步骤S1150中,计算最优节点链路。
在获取到中心服务节点存储的全局网状节点信息之后,可以在该全局网状节点信息中查询当前服务节点信息与目标服务节点信息的通信链路都包括哪些子服务节点,以将该子服务节点的标识或者名称确定为通信服务节点信息。
在全局网状节点信息中查询到与当前服务节点信息和目标服务节点信息对应的通信服务节点信息之后,按照全局网状节点信息中存储的通信服务节点信息的通信链路可以生成对应的候选传输路径。
进一步的,可以在候选传输路径中确定数据传输路径。
首先,分别获取与当前服务节点信息、通信服务节点信息和目标服务节点信息对应的通信强度信息。然后,对通信强度信息进行计算得到候选传输路径的路径通信耗时,并根据路径通信耗时在候选传输路径中确定数据传输路径。
具体的,该通信强度信息可以是能够反映各个服务节点的通信信号强度的信息。举例而言,该通信强度信息可以是信号强度或传输时间。
在得到当前服务节点信息、通信服务节点信息和目标服务节点信息的通信强度信息之后,可以对通信强度信息进行计算得到候选传输路径对应的路径通信耗时。
进一步的,当候选传输路径为多个时,可以得到多个路径通信耗时。因此,可以将多个路径通信耗时进行比较,以从中选择路径通信耗时最小的一条候选传输路径作为数据传输路径。
在步骤S1160中,构造数据传输结构。
将业务数据和数据传输路径构造成如图10所示的传输结构,该传输结构中包括传输业务数据和数据传输路径,以按照数据传输路径传输业务数据。
在步骤S1170中,当前节点发送到下一个节点。
当前服务节点将业务数据和数据传输路径发送到下一服务节点。
在步骤S1180中,判断目标仓是否为当前节点负责。
下一服务节点判断目标仓库是否为自身负责的仓库。由于每个服务节点中已经包括自身所辐射的仓库列表。因此,在仓库列表中查询是否包含目标仓信息即可确定目标仓库是否是这一服务节点负责的。
在步骤S1190中,向仓系统服务发送数据。
当前的服务节点向仓库系统服务发送业务数据。该业务数据是要向仓库下传的数据,可以包括订单数据和商品数据等业务明细数据。
在本公开的应用场景中,确定当前服务节点信息和目标服务节点信息之后,经过链路路径计算确定最优的数据传输路径,通过数据传输路径保证了可用的数据传输服务,提升了数据传输的时效性和有效性。并且,该数据传输路径能够通过动态检测的方式动态规划,保证了服务节点异常或者传输路径异常情况下的通信高可用性提升了数据传输方式的鲁棒性和灵活性。
此外,在本公开的示例性实施例中,还提供一种数据传输装置。图12示出了数据传输装置的结构示意图,如图12所示,数据传输装置1200可以包括:信息获取模块1210、信息匹配模块1220、路径计算模块1230和数据传输模块1240。其中:
信息获取模块1210,被配置为接收业务数据,并获取与业务数据对应的目标仓信息以及当前服务节点信息;信息匹配模块1220,被配置为确定目标仓信息对应的目标服务节点信息,并对当前服务节点信息和目标服务节点信息进行匹配得到节点匹配结果;路径计算模块1230,被配置为基于节点匹配结果,对当前服务节点信息和目标服务节点信息进行链路路径计算得到数据传输路径;数据传输模块1240,被配置为基于目标仓信息,按照数据传输路径传输业务数据。
上述数据传输装置1200的具体细节已经在对应的数据传输方法中进行了详细的描述,因此此处不再赘述。
应当注意,尽管在上文详细描述中提及数据传输装置1200的若干模块或者单元,但是这种划分并非强制性的。实际上,根据本公开的实施方式,上文描述的两个或更多模块或者单元的特征和功能可以在一个模块或者单元中具体化。反之,上文描述的一个模块或者单元的特征和功能可以进一步划分为由多个模块或者单元来具体化。
此外,在本公开的示例性实施例中,还提供了一种能够实现上述方法的电子设备。
下面参照图13来描述根据本发明的这种实施例的电子设备1300。图13显示的电子设备1300仅仅是一个示例,不应对本发明实施例的功能和使用范围带来任何限制。
如图13所示,电子设备1300以通用计算设备的形式表现。电子设备1300的组件可以包括但不限于:上述至少一个处理单元1310、上述至少一个存储单元1320、连接不同系统组件(包括存储单元1320和处理单元1310)的总线1330、显示单元1340。
其中,所述存储单元存储有程序代码,所述程序代码可以被所述处理单元1310执行,使得所述处理单元1310执行本说明书上述“示例性方法”部分中描述的根据本发明各种示例性实施例的步骤。
存储单元1320可以包括易失性存储单元形式的可读介质,例如随机存取存储单元(RAM)1321和/或高速缓存存储单元1322,还可以进一步包括只读存储单元(ROM)1323。
存储单元1320还可以包括具有一组(至少一个)程序模块1325的程序/实用工具1324,这样的程序模块1325包括但不限于:操作系统、一个或者多个应用程序、其它程序模块以及程序数据,这些示例中的每一个或某种组合中可能包括网络环境的实现。
总线1330可以为表示几类总线结构中的一种或多种,包括存储单元总线或者存储单元控制器、外围总线、图形加速端口、处理单元或者使用多种总线结构中的任意总线结构的局域总线。
电子设备1300也可以与一个或多个外部设备1500(例如键盘、指向设备、蓝牙设备等)通信,还可与一个或者多个使得用户能与该电子设备1300交互的设备通信,和/或与使得该电子设备1300能与一个或多个其它计算设备进行通信的任何设备(例如路由器、调制解调器等等)通信。这种通信可以通过输入/输出(I/O)接口1350进行。并且,电子设备1300还可以通过网络适配器1360与一个或者多个网络(例如局域网(LAN),广域网(WAN)和/或公共网络,例如因特网)通信。如图所示,网络适配器1360通过总线1330与电子设备1300的其它模块通信。应当明白,尽管图中未示出,可以结合电子设备1300使用其它硬件和/或软件模块,包括但不限于:微代码、设备驱动器、冗余处理单元、外部磁盘驱动阵列、RAID系统、磁带驱动器以及数据备份存储系统等。
通过以上的实施例的描述,本领域的技术人员易于理解,这里描述的示例实施例可以通过软件实现,也可以通过软件结合必要的硬件的方式来实现。因此,根据本公开实施例的技术方案可以以软件产品的形式体现出来,该软件产品可以存储在一个非易失性存储介质(可以是CD-ROM,U盘,移动硬盘等)中或网络上,包括若干指令以使得一台计算设备(可以是个人计算机、服务器、终端装置、或者网络设备等)执行根据本公开实施例的方法。
在本公开的示例性实施例中,还提供了一种计算机可读存储介质,其上存储有能够实现本说明书上述方法的程序产品。在一些可能的实施例中,本发明的各个方面还可以实现为一种程序产品的形式,其包括程序代码,当所述程序产品在终端设备上运行时,所述程序代码用于使所述终端设备执行本说明书上述“示例性方法”部分中描述的根据本发明各种示例性实施例的步骤。
参考图14所示,描述了根据本发明的实施例的用于实现上述方法的程序产品1400,其可以采用便携式紧凑盘只读存储器(CD-ROM)并包括程序代码,并可以在终端设备,例如个人电脑上运行。然而,本发明的程序产品不限于此,在本文件中,可读存储介质可以是任何包含或存储程序的有形介质,该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。
所述程序产品可以采用一个或多个可读介质的任意组合。可读介质可以是可读信号介质或者可读存储介质。可读存储介质例如可以为但不限于电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。
计算机可读信号介质可以包括在基带中或者作为载波一部分传播的数据信号,其中承载了可读程序代码。这种传播的数据信号可以采用多种形式,包括但不限于电磁信号、光信号或上述的任意合适的组合。可读信号介质还可以是可读存储介质以外的任何可读介质,该可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。
可读介质上包含的程序代码可以用任何适当的介质传输,包括但不限于无线、有线、光缆、RF等等,或者上述的任意合适的组合。
可以以一种或多种程序设计语言的任意组合来编写用于执行本发明操作的程序代码,所述程序设计语言包括面向对象的程序设计语言—诸如Java、C++等,还包括常规的过程式程序设计语言—诸如“C”语言或类似的程序设计语言。程序代码可以完全地在用户计算设备上执行、部分地在用户设备上执行、作为一个独立的软件包执行、部分在用户计算设备上部分在远程计算设备上执行、或者完全在远程计算设备或服务器上执行。在涉及远程计算设备的情形中,远程计算设备可以通过任意种类的网络,包括局域网(LAN)或广域网(WAN),连接到用户计算设备,或者,可以连接到外部计算设备(例如利用因特网服务提供商来通过因特网连接)。
本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本公开的其他实施例。本申请旨在涵盖本公开的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本公开的一般性原理并包括本公开未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本公开的真正范围和精神由权利要求指出。
Claims (10)
1.一种数据传输方法,其特征在于,所述方法包括:
接收业务数据,并获取与所述业务数据对应的目标仓信息以及当前服务节点信息;
确定所述目标仓信息对应的目标服务节点信息,并对所述当前服务节点信息和所述目标服务节点信息进行匹配得到节点匹配结果;
基于所述节点匹配结果,对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径;
基于所述目标仓信息,按照所述数据传输路径传输所述业务数据。
2.根据权利要求1所述的数据传输方法,其特征在于,所述对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径,包括:
确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息;
根据所述当前服务节点信息、所述通信服务节点信息和所述目标服务节点信息生成候选传输路径,并在所述候选传输路径中确定数据传输路径。
3.根据权利要求2所述的数据传输方法,其特征在于,所述在所述候选传输路径中确定数据传输路径,包括:
分别获取与所述当前服务节点信息、所述通信服务节点信息和所述目标服务节点信息对应的通信强度信息;
对所述通信强度信息进行计算得到所述候选传输路径的路径通信耗时,并根据所述路径通信耗时在所述候选传输路径中确定数据传输路径。
4.根据权利要求2所述的数据传输方法,其特征在于,所述确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息,包括:
获取预先配置好的全局网状节点信息;
基于所述全局网状节点信息,确定与所述当前服务节点信息和所述目标服务节点信息对应的通信服务节点信息。
5.根据权利要求4所述的数据传输方法,其特征在于,所述按照所述数据传输路径传输所述业务数据,包括:
对所述数据传输路径进行路由检测得到检测耗时;
基于所述检测耗时,按照所述数据传输路径传输所述业务数据。
6.根据权利要求5所述的数据传输方法,其特征在于,所述对所述数据传输路径进行路由检测得到检测耗时,包括:
获取检测数据,并以预设时长为间隔在所述数据传输路径中传输所述检测数据得到检测耗时。
7.根据权利要求5所述的数据传输方法,其特征在于,所述基于所述检测耗时,按照所述数据传输路径传输所述业务数据,包括:
若所述检测耗时为检测超时,更新所述全局网状节点信息;
基于更新后的所述全局节点信息,对所述当前服务节点信息和所述目标服务节点信息重新进行链路路径计算得到另一数据传输路径,以按照所述另一数据传输路径传输所述业务数据。
8.一种数据传输装置,其特征在于,包括:
信息获取模块,被配置为接收业务数据,并获取与所述业务数据对应的目标仓信息以及当前服务节点信息;
信息匹配模块,被配置为确定所述目标仓信息对应的目标服务节点信息,并对所述当前服务节点信息和所述目标服务节点信息进行匹配得到节点匹配结果;
路径计算模块,被配置为基于所述节点匹配结果,对所述当前服务节点信息和所述目标服务节点信息进行链路路径计算得到数据传输路径;
数据传输模块,被配置为基于所述目标仓信息,按照所述数据传输路径传输所述业务数据。
9.一种计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现权利要求1-7中任意一项所述的数据传输方法。
10.一种电子设备,其特征在于,包括:
处理器;
存储器,用于存储所述处理器的可执行指令;
其中,所述处理器被配置为经由执行所述可执行指令来执行权利要求1-7中任意一项所述的数据传输方法。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110631760.2A CN113765793B (zh) | 2021-06-07 | 2021-06-07 | 数据传输方法及装置、存储介质、电子设备 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110631760.2A CN113765793B (zh) | 2021-06-07 | 2021-06-07 | 数据传输方法及装置、存储介质、电子设备 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN113765793A true CN113765793A (zh) | 2021-12-07 |
CN113765793B CN113765793B (zh) | 2023-09-05 |
Family
ID=78787423
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202110631760.2A Active CN113765793B (zh) | 2021-06-07 | 2021-06-07 | 数据传输方法及装置、存储介质、电子设备 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN113765793B (zh) |
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114584490A (zh) * | 2022-03-25 | 2022-06-03 | 阿里巴巴(中国)有限公司 | 数据传输检测方法以及装置 |
Citations (13)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN103190161A (zh) * | 2010-11-02 | 2013-07-03 | 摩托罗拉移动有限责任公司 | 用于识别与地理区域相关联的移动站的方法和装置 |
WO2015000362A1 (zh) * | 2013-07-05 | 2015-01-08 | 华为技术有限公司 | 一种业务节点配置方法、业务节点池注册器及系统 |
WO2015070424A1 (zh) * | 2013-11-14 | 2015-05-21 | 华为技术有限公司 | 一种用户设备注册/路由更新的方法和设备 |
CN105933398A (zh) * | 2016-04-18 | 2016-09-07 | 乐视控股(北京)有限公司 | 内容分发网络中的访问请求转发方法和系统 |
US20170207994A1 (en) * | 2016-01-20 | 2017-07-20 | National Chiao Tung University | Network communication system, software-defined network controller and routing method thereof |
CN109327539A (zh) * | 2018-11-15 | 2019-02-12 | 上海天玑数据技术有限公司 | 一种分布式块存储系统及其数据路由方法 |
CN109862089A (zh) * | 2019-01-24 | 2019-06-07 | 网联清算有限公司 | 数据处理方法、装置、系统、计算机可读存储介质 |
CN109995817A (zh) * | 2017-12-29 | 2019-07-09 | 中移信息技术有限公司 | 一种服务调度方法及装置 |
CN110365747A (zh) * | 2019-06-24 | 2019-10-22 | 北京奇艺世纪科技有限公司 | 网络请求的处理方法、装置、服务器及计算机可读存储介质 |
CN110858840A (zh) * | 2018-08-23 | 2020-03-03 | 达音网络科技(上海)有限公司 | 大规模实时多媒体通信技术 |
CN110971432A (zh) * | 2018-09-29 | 2020-04-07 | 华为技术有限公司 | 一种数据传输方法以及相关装置 |
CN111385208A (zh) * | 2018-12-29 | 2020-07-07 | 广州市百果园信息技术有限公司 | 路由选择方法、装置、计算机设备及存储介质 |
CN112600914A (zh) * | 2020-12-07 | 2021-04-02 | 腾讯科技(深圳)有限公司 | 数据处理方法、装置、计算机可读介质及电子设备 |
-
2021
- 2021-06-07 CN CN202110631760.2A patent/CN113765793B/zh active Active
Patent Citations (13)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN103190161A (zh) * | 2010-11-02 | 2013-07-03 | 摩托罗拉移动有限责任公司 | 用于识别与地理区域相关联的移动站的方法和装置 |
WO2015000362A1 (zh) * | 2013-07-05 | 2015-01-08 | 华为技术有限公司 | 一种业务节点配置方法、业务节点池注册器及系统 |
WO2015070424A1 (zh) * | 2013-11-14 | 2015-05-21 | 华为技术有限公司 | 一种用户设备注册/路由更新的方法和设备 |
US20170207994A1 (en) * | 2016-01-20 | 2017-07-20 | National Chiao Tung University | Network communication system, software-defined network controller and routing method thereof |
CN105933398A (zh) * | 2016-04-18 | 2016-09-07 | 乐视控股(北京)有限公司 | 内容分发网络中的访问请求转发方法和系统 |
CN109995817A (zh) * | 2017-12-29 | 2019-07-09 | 中移信息技术有限公司 | 一种服务调度方法及装置 |
CN110858840A (zh) * | 2018-08-23 | 2020-03-03 | 达音网络科技(上海)有限公司 | 大规模实时多媒体通信技术 |
CN110971432A (zh) * | 2018-09-29 | 2020-04-07 | 华为技术有限公司 | 一种数据传输方法以及相关装置 |
CN109327539A (zh) * | 2018-11-15 | 2019-02-12 | 上海天玑数据技术有限公司 | 一种分布式块存储系统及其数据路由方法 |
CN111385208A (zh) * | 2018-12-29 | 2020-07-07 | 广州市百果园信息技术有限公司 | 路由选择方法、装置、计算机设备及存储介质 |
CN109862089A (zh) * | 2019-01-24 | 2019-06-07 | 网联清算有限公司 | 数据处理方法、装置、系统、计算机可读存储介质 |
CN110365747A (zh) * | 2019-06-24 | 2019-10-22 | 北京奇艺世纪科技有限公司 | 网络请求的处理方法、装置、服务器及计算机可读存储介质 |
CN112600914A (zh) * | 2020-12-07 | 2021-04-02 | 腾讯科技(深圳)有限公司 | 数据处理方法、装置、计算机可读介质及电子设备 |
Non-Patent Citations (2)
Title |
---|
EFTHYMIOS OIKONOMOU; ANGELOS ROUSKAS: "Selection of Service Nodes in Edge Computing Environments", 《2020 7TH INTERNATIONAL CONFERENCE ON INTERNET OF THINGS: SYSTEMS, MANAGEMENT AND SECURITY (IOTSMS)》 * |
蔡岳平;刘军;: "内容中心网络状态感知路由设计", 通信学报, no. 06 * |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114584490A (zh) * | 2022-03-25 | 2022-06-03 | 阿里巴巴(中国)有限公司 | 数据传输检测方法以及装置 |
CN114584490B (zh) * | 2022-03-25 | 2024-04-09 | 阿里巴巴(中国)有限公司 | 数据传输检测方法以及装置 |
Also Published As
Publication number | Publication date |
---|---|
CN113765793B (zh) | 2023-09-05 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN102369740B (zh) | 用于基于对等和广域网的组合发现的方法和装置 | |
CN111818136B (zh) | 数据处理方法、装置、电子设备及计算机可读介质 | |
US6330453B1 (en) | Map information providing method and system and terminal device used therein | |
CN103826203A (zh) | 公交运行预测方法和装置 | |
RU2658808C2 (ru) | Способы и системы для динамического обнаружения потребителей, зашедших на площадку | |
CN110334998A (zh) | 物流服务确定方法、装置、终端设备及存储介质 | |
US20090262015A1 (en) | Mobile communication device positioning system and method for enhancing position measurement by self learning algorithm | |
US20200110149A1 (en) | Asset tracking | |
US20230163998A1 (en) | Data processing method, device, electronic device and computer readable medium | |
WO2021068839A1 (zh) | 对象监听方法、装置、电子设备及计算机可读存储介质 | |
CN113765793A (zh) | 数据传输方法及装置、存储介质、电子设备 | |
CN111163458B (zh) | 数据采集方法、装置和系统 | |
US20200211094A1 (en) | Calling method and system, and electronic price tag device | |
CN106407480A (zh) | 一种信息查询方法和系统 | |
CN112288362B (zh) | 包裹重投递方法、包裹投递方法以及相关设备 | |
CN114501304A (zh) | 近域通信方法、装置、存储介质和电子设备 | |
US20150103738A1 (en) | Selecting an access point for determining position of a device based on traffic load information | |
CN111489540A (zh) | 智能设备控制方法、装置、计算机可读介质及电子设备 | |
JP2011196936A (ja) | ナビゲーション端末、広告配信システム、並びにナビゲーション端末の制御方法及びプログラム | |
CN111624624B (zh) | 差分数据的处理方法及装置 | |
US20110219082A1 (en) | Apparatus and method of communicating with local service | |
CN101742705A (zh) | 一种通信方法和系统 | |
US11455669B2 (en) | Method and apparatus for predicting wait times | |
US10530821B2 (en) | Distribution and reception method, and system | |
KR100587162B1 (ko) | 이동 통신 망에서의 지피에스를 활용한 중계기 통화량검출 방법 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |