在Rabbitmq中从同一队列发布和订阅

Question

我正在尝试设置到系统中所有节点的广播消息。当一个新节点加入系统时，它会向其他所有节点发布一条html" target="_blank">消息来宣布它的加入。我设计的方式是，存在一个交换，所有节点都将绑定到它自己的队列。每当一个新节点加入系统时，它就会将其队列绑定到exchange并将消息发布到exchange。所有节点都会收到这个消息（包括自身），所有其他节点（除了这个消息）都会发送一个“ACK”消息，这样新节点就会了解系统中可用的节点。但不知怎的，我没办法把它弄好。我的广播消息不会传播到系统中的每个节点。一个简单的节点发布和rest消耗正在工作。但同一节点的发布和消费在某个地方却搞砸了。

除了上面提到的逻辑，有没有其他有效的方法？或者从rabbitmq的角度来看，实现上述目标是否有任何限制，或者是我的代码有缺陷，我是否必须仔细查看它。

Answer 1

按照你所描述的方式，你的解决方案应该能奏效。但是，如果没有更详细的代码示例（“Announcer”中的消费/发布逻辑和其他对等体中的消费/确认-发布逻辑），就很难调试。

不过，有几个常见的问题可能会使您陷入困境：

• 如果您将“Did I get response back from all the other nodes get my annound message”作为“Did the other nodes get my annound message”的权限，则可能需要确认（在AMQP中为basic.ack)播音器接收到的消息。否则，可能由于使用者预取而看不到后续消息，尽管在大多数客户端库中，您必须先在某个地方显式地打开它。
  • 确保您的其他对等方（接收“公告”并返回消息的对等方）也在确认该消息，或者在“no-ack”模式下进行消费。否则，如果它们被阻塞（通过流、速率限制或预取），它们可能会收到一段时间的通知，然后停止。
  • 确保您使用的是“扇出”类型的交换。听起来你想要无条件扇出的行为，所以你不需要在主题路由上胡闹。如果您使用的是主题交换或直接交换，您的路由逻辑中可能有一个bug，在这种情况下，切换到扇出将起作用。不过我怀疑你已经在这么做了。
  • 这可能不是问题所在，而是：您提到您的同伴（而不是播音员）正在“承认”宣布。确保他们通过直接将新消息发布回公告者的队列（没有交换，只有路由密钥）来确认公告，而不是通过将basic.ack发送到RabbitMQ（不会通知发送者任何内容），也不是通过将已接收的公告发布到扇出交换。