消息中间件的接入方法、消息的处理方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113641507A(43)申请公布日2021.11.12(21)申请号202010344646.7(22)申请日2020.04.27(71)申请人北京京东振世信息技术有限公司地址100086北京市海淀区知春路76号6层(72)发明人郭庆海(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人王安娜张效荣(51)Int.Cl.G06F9/54(2006.01)G06F8/71(2018.01)权利要求书2页说明书14页附图4页(54)发明名称消息中间件的接入方法、消息的处理方法和装置(57)摘要本发明公开了消息中间件的接入方法、消息的处理方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：根据目标业务对应的消息中间件的信息，确定消息中间件的类型标识；根据类型标识，判断是否已配置消息中间件对应的配置信息；若否，则配置目标业务对应的消息处理信息和配置信息，消息处理信息包括目标业务的主题标识、目标业务的消息处理方法、以及类型标识与主题标识的对应关系；若是，则配置目标业务对应的消息处理信息。该实施方式能够避免因各消息中间件的客户端和配置信息不同，所以给业务系统的正常运行带来风险的问题。CN113641507ACN113641507A权利要求书1/2页1.一种消息中间件的接入方法，其特征在于，包括：根据目标业务对应的消息中间件的信息，确定所述消息中间件的类型标识；根据所述类型标识，判断是否已配置所述消息中间件对应的配置信息；若否，则配置所述配置信息和所述目标业务对应的消息处理信息，所述消息处理信息包括所述目标业务的主题标识、所述目标业务的消息处理方法、以及所述类型标识与所述主题标识的对应关系；若是，则配置所述目标业务对应的消息处理信息。2.根据权利要求1所述的方法，其特征在于，所述配置信息包括与所述消息中间件对应的消息解码策略、执行信息、监控统计信息和/或异常处理信息。3.根据权利要求1所述的方法，其特征在于，所述执行信息包括单线程模式或多线程模式；若所述执行信息包括所述多线程模式，则所述执行信息还包括线程数量和所述消息中间件发送消息的分片策略。4.一种消息的处理方法，其特征在于，包括如权1-3任一项所述消息中间件的接入方法；在配置所述配置信息和所述目标业务对应的消息处理信息，或配置所述目标业务对应的消息处理信息之后，所述消息的处理方法还包括：接收所述消息中间件发送的待处理消息，所述待处理消息包括所述消息中间件的类型标识和所述目标业务的主题标识；确定与所述类型标识和所述主题标识对应的消息处理方法；通过所述消息处理方法，处理所述待处理消息。5.根据权利要求4所述的方法，其特征在于，所述配置信息包括所述消息中间件对应的监控统计信息和异常处理信息；所述通过所述消息处理方法，处理所述待处理消息，包括：根据所述类型标识，确定所述消息中间件对应的监控统计信息和异常处理信息；根据所述监控统计信息，监控统计所述待处理消息的处理信息；若所述处理信息中包括异常信息，则根据所述异常信息和所述异常处理信息，对所述待处理消息进行异常处理。6.根据权利要求4所述的方法，其特征在于，所述配置信息还包括所述消息中间件对应的消息解码策略；在所述通过所述消息处理方法，处理所述待处理消息之前，还包括：根据所述类型标识确定所述消息中间件对应的消息解码策略；根据所述消息解码策略，对所述待处理消息解码。7.根据权利要求4所述的方法，其特征在于，所述配置信息还包括与所述消息中间件对应的执行信息；所述确定与所述类型标识和所述主题标识对应的消息处理方法，包括：根据所述类型标识，确定所述消息中间件对应的执行信息；根据所述执行信息调用所述主题标识对应的消息处理方法。8.一种消息中间件的接入装置，其特征在于，包括：确定单元，用于根据目标业务对应的消息中间件的信息，确定所述消息中间件的类型2CN113641507A权利要求书2/2页标识；判断单元，用于根据所述类型标识，判断是否已配置所述消息中间件对应的配置信息；若否，则配置单元，用于配置所述配置信息和所述目标业务对应的消息处理信息，所述消息处理信息包括所述目标业务的主题标识、所述目标业务的消息处理方法、以及所述类型标识与所述主题标识的对应关系；若是，则所述配置单元，还用于配置所述目标业务对应的消息处理信息。9.一种消息的处理装置，其特征在于，包括如权8所述消息中间件的接入装置，所述消息的处理装置还包括：接收单元，用于接收所述消息中间件发送的待处理消息，所述待处理消息包括所述消息中间件的类型标识和所述目标业务的主题标识；所述确定单元，该用于确定与所述类型标识和所述主题标识对应的消息处理方法；处理单元，用于通过所述消息处理方法，处理所述待处理消息。