当前位置: 首页 > 网络应用技术

如何使用RabbitMQ批处理处理功能优化服务

时间:2023-03-08 14:54:22 网络应用技术

  兔队的队列经常发生交通拥堵。原因是每次花费时,数据都会插入数据库。尽管数据库配置了连接池,但仍无法对其进行处理,从而导致消息累积。

  基本优化想法()应该是一个一个插入一个以优化批处理插入。例如:对于每100个数据,请通过批处理插入方法输入DB,例如由ORM框架提供的insertbatch/saveBatch/saveall。

  因此,这里需要考虑的是如何收集这一数百个数据。RabbitMQ仅提供此类功能(成为可行的解决方案)。

  AMQP规定只能在协议上一次传输一个数据。因此,需要在应用程序层上定义批处理数据操作。春天现在提供了这种能力。

  官方文件

  从2.2版开始,您可以配置侦听器容器工厂和侦听器一次打电话,并一次接收整个批次。只需设置工厂的批处理属性,并设置有效负载参数的方法。

  实际上,该代码的实施非常简单,如有必要,请自己拿!

  作者:L Laburami