一种异步消息的监听方法、装置、存储介质及电子设备.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115237722A(43)申请公布日2022.10.25(21)申请号202210916865.7(22)申请日2022.08.01(71)申请人中国银行股份有限公司地址100818北京市西城区复兴门内大街1号(72)发明人杨秀丽钟艳辉朱政(74)专利代理机构北京集佳知识产权代理有限公司11227专利代理师韩丽波(51)Int.Cl.G06F11/30(2006.01)权利要求书2页说明书9页附图4页(54)发明名称一种异步消息的监听方法、装置、存储介质及电子设备(57)摘要一种异步消息的监听方法、装置、存储介质及电子设备，涉及分布式系统技术领域与金融技术领域。其中，该方法包括，在应用程序启动时，根据所述应用程序的监听器使能参数确定是否创建消费者，所述消费者用于消息系统中轮询获取消息并进行处理；当根据所述监听器使能参数确定需要创建消费者时，读取所述应用程序的YAML文件中的配置信息以创建监听器消费者，所述配置信息包括主题topic和消费者组的标识号，所述监听器消费者为持有消费者实例，所述消费者实例为一个所述消费者。利用该方法，能够动态创建监听器，实现难度低，具有较高的实用性。CN115237722ACN115237722A权利要求书1/2页1.一种异步消息的监听方法，其特征在于，所述方法包括：在应用程序启动时，根据所述应用程序的监听器使能参数确定是否创建消费者，所述消费者用于消息系统中轮询获取消息并进行处理；当根据所述监听器使能参数确定需要创建消费者时，读取所述应用程序的YAML文件中的配置信息以创建监听器消费者，所述配置信息包括主题topic和消费者组的标识号，所述监听器消费者为持有消费者实例，所述消费者实例为一个所述消费者。2.根据权利要求1所述的异步消息的监听方法，其特征在于，读取所述应用程序的YAML文件中的配置信息以创建监听器，具体包括：根据所述配置信息，为每个所述消费者创建的监听器端点和监听器容器并发工厂；将所述监听器端点和所述监听器容器并发工厂注册到监听器端点注册表中，所述监听器端点注册表用于管理所述消费者的生命周期，并为每个所述监听器端点创建对应的并发消息监听容器；并发消息监听容器根据并发数创建消息监听器容器，每个所述消息监听器容器包括一个监听器消费者，所述监听器消费者用于从消息系统中拉取消息。3.根据权利要求2所述的异步消息的监听方法，其特征在于，所述将所述监听器端点和所述监听器容器并发工厂注册到监听器端点注册表中，具体包括：初始化监听器端点注册器，以将所述监听器端点和所述监听器容器并发工厂注册到所述监听器端点注册表中。4.根据权利要求2所述的异步消息的监听方法，其特征在于，所述方法还包括：使所述消息监听器容器采用与所述消费者不同的线程执行所述消费者对应的消息处理方法。5.根据权利要求1所述的异步消息的监听方法，其特征在于，所述根据所述应用程序的监听器使能参数确定是否创建消费者前，所述方法还包括：利用监听器注册器实现智能初始化单例SmartInitializingSingleton接口。6.一种异步消息的监听装置，其特征在于，所述装置包括：确定单元和创建单元；所述确定单元，用于在应用程序启动时，根据所述应用程序的监听器使能参数确定是否创建消费者，所述消费者用于消息系统中轮询获取消息并进行处理；所述创建单元，用于当根据所述监听器使能参数确定需要创建消费者时，读取所述应用程序的YAML文件中的配置信息以创建监听器消费者，所述配置信息包括主题topic和消费者组的标识号，所述监听器消费者为持有消费者实例，所述消费者实例为一个所述消费者。7.根据权利要求6所述的异步消息的监听装置，其特征在于，所述创建单元，具体包括：第一创建子单元、注册子单元和第二创建子单元；所述第一创建子单元，用于根据所述配置信息，为每个所述消费者创建的监听器端点和监听器容器并发工厂；所述注册子单元，用于将所述监听器端点和所述监听器容器并发工厂注册到监听器端点注册表中，所述监听器端点注册表用于管理所述消费者的生命周期，并为每个所述监听器端点创建对应的并发消息监听容器；所述第二创建子单元，用于使并发消息监听容器根据并发数创建消息监听器容器，每2CN115237722A权利要求书2/2页个所述消息监听器容器包括一个监听器消费者，所述监听器消费者用于从消息系统中拉取消息。8.根据权利要求7所述的异步消息的监听装置，其特征在于，所述注册子单元，具体用于初始化监听器端点注册器，以将所述监听器端点和所述监听器容器并发工厂注册到所述监听器端点注册表中。9.一种计算机可读存储介质，其特征在于，其上存储有计算机程序，该程序被处理器执行时实现权利要求1‑5中任意一项所述的异步消息的监听方法。10.一种电