我们目前在Azure中使用服务总线，由于各种原因，我们正在切换到RabbitMQ。在负载较重的情况下，当后端的特定任务出现问题时，我们的一个队列可能会有多达100万条消息等待处理。
RabbitMQ的每个队列最多可以有50000条消息。问题是我们如何设计RabbitMQ基础设施，使其在消息临时累积时继续工作？
注意：我们希望在kubernetes集群中的一个docker映像中托管我们的RabbitMQ服务器。我们设想了一个交换，它将在后面节点的队列之间负载平衡消息。但我们不清楚的是，如果我们检测到队列变满，如何根据需要动态添加新队列。
1条答案
按热度按时间egdjgwm81#
RabbitMQ的每个队列最多可以有50000条消息。
没有这种限制。RabbitMQ可以处理更多的消息使用仲裁或经典队列与懒惰。与stream queues RabbitMQ可以处理数百万条消息每秒。
我们设想一种交换，其将在后面的节点中的队列之间对消息进行负载平衡。
您可以使用不同的绑定来实现这一点。
Kubernetes集群。
我建议使用k8s Operator
但我们不清楚的是，如果我们检测到队列变满，如何根据需要动态添加新队列。
在RabbitMQ中没有FULL的概念。使用max-length or TTL可以设置一些限制。