一种基于消息总线的数据汇聚系统和方法

专利申请号：CN202211344591.5

公 开 号：CN116594988A

发 明 人：曹良晶 温昭琦 张隽 钱行 宋磊 彭顺超 赵晨晓 冀东旭 蓝海波 秦振 李梁 张鹏 

代 理 人：朱远枫

代理机构：南京纵横知识产权代理有限公司

专利类型：发明专利

申 请 日：20230815

公 开 日：20221031

专利主分类号：G06F16/215

关 键 词：消息报文 数据汇集 消息总线 调用 总线 插件 集群 任务配置模块 数据汇聚系统 消息报文发送 消息报文格式 参数生成 抽取数据 定义解析 反序列化 设置数据 数据汇聚 数据填充 数据转换 异构系统 源端地址 转换方式 接收端 重复 发布 开发 

摘      要：本发明公开了一种基于消息总线的数据汇聚系统和方法，方法包括设置数据汇集任务的参数，根据参数生成各数据汇集任务；定义基于protobuf插件的消息报文格式并发布；根据所述任务配置模块生成的数据汇集任务，从源端地址中抽取数据，根据数据汇聚任务中设置的转换方式将数据转换为接收端能够识别的格式和内容；调用protobuf插件提供的接口将数据填充到消息报文名称对应的消息报文中，调用消息总线接口将消息报文发送至总线集群；调用消息总线接口从总线集群接收消息报文，将消息报文反序列化，按照消息报文的定义解析消息报文内容。本发明可以提高异构系统之间的数据汇集效率，减少重复开发成本，具有很强的实用性。