我正在使用rabbitmq流,我需要在消息之间添加一个延迟,因为流处理消息的速度非常快。我该怎么做?
x759pob21#
***EDIT***RabbitMQ流本身发送消息的速度更快,但有一个信用机制来避免消费者节流。客户端发送信用以获得更多消息。目前还没有公开此功能,我们正在研究它,因此,当您生成/消费消息时,您需要在客户端执行此操作。
1条答案
按热度按时间x759pob21#
***EDIT***RabbitMQ流本身发送消息的速度更快,但有一个信用机制来避免消费者节流。客户端发送信用以获得更多消息。目前还没有公开此功能,我们正在研究它,因此,当您生成/消费消息时,您需要在客户端执行此操作。