本技术属于数据传输,尤其涉及数据定向传输方法、装置、终端设备及存储介质。
背景技术:
1、在分布式系统中,gossip协议因其高可扩展性、容错性和最终一致性而被广泛应用,然而,非定向的数据传输方式是gossip协议的显著特征,节点之间传输数据的方式是将数据从源头节点传输至所有节点,非定向的传输方式会导致不必要的资源浪费,特别是在需要精确控制数据传输路径或频率的场景中,因此如何实现gossip协议下数据的定向传输是亟需解决的问题。
技术实现思路
1、本技术实施例提供了数据定向传输方法、装置、终端设备及存储介质,可以解决在gossip网络中数据不能定向传输的问题。
2、第一方面,本技术实施例提供了一种数据定向传输方法,应用于分布式网络系统中的当前数据传输的直连路径,所述分布式网络系统包括多个节点,所述第一节点为当前发送数据的节点,所述数据定向由源头节点传输至目标节点,所述数据传输方法由第一节点执行,所述数据定向传输方法包括:
3、根据所述第一节点对应的拓扑图,筛选所述第一节点当前发送数据的第二节点;
4、向筛选出的所述第二节点发送所述数据,以使所述数据通过所述第二节点所在的可达路径传输至所述目标节点。
5、可选的,每个直连路径由第一节点和对应直连的第二节点形成,所述可达路径由连续连接的多个直连路径形成,所述根据所述第一节点对应的拓扑图,筛选所述第一节点当前发送数据的第二节点,包括:
6、根据所述第一节点对应的拓扑图结合源头节点和目标节点,得到所有可达路径;
7、根据所述可达路径筛选所述第一节点当前发送数据的第二节点。
8、可选的,所述根据所述可达路径筛选所述第一节点当前发送数据的第二节点包括:
9、根据每条可达路径上每条直连路径的网络延时,得到每条可达路径的权重;
10、根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点。
11、可选的,所述根据每条可达路径上每条直连路径的网络延时,得到每条可达路径的权重包括:
12、根据每条可达路径上每条直连路径的网络延时,得到每条直连路径平均网络延时;
13、每条直连路径平均网络延时,得到每条可达路径的网络延时;
14、所述每条可达路径的网络延时作为每条可达路径的权重。
15、可选的,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点之前包括:
16、根据预设数据传输规则,确定可达路径权重和可达路径跳数的优先级。
17、可选的,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点包括:
18、当可达路径权重优先级大于可达路径跳数优先级时,确定当前权重最小的可达路径数量;
19、当权重最小的可达路径大于1时,从所有权重最小的可达路径中筛选跳数最少的可达路径;
20、根据当前跳数最少的可达路径中筛选所述第一节点当前发送数据的最优第二节点。
21、可选的,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点还包括:
22、当可达路径权重优先级小于可达路径跳数优先级时,确定当前跳数最小的可达路径数量;
23、当跳数最小的可达路径大于1时,从所有跳数最少的可达路径中筛选权重最小的可达路径;
24、根据当前权重最小的可达路径中筛选所述第一节点当前发送数据的最优第二节点。
25、第二方面,本技术实施例提供了一种数据定向传输装置,应用于分布式网络系统中的当前数据传输的直连路径,所述分布式网络系统包括多个节点,所述第一节点为当前发送数据的节点,所述数据定向由源头节点传输至目标节点,所述数据传输方法由第一节点执行,所述传输装置包括:筛选模块和传输模块;
26、所述筛选模块,用于根据所述第一节点对应的拓扑图,筛选所述第一节点当前发送数据的第二节点;
27、所述传输模块,用于向筛选出的所述第二节点发送所述数据,以使所述数据通过所述第二节点所在的可达路径传输至所述目标节点。
28、可选的,每个直连路径由第一节点和对应直连的第二节点形成,所述可达路径由连续连接的多个直连路径形成,所述筛选模块包括:
29、确定可达路径单元,根据所述第一节点对应的拓扑图结合源头节点和目标节点,得到所有可达路径;
30、第一筛选单元,根据所述可达路径筛选所述第一节点当前发送数据的第二节点。
31、可选的,所述第一筛选单元包括:
32、权重单元,根据每条可达路径上每条直连路径的网络延时,得到每条可达路径的权重;
33、第二筛选单元,根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点。
34、可选的,所述权重单元包括:
35、直连路径权重单元,根据每条可达路径上每条直连路径的网络延时,得到每条直连路径平均网络延时;
36、可达路径权重单元,每条直连路径平均网络延时,得到每条可达路径的网络延时;
37、第一权重单元,所述每条可达路径的网络延时作为每条可达路径的权重。
38、可选的,所述第二筛选单元包括:
39、优先级确定单元,根据预设数据传输规则,确定可达路径权重和可达路径跳数的优先级。
40、可选的,所述第二筛选单元还包括:
41、第一优先级确定单元,当可达路径权重优先级大于可达路径跳数优先级时,确定当前权重最小的可达路径数量;
42、第一确定单元,当权重最小的可达路径大于1时,从所有权重最小的可达路径中筛选跳数最少的可达路径;
43、第三筛选单元,根据当前跳数最少的可达路径中筛选所述第一节点当前发送数据的最优第二节点。
44、可选的,所述第二筛选单元还包括:
45、第二优先级确定单元,当可达路径权重优先级小于可达路径跳数优先级时,确定当前跳数最小的可达路径数量;
46、第二确定单元,当跳数最小的可达路径大于1时,从所有跳数最少的可达路径中筛选权重最小的可达路径;
47、第四筛选单元,根据当前权重最小的可达路径中筛选所述第一节点当前发送数据的最优第二节点。
48、第三方面,本技术实施例提供了一种终端设备,包括:存储器、处理器以及存储在所述存储器中并可在所述处理器上运行的计算机程序,所述处理器执行所述计算机程序时实现如上述任一项所述的方法。
49、第四方面,本技术实施例提供了一种计算机可读存储介质,所述计算机可读存储介质存储有计算机程序,所述计算机程序被处理器执行时实现如上述任一项所述的方法。
50、第五方面,本技术实施例提供了一种计算机程序产品,当计算机程序产品在终端设备上运行时,使得终端设备执行上述第一方面中任一项所述的清理方法。
51、可以理解的是,上述第二方面至第五方面的有益效果可以参见上述第一方面中的相关描述,在此不再赘述。
52、本技术实施例与现有技术相比存在的有益效果是:
53、本技术根据所有第一节点形成的拓扑图可以推知该网络结构下完整拓扑信息,根据该拓扑信息筛选出当前第一节点需发送数据的第二节点,当数据到达第二节点后将该节点作为第一节点,继续筛选第二节点,直至数据通过第二节点所在的可达路径传输至目标节点,本技术通过该方法实现了gossip网络协议下数据的定向传输,提高数据传输的效率。
1.一种数据定向传输方法,应用于分布式网络系统中,所述分布式网络系统包括多个节点,所述第一节点为当前发送数据的节点,所述数据定向由源头节点传输至目标节点,其特征在于,所述数据定向传输方法由第一节点执行,所述数据定向传输方法包括:
2.根据权利要求1所述的一种数据定向传输方法,其特征在于,每个直连路径由第一节点和对应直连的第二节点形成,所述可达路径由连续连接的多个直连路径形成,所述根据所述第一节点对应的拓扑图,筛选所述第一节点当前发送数据的第二节点,包括:
3.根据权利要求2所述的一种数据定向传输方法,其特征在于,所述根据所述可达路径筛选所述第一节点当前发送数据的第二节点包括:
4.根据权利要求3所述的一种数据定向传输方法,其特征在于,所述根据每条可达路径上每条直连路径的网络延时,得到每条可达路径的权重包括:
5.根据权利要求3所述的一种数据定向传输方法,其特征在于,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点之前包括:
6.根据权利要求1-5任一项所述的一种数据定向传输方法,其特征在于,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点包括:
7.根据权利要求1-5任一项所述的一种数据定向传输方法,其特征在于,所述根据每条可达路径权重和每条可达路径跳数筛选所述第一节点当前发送数据的最优第二节点还包括:
8.一种数据定向传输装置,应用于分布式网络系统中的当前数据传输的直连路径,所述分布式网络系统包括多个节点,所述第一节点为当前发送数据的节点,所述数据定向由源头节点传输至目标节点,其特征在于,所述数据传输方法由第一节点执行,其特征在于,所述传输装置包括:筛选模块和传输模块;
9.一种终端设备,包括存储器、处理器以及存储在所述存储器中并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现如权利要求1至7任一项所述的方法。
10.一种计算机可读存储介质,所述计算机可读存储介质存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至7任一项所述的方法。