(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211199714.0 (22)申请日 2022.09.29 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 郭峰　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 崔清杨 (51)Int.Cl. G06F 9/54(2006.01) G06F 11/14(2006.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) (54)发明名称 一种消息传输方法、 装置、 电子设备、 及计算 机存储介质 (57)摘要 本申请公开了一种消息传输方法、 装置、 电 子设备、 及计算机存储介质， 可应用于大数据领 域或金融领域。 该方法包括在接收到前端应用发 送的待传输消息时， 将待传输消息进行存储； 基 于待传输消息携带的需求， 将待传输消息转换成 目标消息； 在确定目标消息与待传输消息存在一 致性时， 将目标消息发送给目标应用， 目标应用 是基于待传输消息携带的请求确定的。 在本方案 中， 通过将CMQ和MQ两者之间消息并发优化， 转换 传输高效的机制方法， 以在CMQ和MQ之间实现消 息传输， 以解决CMQ和MQ之间消息并发不一致问 题， 进而避免由于消息收发并发数不一致导致的 消息阻塞。 权利要求书1页 说明书9页 附图4页 CN 115495266 A 2022.12.20 CN 115495266 A 1.一种消息传输方法， 其特 征在于， 应用于中转处 理器， 所述方法包括： 在接收到前端应用发送的待传输消息时， 将所述待传输消息进行存 储； 若确定所述待传输消息为CMQ类型的消息， 基于所述待传输消息携带的需求， 将所述待 传输消息转换成目标消息； 在确定所述目标消息与所述待传输消息存在一致性 时， 将所述目标消息发送给目标应 用， 所述目标应用是基于所述待传输消息携带的请求确定的。 2.根据权利要求1所述的方法， 其特 征在于， 还 包括： 将所述目标消息进行 备份， 并存 储； 对所述存 储的目标消息进行打标 标注， 以便后续进行 数据回溯。 3.根据权利要求1所述的方法， 其特 征在于， 还 包括： 在接收到前端应用发送的待传输消息之前， 对前端应用发送的待传输消息进行监控。 4.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 若确定所述待传输消息为MQ类型的消息， 基于所述待传输消息携带的需求， 将所述待 传输消息转换成目标消息； 在确定所述目标消息与所述待传输消息存在一致性 时， 将所述目标消息发送给目标应 用， 所述目标应用是基于所述待传输消息携带的请求确定的。 5.一种消息传输装置， 其特 征在于， 应用于中转处 理器， 所述装置包括： 存储单元， 用于在接收到前端应用发送的待传输消息时， 将所述待传输消息进行存 储； 处理单元， 用于若确定所述待传输消息为CMQ类型的消息， 基于所述待传输消息携带的 需求， 将所述待传输消息转换成目标消息； 在确定所述 目标消息与所述待传输消息存在一 致性时， 将所述目标消息发送给目标应用， 所述 目标应用是基于所述待传输消息携带 的请 求确定的。 6.根据权利要求5所述的装置， 其特 征在于， 还 包括： 备份单元， 用于将所述目标消息进行备份， 并存储； 对所述存储的目标消息进行打标标 注， 以便后续进行 数据回溯。 7.根据权利要求5所述的装置， 其特 征在于， 还 包括： 监控单元， 用于在接收到前端应用发送的待传输消息之前， 对前端应用发送的待传输 消息进行监控。 8.根据权利要求5所述的装置， 其特征在于， 所述处理单元， 还用于： 若确定所述待传输 消息为MQ类型的消息， 基于所述待传输消息携带的需求， 将所述待传输消息转换成目标消 息； 在确定所述目标消息与所述待传输消息存在一致性 时， 将所述目标消息发送给目标应 用， 所述目标应用是基于所述待传输消息携带的请求确定的。 9.一种电子设备， 其特征在于， 所述电子设备用于运行程序， 其中， 所述程序运行时执 行如权利要求1 ‑4中任一所述的消息传输方法。 10.一种计算机存储介质， 其特征在于， 所述存储介质包括存储程序， 其中， 在所述程序 运行时控制所述存 储介质所在设备 执行如权利要求1 ‑4中任一所述的消息传输方法。权　利　要　求　书 1/1 页 2 CN 115495266 A 2一种消息传输方 法、 装置、 电子设备、 及计算机存 储介质 技术领域 [0001]本发明涉及数据处理技术领域， 尤其涉及一种消息传输方法、 装置、 电子设备、 及 计算机存 储介质。 背景技术 [0002]由于目前基于腾讯云发布的CMQ消息传输队列， 在银行金融业中还未广 泛应用， 由 于该框架架构不仅安全性好、 数据不易丢失、 可回溯、 消息并发大等优点， 越来越被企业和 公司应用， 但是由于目前好多消息传输还 是基于IBM开源的rabbitMQ架构， 如果实现两者之 间互相消息传输， 鉴于两者之间并发量， 消息类型等有差异性， 传输过程导致交易量不一 致， 容易导致消息阻塞， 交易丢失甚至可能导 致系统宕机 。 发明内容 [0003]有鉴于此， 本发明实施例提供一种消息传输方法、 装置、 电子设备、 及计算机存储 介质， 以解决现有技 术中消息阻塞， 交易丢失甚至可能导 致系统宕机的问题。 [0004]为实现上述目的， 本发明实施例提供如下技 术方案： [0005]本发明实施例第一方面示出了一种消息传输方法， 应用于中转处理器， 所述方法 包括： [0006]在接收到前端应用发送的待传输消息时， 将所述待传输消息进行存 储； [0007]若确定所述待传输消息为CMQ类型的消息， 基于所述待传输消息携带的需求， 将所 述待传输消息转换成目标消息； [0008]在确定所述目标消息与所述待传输消息存在一致性时， 将所述目标消息发送给目 标应用， 所述目标应用是基于所述待传输消息携带的请求确定的。 [0009]可选的， 还 包括： [0010]将所述目标消息进行 备份， 并存 储； [0011]对所述存 储的目标消息进行打标 标注， 以便后续进行 数据回溯。 [0012]可选的， 还 包括： [0013]在接收到前端应用发送的待传输消息之前， 对前端应用发送的待传输消息进行监 控。 [0014]可选的， 所述方法还 包括： [0015]若确定所述待传输消息为MQ类型的消息， 基于所述待传输消息携带的需求， 将所 述待传输消息转换成目标消息； [0016]在确定所述目标消息与所述待传输消息存在一致性时， 将所述目标消息发送给目 标应用， 所述目标应用是基于所述待传输消息携带的请求确定的。 [0017]本发明实施例第二方面示出了一种消息传输装置， 应用于中转处理器， 所述装置 包括： [0018]存储单元， 用于在接收到前端应用发送的待传输消息时， 将所述待传输消息进行说　明　书 1/9 页 3 CN 115495266 A 3