(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221048418 8.6 (22)申请日 2022.05.06 (71)申请人 浪潮软件科技有限公司 地址 250100 山东省济南市高新区浪潮路 1036号浪潮科技园 (72)发明人 段其朴　付君伟　 (74)专利代理 机构 济南信达专利事务所有限公 司 37100 专利代理师 阚恭勇 (51)Int.Cl. G06F 9/54(2006.01) G06F 16/215(2019.01) G06F 16/23(2019.01) (54)发明名称 一种基于消息队列的机构数据整合实现方 法及装置 (57)摘要 本发明提供一种基于消息队列的机构数据 整合实现方法及装置， 属于计算机应用技术领 域， 本发明基于消息队列进行数据传递和同步， 将各个业务系统数据进行解耦， 并有效整合数 据， 快速实现对业务系统进行数据分发， 完成数 据更新， 解决数据缺少规范， 数据冗余和可信度 偏低的问题。 能够很有效的减少数据对接的工作 量， 快速的进行数据整合， 提高数据质量， 保证数 据的真实性、 完整性以及准确性。 权利要求书2页 说明书4页 附图2页 CN 114968620 A 2022.08.30 CN 114968620 A 1.一种基于消息队列的机构数据整合实现方法， 其特 征在于， 各个业务系统将自 己的机构数据实时发送至共享消息中间件， 接收数据后， 按照预先 配置的处理规则， 对 数据进行自动处理， 之后对所有 数据进行收集整合以及数据的持久化， 最后根据业 务系统需要 进行定时发版或者进行实时的数据推送。 2.根据权利要求1所述的方法， 其特 征在于， 首先需对各个业务系统进行单点登录集成， 通过系统后台管理配置对待集成的业务系 统做基础的配置， 需要业务系统提供基础信息， 系统为各个业务系统生成业务服务接口调 用的客户端编号和密钥； 其次， 设置统一的消息通道， 实现消息中间件集成； 最后， 制定同步 规则和数据格式， 并发布启用配置 。 3.根据权利要求2所述的方法， 其特 征在于， 消息中间件接收数据， 并进行对应 个性化处理； 个性化处理包括基础的日志模块， 可以对接收的数据进行记录、 追踪、 统计； 可根据业务系统 的操作标志位， 以及数据实际情况进行预编译处理， 完成数据的新增、 删除、 更新、 合并操作； 还可根据业务系统要求， 设置定制化的规则对数据进行格式化处理， 针对不同的业务 系统可定制不同的处 理规则。 4.根据权利要求3所述的方法， 其特 征在于， 将数据根据预先配置的规则进行清洗、 转换和加工， 形成格式规范、 标准统一的数据集 合， 方便后续的数据存 储和发布。 5.根据权利要求2所述的方法， 其特 征在于， 数据持久化是存储数据， 对所有处理的数据进行持久化， 将所处理的数据异步存储至 关系型数据库及缓存数据库中， 用于后续的查询调用。 6.根据权利要求5所述的方法， 其特 征在于， 数据发送提供对数据的管理功能， 以自行进行发版或根据业务系统要求进行实时分 发， 以及定时发版， 同时为各个 应用系统提供机构等各类 基础数据的查询服 务。 7.一种基于消息队列的机构数据整合实现装置， 其特 征在于， 包括数据接收模块、 个性 化数据处 理模块、 汇总整合模块、 数据持久化模块、 发送模块； 数据接收， 消息中间件接收数据， 并分发给对应 个性化处理模块； 个性化处理模块， 包括基础的日志模块， 可以对接收的数据进行记录、 追踪、 统计； 个性 化处理模块可根据业务系统的操作标志位， 以及数据实际情况进行预编译处理， 完成数据 的新增、 删除、 更新、 合并操作； 汇总整合， 汇总 整合模块用于将各个个性化处理模块中的数据根据预先配置的规则进 行清洗、 转换和 加工， 形成格式规范、 标准统一的数据集 合， 方便后续的数据存 储和发布； 数据持久化模块， 存 储数据， 对所有处 理的数据进行持久化； 数据发送模块， 提供对数据的管理功能， 可以自行进行发版或根据业务系统要求进行 实时分发， 以及定时发版， 同时为各个 应用系统提供 各类基础数据的查询服 务； 各个业务系统将自己的机构数据实时发送至共享消息 中间件， 对应的个性化数据处理 模块接收数据后， 按照预先配置的处理规则， 对数据进 行自动处理， 之后数据整合模块对所权　利　要　求　书 1/2 页 2 CN 114968620 A 2有数据进行收集整合以及数据的持久化， 最后根据业务系统需要进行定时发版或者进 行实 时的数据推送。 8.根据权利要求7 所述的装置， 其特 征在于， 首先需对各个业务系统进行单点登录集成， 通过系统后台管理配置对待集成的业务系 统做基础的配置， 需要业 务系统提供基础信息； 系统为各个业 务系统生成业 务服务接口调用的客户端编号和密钥； 其次， 设置统一的消息通道， 实现消息中间件集成； 最后， 制定同步 规则和数据格式， 并发布启用配置 。 9.根据权利要求7 所述的装置， 其特 征在于， 个性化处理模块还可根据业务系统要求， 设置定制化的规则对数据进行格式化处理； 针对不同的业 务系统可定制不同的处 理规则。 10.根据权利要求8所述的装置， 其特 征在于， 数据持久化模块将所处理的数据异步存储至关系型数据库及缓存数据库中， 用于后续 的查询调用。权　利　要　求　书 2/2 页 3 CN 114968620 A 3