rabbitmq - 如何处理卡住的 RabbitMQ Dynamic Shovel 消息

Question

我们目前正在使用RabbitMQ 动态铲子将消息转发到Azure 事件中心。最近我们设置了一个新队列以转发到事件中心。此队列中的某些消息的大小超过1MB，这是事件中心上消息的限制。由于此限制，消息会弹回并每秒再次发送几次。这会产生大量网络流量，这可能是一个问题。

有没有办法将反弹回 DLX（死信交换）或不同队列的消息发送？我们已经寻找了一些 Dynamic Shovel 选项，但找不到任何有用的选项。

标签： rabbitmqazure-eventhubrabbitmq-shovel

Answer 1

谢谢杰西乡绅。发布您的建议作为帮助其他社区成员的答案。

通常，对于您的有效负载大于（或可能）大于允许大小的情况，我们建议您考虑将有效负载存储在其他一些持久存储（例如 Blob 存储）中的声明检查模式，然后使用正文发布事件指向该资源。

可以参考RabbitMQ 中的死信死信消息。

你也可以在 GitHub 上打开一个问题：rabbitmq-server