使用pika在rabbitMQ中批量发送消息

问题描述

我想在 python 中使用 pika 在 rabbitMQ 中一次发送大量消息(大约 500k)。一种方法是遍历所有消息并按顺序发送它们,但这会很慢。

有什么办法可以解决这个问题吗?

解决方法

默认情况下,AMQP 不提供任何批处理机制,因此您无法使用 pika 对消息进行批处理。

顺便说一句,您可以使用一些提示:

  • 在客户端聚合消息,从而将更多消息集中在一个
  • 您可以创建压缩消息,例如 zip/lzo 或某些可以在内存中压缩/解压缩的库。

注意:如果你想压缩消息,500k太高了,你应该把它们分开

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...