(19)国家知识产权局
(12)发明 专利
(10)授权公告 号
(45)授权公告日
(21)申请 号 202210964940.7
(22)申请日 2022.08.12
(65)同一申请的已公布的文献号
申请公布号 CN 115037782 A
(43)申请公布日 2022.09.09
(73)专利权人 南瑞轨道交通 技术有限公司
地址 211500 江苏省南京市江北新区高新
路20号
(72)发明人 李冰 胡波 石琦 孟凡辉 张浩
(74)专利代理 机构 南京苏高专利商标事务所
(普通合伙) 32204
专利代理师 王恒静
(51)Int.Cl.
H04L 67/14(2022.01)
H04L 69/163(2022.01)H04L 9/40(2022.01)
(56)对比文件
CN 1658578 A,20 05.08.24
CN 103888300 A,2014.0 6.25
审查员 郭红
(54)发明名称
一种基于双网双链路的实时数据传输方法
及系统
(57)摘要
本发明公开了一种基于双网双链路的实时
数据传输方法及系统, 该方法包括: 所有节点部
署通信服务模块, 通过A网和B网与目标节 点上的
通信服务模块分别建立TCP链接, 当前节点上运
行的应用模块对外发送数据, 需要通过通信服务
模块进行网络传输, 通信服务模块接收到本节点
应用模块发送的数据, 计算出唯一性标签, 并组
成新数据包, 分别通过A网和B网同时发往目标节
点的A网地址和B网地址; 目标节点通信服务模块
接收数据, 解析数据中的唯一性标签, 与本节点
之前保存的标签集合进行比对, 分离出时间戳和
唯一标签的数据, 存入数据缓存中。 本发明保证
当网络出现故障, 需要发生切换时, 数据传输不
受影响, 应用层保证数据不丢失。
权利要求书2页 说明书8页 附图1页
CN 115037782 B
2022.11.18
CN 115037782 B
1.一种基于双网双链路的实时数据传输方法, 其特 征在于, 该 方法包括以下步骤:
S1当前发送节点M的主线程读取预定义配置, 从而获取所有需要通信节点的A网和B网
的地址;
S2所述主线程轮询以上的所有地址, 按照每个地址启动一个线程, 并在线程内对目标
地址建立TCP链接, 与对应目标节点N在A网和B网的地址建立的TCP链接分别记为M ‑Na链接
和M‑Nb链接, M ‑Na链接所在的线程称为M ‑Na发送线程, M ‑Nb链接所在的线程称为M ‑Nb发送
线程;
S3当前发送节点M的应用模块发送原数据至当前发送节点M的通信服务模块, 所述通信
服务模块对所述数据进行加密运 算, 得到一个唯一 性标签;
S4获取当前时间, 进而得到时间戳, 将所述 时间戳置于所述唯一性标签前, 并将所述时
间戳和唯一 性标签放在原数据字段的前面, 组成新数据包;
S5所述新数据包存入所述目标节点N启动的M ‑Na发送线程和M ‑Nb发送线程中, 接收到
新数据包后, 通过线程内的TCP链接给目标地址发送数据;
所述S5中通过线程内的TCP链接给目标地址发送数据, 具体包括:
S51当前发送节点M通过A网尝试与目标节点N的通信服务模块建立M ‑Na链接, 目标节点
N的通信服务模块的接收线程获取到TCP链接请求后, 节 点N的接收线程新建一个接收线程,
放置与节点M的通信服 务模块建立 好M‑Na接收线程;
S52当前发送节点M通过M ‑Na线程发送的数据, 就是目标节点N通过步骤S51中接收线程
中的M‑Na链接收到的;
S53所述M ‑Na接收线程收到数据后, 首先从新数据包中取出 时间戳和唯一性标签, 通过
唯一性标签至当前发送节点M上存储的HASH表中查询, 把唯一性标签和时间戳作为一对键
值存入HAS H表, 并把分离出时间戳和唯一性标签后的数据, 存入数据缓存中, 供应用模块后
续处理;
S54此时, 目标节点N上的M ‑Nb接收线程也收到当前发送节点M通过M ‑Nb链接发送的同
样数据后, 到HASH表 中进行比对, 由于A网接收的数据已经放入HASH表中, 即HASH表中已经
有此数据的唯一 性标签, 此时丢弃当前 数据包, M ‑Nb接收线程继续 等待接收数据。
2.根据权利要求1所述的基于双网双链路的实时数据传输方法, 其特征在于, 所述S1
中, 主线程通过当前发送节点M的通信服务模块启动, 且所述主线程用于启动若干个接收线
程、 一个监护线程以及若干个发送线程, 所述监护线程用于动态监测所有TCP链接的线程,
当监测到存在 线程僵死, 重启相应线程, 所述 发送线程用于发送当前发送节点的TCP链接请
求, 并定时检测链接, 若链接中断, 则重新建立链接, 所述接收线程用于接收目标节点N的
TCP链接请求, 并分配出新的线程与发送端建立链接 。
3.根据权利要求1所述的基于双网双链路的实时数据传输方法, 其特征在于, 所述S3
中, 所述加密运 算采用的方法为MD5算法, 进 而计算出128位的唯一 性标签。
4.根据权利要求1所述的基于双网双链路的实时数据传输方法, 其特征在于, 该方法还
包括: 定时清理所述HASH表中的键值对。
5.一种基于双网双链路的实时数据传输系统, 其特征在于, 该系统包括: 当前发送节点
M和目标节点 N, 所述当前发送 节点M与目标节点之间设置有双网络, 记为A网和B网;
所述当前发送节点M的主线程读取预定义配置, 从而获取所有需要通信节点的A网和B权 利 要 求 书 1/2 页
2
CN 115037782 B
2网的地址;
当前发送节点M的主线程轮询以上的所有地址, 按照每个地址启动一个线程, 并在线程
内对目标地址建立TCP链接, 与对应目标节点N在A网和B网的地址建立的TCP链接分别记为
M‑Na链接和M ‑Nb链接, M ‑Na链接所在的线程称为M ‑Na发送线程, M ‑Nb链接所在的线程称为
M‑Nb发送线程;
当前发送节点M的应用模块发送原数据至当前发送节点M的通信服务模块, 所述通信服
务模块对所述数据进行加密运 算, 得到一个唯一 性标签;
获取当前时间, 进而得到时间戳, 将所述 时间戳置于所述唯一性标签前, 并将所述时间
戳和唯一 性标签放在原数据字段的前面, 组成新数据包;
所述新数据包存入所述目标节点N启动的M ‑Na发送线程和M ‑Nb发送线程中, 接收到新
数据包后, 通过线程内的TCP链接给目标地址发送数据;
所述通过线程内的TCP链接给目标地址发送数据, 具体包括:
当前发送节点M通过A网尝试与目标节点N的通信服务模块建立M ‑Na链接, 目标节点N的
通信服务模块的接收线程获取到TCP链接请求后, 节点N的接收线程新建一个接收线程, 放
置与节点M的通信服 务模块建立 好M‑Na接收线程;
当前发送节点M通过M ‑Na线程发送的数据, 就是目标节点N通过步骤S51中接收线程中
的M‑Na链接收到的;
所述M‑Na接收线程收到数据后, 首先从新数据包中取出时间戳和唯一性标签, 通过唯
一性标签至当前发送节点M上存储的HASH表中查询, 把唯一性标签和时间戳作为一对键值
存入HASH表, 并把分离出时间戳和唯一性标签后的数据, 存入数据缓存中, 供应用模块后续
处理;
此时, 目标节点N上的M ‑Nb接收线程也收到当前发送节点M通过M ‑Nb链接发送的同样数
据后, 到HASH表中进行比对, 由于A网接收的数据已经放入HASH表 中, 即HASH表 中已经有此
数据的唯一 性标签, 此时丢弃当前 数据包, M ‑Nb接收线程继续 等待接收数据。
6.根据权利要求5所述的基于双网双链路的实时数据传输系统, 其特征在于, 所述当前
发送节点M的主线程通过当前发送节 点M的通信服务模块启动, 且所述主线程用于启动若干
个接收线程、 一个监护线程以及若干个发送线程, 所述监护线程用于动态监测所有TCP链接
的线程, 当监测到存在线程僵死, 重启相应线程, 所述发送线程用于发送当前发送节点的
TCP链接请求, 并定时检测链接, 若链接中断, 则重新建立链接, 所述接收线程用于接收目标
节点N的TCP链接请求, 并分配出新的线程与发送端建立链接 。
7.根据权利要求5所述的基于双网双链路的实时数据传输系统, 其特征在于, 所述加密
运算采用的方法为MD5算法, 进 而计算出128位的唯一 性标签。
8.根据权利要求5所述的基于双网双链路的实时数据传输系统, 其特征在于, 该系统还
包括定时清理所述HASH表中的键值对。权 利 要 求 书 2/2 页
3
CN 115037782 B
3
专利 一种基于双网双链路的实时数据传输方法及系统
文档预览
中文文档
12 页
50 下载
1000 浏览
0 评论
0 收藏
3.0分
温馨提示:本文档共12页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
本文档由 SC 于 2024-02-18 22:27:19上传分享