基于RocketMQ的消息订阅方法及组件、消息订阅系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN110956485A(43)申请公布日2020.04.03(21)申请号201811136394.8(22)申请日2018.09.27(71)申请人千寻位置网络有限公司地址200433上海市杨浦区军工路1436号64幢一层J165室(72)发明人蒋文倩徐盛汤严敏(74)专利代理机构上海市海华永泰律师事务所31302代理人包文超(51)Int.Cl.G06Q30/02(2012.01)G06Q30/06(2012.01)权利要求书2页说明书7页附图4页(54)发明名称基于RocketMQ的消息订阅方法及组件、消息订阅系统(57)摘要本发明适用物联网技术领域，提供了一种基于RocketMQ的消息订阅方法及组件、消息订阅系统，所述消息订阅方法包括：对消息消费者列表中的订阅规则及消息过滤规则进行适配，其中，所述订阅规则及消息过滤规则与消息主题和消息标识相关；接收到消息通知时，轮询所述消息消费者列表，查找与所述消息通知中的所述订阅规则及消息过滤规则对应的所述消息消费者；执行相应的消费逻辑。本发明中，将消息消费者的消息订阅粒度细化至消息标识级别，使得有新的业务目的产生时，只需要新增加一个消息消费者即可，减少了变更实现带来的业务风险。CN110956485ACN110956485A权利要求书1/2页1.一种基于RocketMQ的消息订阅方法，其特征在于，包括：对消息消费者列表中的订阅规则及消息过滤规则进行适配，其中，所述订阅规则及所述消息过滤规则与消息主题和消息标识相关；接收到消息通知时，轮询所述消息消费者列表，查找与所述消息通知中的所述订阅规则及消息过滤规则对应的所述消息消费者；执行相应的消费逻辑。2.根据权利要求1所述的消息订阅方法，其特征在于，同一所述消息主题下包括多个所述消息标识不同的所述消息消费者。3.根据权利要求1所述的消息订阅方法，其特征在于，所述对消息消费者列表中的订阅规则及消息过滤规则进行适配，包括：将所述消息主题和所述消息标识相同的所述消息消费者合并；没有指定所述消息标识时，自动订阅所述消息主题下的所有消息。4.根据权利要求1所述的消息订阅方法，其特征在于，所述对消息消费者列表中的订阅规则及消息过滤规则进行适配之前，包括：将实现了消息消费接口类的所述消息消费者自动加载进所述消息消费者列表中；统一管理完成所述消息消费者的创建。5.根据权利要求1所述的消息订阅方法，其特征在于，所述对消息消费者列表中的订阅规则及消息过滤规则进行适配之前，包括：对消息生产者进行统一管理，把所述消息生产者对象的生命周期分成构造函数，实例化、清理三个方法。6.根据权利要求5所述的消息订阅方法，其特征在于，所述把消息生产者对象的生命周期分成构造函数，实例化、清理三个方法，包括：将所述消息生产者对象组名、NameServer地址作为属性，由Spring容器在配置时提供；实例化所述消息生产者对象、设置NameServer地址、初始化所述消息生产者对象；在所述消息生产者对象销毁时清理资源。7.一种基于RocketMQ的消息订阅组件，其特征在于，包括：适配单元，用于对消息消费者列表中的订阅规则及消息过滤规则进行适配，其中，所述订阅规则及消息过滤规则与消息主题和消息标识相关；查找单元，用于接收到消息通知时，轮询所述消息消费者列表，查找与所述消息通知中的所述订阅规则及消息过滤规则对应的所述消息消费者；执行单元，用于执行相应的消费逻辑。8.一种基于RocketMQ的消息订阅系统，其特征在于，包括如权利要求7所述的消息订阅组件。9.一种存储器，所述存储器存储有计算机程序，其特征在于，所述计算机程序被处理器执行如下步骤：对消息消费者列表中的订阅规则及消息过滤规则进行适配，其中，所述订阅规则及消息过滤规则与消息主题和消息标识相关；接收到消息通知时，轮询所述消息消费者列表，查找与所述消息通知中的所述订阅规则及消息过滤规则对应的所述消息消费者；2CN110956485A权利要求书2/2页执行相应的消费逻辑。10.一种消息订阅组件，包括存储器、处理器及存储在所述存储器中并可在所述处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现如权利要求1至6任意一项所述的基于RocketMQ的消息订阅方法的步骤。3CN110956485A说明书1/7页基于RocketMQ的消息订阅方法及组件、消息订阅系统技术领域[0001]本发明属于物联网技术领域，尤其涉及一种基于RocketMQ的消息订阅方法及组件、消息订阅系统。背景技术[0002]电商系统中通常需要收发异步消息，实现不同工程之间的解耦，如创建订单后异步健全日志，清除购物车，发送通知邮件等，此场景下消费者可以通过订阅某一消息主题(topi