预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共16页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113687956A(43)申请公布日2021.11.23(21)申请号202110839374.2(22)申请日2021.07.23(71)申请人上海浦东发展银行股份有限公司地址200001上海市中山东一路12号(72)发明人曹先荣李松韦良孝(74)专利代理机构广州华进联合专利商标代理有限公司44224代理人黄晓庆(51)Int.Cl.G06F9/54(2006.01)权利要求书2页说明书9页附图4页(54)发明名称消息路由分发方法、装置、计算机设备及存储介质(57)摘要本发明涉及消息中间件技术领域,公开了一种消息路由分发方法、装置、计算机设备及存储介质,包括通过消息接收接口获取待处理消息;根据待处理消息的事件类型,确定与事件类型相匹配的消息中间件;将待处理消息透传至消息中间件;根据配置管理信息确定与待处理消息的事件类型相匹配的消息队列和发送处理方式;根据发送处理方式通过消息发送接口将待处理消息透传至对应的消息队列;通过消息队列将待处理消息发送至目标系统。所述方法通过对多种消息中间件进行整合,可以屏蔽不同消息中间件间的差异性,从而实现对外提供统一的消息收发功能。同时,还为业务场景提供了不同服务间的消息路由和分发处理机制。CN113687956ACN113687956A权利要求书1/2页1.一种消息路由分发方法,其特征在于,包括:通过消息接收接口获取待处理消息;根据所述待处理消息的事件类型,确定与所述事件类型相匹配的消息中间件;将所述待处理消息透传至所述消息中间件;根据配置管理信息确定与所述待处理消息的事件类型相匹配的消息队列和发送处理方式;根据所述发送处理方式通过消息发送接口将所述待处理消息透传至对应的所述消息队列;通过所述消息队列将所述待处理消息发送至目标系统。2.根据权利要求1所述的消息路由分发方法,其特征在于,所述消息队列有预先设置的发送优先级,在根据所述发送处理方式通过消息发送接口将所述待处理消息透传至对应的所述消息队列之前,还包括:根据所述发送优先级确定优先发送的消息队列;所述根据所述发送处理方式通过消息发送接口将所述待处理消息透传至对应的所述消息队列包括:根据所述发送处理方式,通过消息发送接口将所述优先发送的消息队列对应的待处理消息透传至所述优先发送的消息队列。3.根据权利要求1所述的消息路由分发方法,其特征在于,所述消息中间件包括Kafka、RocketMQ、ActiveMQ、RabbitMQ。4.根据权利要求1所述的消息路由分发方法,其特征在于,在根据所述发送处理方式通过消息发送接口将所述待处理消息透传至对应的所述消息队列后,所述方法还包括:根据所述待处理消息对应的目标系统对所述待处理消息进行分类缓存;当所述分类缓存中透传至同一个目标系统的待处理消息的个数累计到预设数量时,将所述分类缓存中透传至同一个目标系统的待处理消息合并成第一批量消息集合;和/或每间隔预设时间,将所述分类缓存中透传至同一个目标系统的待处理消息合并成第二批量消息集合;所述通过所述消息队列将所述待处理消息发送至目标系统包括:通过所述消息队列将所述第一批量消息集合和/或所述第二批量消息集合发送至对应的目标系统。5.根据权利要求1所述的消息路由分发方法,其特征在于,在通过所述消息队列将所述待处理消息发送至目标系统后,所述方法还包括:对所述待处理消息的发送操作记录于事件明细表中;定时对所述事件明细表中的数据进行迁移。6.根据权利要求5所述的消息路由分发方法,其特征在于,在通过所述消息队列将所述待处理消息发送至目标系统后,所述方法还包括:接收所述目标系统反馈的对所述待处理消息的消费结果;当所述目标系统反馈的消费结果为消费成功时,将所述消息队列中的所述待处理消息删除,将所述事件明细表中所述待处理消息的状态更改为已消费。7.根据权利要求6所述的消息路由分发方法,其特征在于,在通过所述消息队列将所述2CN113687956A权利要求书2/2页待处理消息发送至目标系统后,所述方法还包括:当所述消费结果为消费失败时,重新将所述待处理消息通过所述消息队列发送至目标系统。8.一种消息路由分发装置,其特征在于,包括:消息接口模块,用于通过消息接收接口获取待处理消息,还用于通过消息发送接口将所述待处理消息透传至对应的所述消息队列;消息中间件配置模块,用于根据所述待处理消息的事件类型,确定与所述事件类型相匹配的消息中间件;还用于将所述待处理消息透传至所述消息中间件;还用于根据配置管理信息确定与所述待处理消息的事件类型相匹配的消息队列和发送处理方式;还用于根据所述发送处理方式通过消息发送接口将所述待处理消息透传至对应的所述消息队列;消息中间件模块,用于通过所述消息队列将所述待处理消息发送至目标系