本发明涉及数据处理领域,特别涉及一种异步消息处理的优化方法及终端。
背景技术:
1、目前的系统为了解决大量高并发,高吞吐的性能要求,服务端架构一般都采用微服务架构的方式,同时,各个系统之间采用消息中间件进行系统或者模块之间的解耦。通常使用消息中间件的模式为,生产者发送消息至mq中,存在多个的消费者,轮询或者随机的访问mq的不同节点或者分区,读取数据后进行消费。
2、在实际场景中,通常都会把消息进行一些业务逻辑处理后,进行统一的存储,方便其他的消息或者任务或者模块统一读取使用。但部分存在关联内容的消息消费时,通常需要对关联内容进行调取,从而进行额外的网络io过程,导致消费过程的效率变低。
技术实现思路
1、本发明所要解决的技术问题是:提供一种异步消息处理的优化方法及终端,解决具有关联内容的消息消费过程中需要过多进行额外网络io的问题。
2、为了解决上述技术问题,本发明采用的技术方案为:
3、一种异步消息处理的优化方法,包括步骤:
4、s1、根据业务规则对消息之间的关系信息进行确认并生成分组规则;
5、s2、利用所述分组规则对消息中间件中的消息进行分组,将各组消息分别发送至消息中间件的不同分区进行消费。
6、为了解决上述技术问题,本发明采用的另一技术方案为:
7、一种异步消息处理的优化终端,包括存储器、处理器以及存储在所述存储器上并可在处理器上运行的计算机程序,所述处理器执行所述计算机程序时完成以下步骤:
8、s1、根据业务规则对消息之间的关系信息进行确认并生成分组规则;
9、s2、利用所述分组规则对消息中间件中的消息进行分组,将各组消息分别发送至消息中间件的不同分区进行消费。
10、本发明的有益效果在于:提供一种异步消息处理的优化方法及终端,根据预设的业务规则对消息之间的关系信息进行确认并生成分组规则,后续针对存在关联关系的消息发送至消息中间件的同一分区进行消费,可以确保相关联的消息被统一处理,减少了消息处理过程中的因过多的网络io引起的延迟和混乱,有效地提高消息处理的效率和响应速度,提高系统的并发处理能力,减少消息堆积,优化系统资源的使用,从而提高整体的系统性能和用户体验。
1.一种异步消息处理的优化方法,其特征在于:包括步骤:
2.根据权利要求1所述的一种异步消息处理的优化方法,其特征在于:所述步骤s1还包括步骤:
3.根据权利要求1所述的一种异步消息处理的优化方法,其特征在于:所述步骤s2还包括步骤:
4.根据权利要求1所述的一种异步消息处理的优化方法,其特征在于:所述步骤s2之后还包括步骤s3:
5.根据权利要求1所述的一种异步消息处理的优化方法,其特征在于:所述消息中间件为rabbitmq。
6.一种异步消息处理的优化终端,其特征在于:包括存储器、处理器以及存储在所述存储器上并可在处理器上运行的计算机程序,所述处理器执行所述计算机程序时完成以下步骤:
7.根据权利要求6所述的一种异步消息处理的优化终端,其特征在于:所述步骤s1还包括步骤:
8.根据权利要求6所述的一种异步消息处理的优化终端,其特征在于:所述步骤s2还包括步骤:
9.根据权利要求6所述的一种异步消息处理的优化终端,其特征在于:所述步骤s2之后还包括步骤s3:
10.根据权利要求6所述的一种异步消息处理的优化终端,其特征在于:所述消息中间件为rabbitmq。
