(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211135837.8 (22)申请日 2022.09.19 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 申世哲　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 薛平 (51)Int.Cl. G06F 9/54(2006.01) G06F 16/25(2019.01) (54)发明名称 基于MQ消息分发的超级网银分库方法和系 统 (57)摘要 本发明提供了一种基于MQ消息分发的超级 网银分库方法和系统， 所述方法由MQ消息分发系 统侧执行， 方法包括： 侦听PMTS系统报文发出队 列中的报文； 当所述PMTS系统报文发出队列中有 报文存在时， 取出所述报文； 解析取出的所述报 文获得对应的报文特征； 根据所述报文特征选择 对应的收发报系统队列， 将所述报文通过所述收 发报系统队列发送至所述收发报系统， 所述收发 报系统有多个， 与多个数据库一一对应。 使用本 申请的方法进行超级网银分库， 不需要修改现有 代码， 只需在新增的MQ消息分发系统中新增逻辑 实现代码， 因此不会给现有代码增加负担， 可 以 避免大量测试工作， 减少成本 。 权利要求书1页 说明书5页 附图3页 CN 115543653 A 2022.12.30 CN 115543653 A 1.一种基于MQ消息分发的超级网银分库方法， 其特征在于， 所述方法由MQ消息分发系 统侧执行， 所述方法包括： 侦听PMTS系统报文发出队列中的报文； 当所述PMTS系统报文发出队列中有报文存在时， 取 出所述报文； 解析取出的所述报文获得对应的报文特 征； 根据所述报文特征选择对应的收发报系统队列， 将所述报文通过所述收发报系统队列 发送至所述收发报系统， 所述收发报系统有 多个， 与多个数据库一 一对应。 2.如权利 要求1所述的基于MQ消息分发的超级网银分库方法， 其特征在于， 所述PMTS系 统报文发出队列包 含多个队列， PMTS系统根据负载均衡原则将 报文发送至所述多个队列。 3.如权利要求1所述的基于MQ消息分发的超级网银分库 方法， 其特征在于， 将所述报文 通过所述收发报系统队列发送至所述收发报系统包括： 将所述报文发送至所述收发报系统 队列， 所述收发报系统队列被 收发报系统所侦听， 所述收发报系统侦听到 收发报系统队列 中有报文时， 取 出所述报文。 4.如权利要求1所述的基于MQ消息分发的超级网银分库 方法， 其特征在于， 所述报文特 征包括报文类型。 5.一种基于MQ消息分发的超级网银分库系 统， 其特征在于， 所述系 统包括： PMTS系 统、 MQ消息分发系统和多个收发报系统， 所述MQ消息分发系统分别和所述P MTS系统及所述多个 收发报系统进行通信连接， 所述MQ消息分发系统用于： 侦听所述PMTS系统报文发出队列中 的报文； 当所述P MTS系统报文发出队列中有报文存在时， 取出所述报文； 解析取出的所述报 文获得对应的报文特征； 根据所述报文特征选择对应的收发报系统队列， 将所述报文通过 所述收发报系统队列发送至对应收发报系统。 6.如权利 要求5所述的基于MQ消息分发的超级网银分库系统， 其特征在于， 所述PMTS系 统报文发出队列包含多个队列， 所述P MTS系统根据负载均衡原则将报文发送至所述多个队 列。 7.如权利要求5所述的基于MQ消息分发的超级网银分库系统， 其特征在于， 所述MQ消息 分发系统将所述报文通过所述收发报系统队列发送至所述收发报系统包括： 将所述报文发 送至所述收发报系统队列， 所述收发报系统队列被 收发报系统所侦听， 所述收发报系统侦 听到收发报系统队列中有报文时， 取 出所述报文。 8.如权利要求5所述的基于MQ消息分发的超级网银分库系统， 其特征在于， 所述报文特 征包括： 报文类型。 9.一种电子设备， 包括存储器、 处理器以及存储在所述存储器上并可在所述处理器上 运行的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至4任 一项所述方法的步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至4任一项所述方法的步骤。 11.一种计算机程序产品， 包括计算机程序/指令， 其特征在于， 所述计算机程序/指令 被处理器执行时实现权利要求1至4任一项所述方法的步骤。权　利　要　求　书 1/1 页 2 CN 115543653 A 2基于MQ消 息分发的超级网银分库方 法和系统 技术领域 [0001]本发明涉及数据库分库技术领域， 尤其涉及一种基于MQ消息分发的超级网银分库 方法和系统。 背景技术 [0002]目前银行的超级网银系统， 由于业务量增多， 原先的数据库压力太大， 因此需要将 业务进行分流， 即采用两个或两个以上数据库， 不同的业务限制在在不同的数据库中进行 操作。 [0003]PMTS系统是支付报文传输平台,部署在各家商业银行， 用于与商业银行行内系统 进行报文传输， 超级网银系统即网上支付跨行清算系统(Internet  Banking Payment  System， IBP S)主要从PMTS系统接收各类支付类报文、 信息类报文及管理类报文。 [0004]虽然可以通过修改代码的方式来实现从PMTS发出的报文进行分流到超级网银系 统的不同数据库中， 但是修改代码会给现有代码增加负担， 还会需要 大量的测试工作， 成本 会增大。 发明内容 [0005]有鉴于此， 本发明提供一种基于MQ消息分发的超级网银分库方法和系统， 以解决 上述提及的至少一个问题。 [0006]为了实现上述目的， 本发明采用以下 方案： [0007]根据本发明的第一方面， 提供一种基于MQ消息分发的超级网银分库方法， 所述方 法由MQ消息 分发系统侧执行， 所述方法包括： 侦听PMTS系统报文发出队列中的报文； 当所述 PMTS系统报文发出队列中有报文存在时， 取出所述报文； 解析取出的所述报文获得对应的 报文特征； 根据所述报文特征选择对应的收发报系统队列， 将所述报文通过所述收发报系 统队列发送至所述收发报系统， 所述收发报系统有 多个， 与多个数据库一 一对应。 [0008]根据本发明的第二方面， 提供一种基于MQ消息分发的超级网银分库系统， 所述系 统包括： PMTS系统、 MQ消息分发系统和多个收发报系统， 所述MQ消息分发系统分别和所述 PMTS系统及所述多个收发报系统进行通信连接， 所述MQ消 息分发系统用于： 侦听所述PMTS 系统报文发出队列中的报文； 当所述PMTS系统报文发出队列中有报文存在时， 取出所述报 文； 解析取出 的所述报文获得对应的报文特征； 根据所述报文特征选择对应的收发报系统 队列， 将所述报文通过 所述收发报系统队列发送至对应收发报系统。 [0009]根据本发明的第三方面， 提供一种电子设备， 包括存储器、 处理器以及存储在所述 存储器上并可在所述处理器上运行的计算机程序， 处理器执行所述计算机程序时实现上述 方法的步骤。 [0010]根据本发明的第四方面， 提供一种计算机可读存储介质， 其上存储有计算机程序， 所述计算机程序被处 理器执行时实现上述方法的步骤。 [0011]根据本发明的第五方面， 提供一种计算机程序产品， 包括计算机程序/指令， 其所说　明　书 1/5 页 3 CN 115543653 A 3