(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111336738.1 (22)申请日 2021.11.12 (71)申请人 上海铂铸信息科技有限公司 地址 200032 上海市宝山区高逸路1 12-118 号3幢8472室 (72)发明人 唐勇骅　 (74)专利代理 机构 上海智力专利商标事务所 (普通合伙) 31105 代理人 周涛 (51)Int.Cl. H04L 67/565(2022.01) H04L 67/5682(2022.01) H04L 67/5683(2022.01) H04L 9/40(2022.01) H04L 43/50(2022.01) (54)发明名称 适于多版本时序数据传输和重放的系统及 方法 (57)摘要 本发明公开了一种适于多版本时序数据传 输和重放的系统及方法， 所述系统包括客户端， 用于根据用户权限， 向服务端发送消息订阅请 求， 并接收订阅的消息； 服务端， 用于标准化定义 消息的数据结构， 该数据结构中至少包括消息分 类、 版本信息、 数据包标识号和消息发送时间； 将 上游数据源适配成具有所述数据结构的消息； 接 收客户端的消息订阅请求， 根据用户权限和消息 的版本信息对请求订阅的消息进行校验， 校验通 过后将消息回传给客户端； 根据所述数据包 标识 号和消息发送时间重放所述消息； 网络传输模 块， 用于所述客户端与服务端之间的数据传输。 本发明对于不同的数据源只需简单增加对应的 消息适配管 理模块即可完成数据的发布， 同时能 有效隔离数据源的变化对下游业 务系统的影响。 权利要求书2页 说明书11页 附图5页 CN 114338797 A 2022.04.12 CN 114338797 A 1.一种适于多版本时序数据传输和重放的系统， 其特 征在于， 包括： 客户端， 用于根据用户权限， 向服 务端发送消息订阅请求， 并接收订阅的消息； 服务端， 用于标准化定义消息的数据结构， 该数据结构中至少包括消息分类、 版本信 息、 数据包标识 号和消息发送时间； 将上游数据源适配成具有 所述数据结构的消息； 接收客 户端的消息订阅请求， 根据用户权限和消息的版本信息对请求订阅的消息进行校验， 校验 通过后将消息回传给用户端； 根据所述数据包标识号和 消息发送时间重放所述消息； 网络传输模块， 用于所述 客户端与服 务端之间的数据传输 。 2.根据权利要求1所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述客 户端包括消息订阅模块和应用程序接口； 所述消息订阅模块适于根据用户权限进 行消息订 阅管理； 所述应用程序接口用于 接入用户端订阅和接收业 务消息。 3.根据权利要求2所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述客 户端还包括数据更新缓存单元， 用于缓存消息于内存中， 并根据新接 收的消息对内存中的 快照进行合并更新。 4.根据权利要求2所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述服 务端包括多个并联的分别对应于不同上游数据源的消息管理适配模块、 发布订阅模块和数 据包组装模块； 各所述消息管理适配模块的输入端连接至与其对应的上游数据源， 各所述 消息管理适配模块的输出端均连接至所述发布订阅模块， 所述发布订阅模块的输入端通过 所述网络传输模块连接至所述客户端以接收订阅请求， 所述 发布订阅模块的输出端连接至 所述数据包组装模块的输入端， 所述数据包组装模块的输出端连接至通过所述网络传输模 块连接至所述客户端以回传订阅的消息； 所述消息管理适配模块适于定义所述数据结构， 并将上游数据源适配成具有所述数据结构的消息； 所述 发布订阅模块适于接收客户端的消 息订阅请求， 根据消息类别、 用户权限和消息的版本信息对请求订阅的消息进 行校验， 校验 通过后将消息回传给用户端； 所述数据包组装模块用于将消息组装成具有 所述数据结构的 数据包。 5.根据权利要求4所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述服 务端还包括用户权限管理模块， 所述用户权限管理模块 适于进行 账户权限管理。 6.根据权利要求4所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述服 务端还包括日志模块， 所述日志模块 适于存储记录所述数据包， 以离线重放。 7.根据权利要求4所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述用 户端还包括多个并联的分别对应于不同版本消息的解码 器， 所述服务端还包括多个并联的 分别对应于不同版本消息的编码器， 各 所述编码器与各 所述解码器一 一对应。 8.根据权利要求4所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述消 息管理适配模块包括数据结构抽象及标准化定义单元、 分类单元和适配单元； 所述发布订 阅模块包括多个并联 的不同版本的发布单元、 订阅单元； 所述数据结构抽象及标准化定义 单元用于将上游数据源定义成所述数据结构， 所述分类单元用于根据所述数据结构中的版 本信息将该数据源分成不同的版本， 所述适配单元用于将不同版本的数据源与所述 发布订 阅模块中对应版本的发布端口相匹配。 9.根据权利要求8所述的适于多版本时序数据传输和重放的系统， 其特征在于， 所述发 布订阅模块包括多个并联 的不同版本的发布单元、 订阅单元、 权限及版本校验单元和发送权　利　要　求　书 1/2 页 2 CN 114338797 A 2队列单元； 各所述发布单元用于发布不同版本的信息， 所述订阅单元用于接 收消息订阅请 求， 所述权限及版本校验单元用于根据用户权限和信息版本对拟订阅消息与发布的消息进 行一致性校验， 所述发送队列单元用于存储待发送的消息； 所述适配单元用于将不同版本 的数据源与各 所述发布单 元相匹配。 10.一种适于多版本时序数据传输和重放的方法， 其特 征在于， 包括以下步骤： (1)在服务端建立用户权限列表， 并按照含有版本信息的标准化数据结构定义不同的 上游数据源， 形成结构化消息， 同时保存该 结构化消息的副本以备重放； (2)在客户端向服 务端发送订阅消息的请求； (3)服务端对请求订阅的消息进行权限和版本校验， 如校验成功， 则继续到步骤(4)， 如 校验失败， 则返回步骤(2)； (4)客户端创建对应版本的消息解码器； (5)服务端建立具有版本信息的消息发送队列， 同时创建对应版本的消息编码器； (6)服务端对消息进行编码， 组装成数据包后发送至客户端。 11.根据权利要求10所述的适于多版本时序 数据传输和重放的方法， 其特征在于， 还包 括步骤(7)： 客户端建立数据更新缓存并构建索引， 并根据新接收的消息对内存中的快照进 行合并更新。 12.根据权利要求10所述的适于多版本时序 数据传输和重放的方法， 其特征在于， 步骤 (1)中所述标准化数据结构包括数据包头和数据承载域， 所述数据包头包括数据属 性信息 和日志信息， 所述数据承载域包括数据的实体信息 。 13.根据权利要求12所述的适于多版本时序 数据传输和重放的方法， 其特征在于， 所述 数据包头包括消息起始标志、 消息长度、 消息时间、 包序列号、 消息一级分类、 消息二级分 类、 消息版本号和校验码。 14.根据权利要求12所述的适于多版本时序 数据传输和重放的方法， 其特征在于， 所述 数据承载域包括数据包内的数据记录条数、 记录字段域掩码和记录字段域内容； 所述记录 字段域掩码是指对不同的数据消息中针对每 个字段标识掩码， 以实现数据的增量发送。权　利　要　求　书 2/2 页 3 CN 114338797 A 3