数据发布与订阅系统、数据发布方法、数据订阅方法.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115065733A(43)申请公布日2022.09.16(21)申请号202210388604.2(22)申请日2022.04.14(71)申请人中国银行股份有限公司地址100818北京市西城区复兴门内大街1号(72)发明人张帆(74)专利代理机构北京三友知识产权代理有限公司11127专利代理师郝博汤在彦(51)Int.Cl.H04L69/16(2022.01)H04L67/1095(2022.01)H04L49/9057(2022.01)H04L47/34(2022.01)权利要求书3页说明书11页附图4页(54)发明名称数据发布与订阅系统、数据发布方法、数据订阅方法(57)摘要本发明提供了一种数据发布与订阅系统、数据发布方法、数据订阅方法，应用于分布式技术领域，该系统包括：数据发布装置，用于将数据生成UDP数据报，并发送至数据接收装置，UDP数据报设有唯一的消息序号；在设定时长内无UDP数据报时，向数据接收装置发送心跳数据报，心跳数据报带有消息序号；在接收到重送请求后，向数据接收装置标识对应的数据接收装置发送目标消息序号对应的数据包；数据接收装置，用于在接收到UDP数据报后，检查UDP数据报是否缺失；在接收到心跳数据报后，检查UDP数据报是否缺失；在确定UDP数据报缺失后，向数据发布装置发送重送请求。本发明可以实现可靠、高效、快速、公平的数据发送与订阅。CN115065733ACN115065733A权利要求书1/3页1.一种数据发布与订阅系统，其特征在于，包括：数据发布装置，用于在接收到数据后，将所述数据生成UDP数据报，并发送至数据接收装置，所述UDP数据报的消息序号栏位设有唯一的消息序号；在设定时长内无UDP数据报时，向数据接收装置发送心跳数据报，所述心跳数据报带有上一次发送的UDP数据报的消息序号；在接收到重送请求后，向数据接收装置标识对应的数据接收装置发送目标消息序号对应的数据包，所述数据包为TCP数据包，且所述TCP数据包中的内容与所述目标消息序号对应的UDP数据报的内容一致；数据接收装置，用于在接收到UDP数据报后，基于UDP数据报的消息序号，检查UDP数据报是否缺失；在接收到心跳数据报后，基于心跳数据报带有的上一次发送的UDP数据报的消息序号，检查UDP数据报是否缺失；在确定UDP数据报缺失后，向数据发布装置发送重送请求，所述重送请求带有数据接收装置标识和目标消息序号。2.如权利要求1所述的系统，其特征在于，数据发布装置还用于：在生成UDP数据报时，在UDP数据报的校验码栏位生成所述UDP数据报的校验码；数据接收装置还用于：在接收到UDP数据报后，基于所述UDP数据报的校验码检查UDP数据报的完整性；在接收到数据包后，获得所述数据包中与UDP数据报对应的校验码，基于所述校验码检查UDP数据报的完整性；在检查结果为不完整时，向数据发布装置发送重送请求。3.如权利要求1所述的系统，其特征在于，数据接收装置有多个；多个数据接收装置和数据发布装置组成通讯组；数据接收装置还用于：在刚加入通讯组且首次接收到数据发布装置的UDP数据报时，若所述UDP数据报的消息序号比预期大，根据数据需求，判断是否需要获取小于所述消息序号的UDP数据报，若是，向数据发布装置发送重送请求。4.如权利要求1所述的系统，其特征在于，数据接收装置具体用于：在非首次接收到数据发布装置的UDP数据报，且UDP数据报的消息序号比预期大时，确定UDP数据报存在缺失；根据UDP数据报的消息序号和预期，获得目标消息序号；在接收到数据发布装置的UDP数据报，且UDP数据报的消息序号比预期小时，确定UDP数据报乱序，丢弃所述UDP数据报；在接收到数据发布装置的数据包，且数据包的消息序号比预期小时，确定UDP数据报乱序，丢弃所述数据包。5.如权利要求1所述的系统，其特征在于，数据接收装置具体用于：在心跳数据报带有的上一次发送的UDP数据报的消息序号比预期大时，确定UDP数据报存在缺失；根据上一次发送的UDP数据报的消息序号和预期，获得目标消息序号。6.如权利要求1所述的系统，其特征在于，数据接收装置还用于：采用NIO非阻塞方式接收UDP数据报和/或数据包，将接收的UDP数据报和/或数据包按照正确的顺序保存到环形无锁队列中，所述环形无锁队列中的UDP数据报和/或数据包在处理时采用独占CPU核心的方式。7.如权利要求1所述的系统，其特征在于，数据接收装置还用于：当超过设定时长未收到任何数据报时，生成报警信息。8.如权利要求1所述的系统，其特征在于，数据接收装置为数据订阅端；2CN115065733A权利要求书2/3页所述数据订阅端用于对环形无锁队列中的UDP数据和/或数据包进行处理。9.如权利要求1所述