如何使用rabbitmq路由功能知道消息是否已发布到队列

Question

它像发布/订阅一样工作。因此，可以将队列绑定或取消绑定到不同的事件，以便消费者/订阅者只接收他们感兴趣的消息。

当然，生产者/发布者现在使用绑定键（事件名）作为routing_key将其传递给pika实现。但是，当它为不存在的绑定发布某些内容时，消息就会丢失，也就是说，当没有人为事件foo绑定队列时，但是一些发布服务器调用pika.basic_publish(...，routing_key='foo')。

所以我的问题是：

>

检查pika.basic_publish的返回值。它总是返回none。

检查当我们试图发布一个不存在的绑定时是否有异常。一个都没有。

有一个额外的队列来进行频带控制（因为所有订阅服务器都由相同的进程运行）。这种方法在我看来并不理想。

rabbitmq版本为2.8

多谢

Answer 1

我相信您的问题的答案是RabbitMQ中的强制标志：

此标志告诉服务器，如果消息无法路由到队列，该如何响应。具体地说，如果设置了强制，并且在运行绑定之后，消息被放置在零队列中，那么消息将返回给发件人（带有一个basic.return）。如果在相同的情况下没有设置强制，服务器将静默地删除消息。

这基本上意味着，对一条消息进行排队，如果它不能被路由，那么将它返回给我。查看规范中的basic_publish以打开它。