如何才能等到RabbitMQ消息同步到集群中的其他节点？
我有一个三节点的rabbitmq集群。这是我正在使用的集群（不是我的）https://github.com/bijukunjummen/docker-rabbitmq-cluster。
我遇到了一个问题，如果我用ha-policy=all向队列发送大量消息，并不优雅地关闭服务器，则其他节点上的消息并不都可用。
这在Java RMQ库中可能吗？
谢了。
共有1个答案
请查看Publisher确认https://www.rabbitmq.com/Confirms.html
-
我在一个集群中运行了4个ActiveMQ Artemis 2.10.1实例。客户端(A)连接到其中一个节点，并发布QOS=0且RETUST=true的MQTT消息。当一个新的MQTT客户机(B)连接到集群中的另一个节点并订阅主题时，以前发送的消息不会被接收。当客户机A发布下一条消息时，客户机B获得该消息。
-
本文向大家介绍Python如何将消息发布到RabbitMQ，包括了Python如何将消息发布到RabbitMQ的使用技巧和注意事项，需要的朋友参考一下 示例 从导入库开始。 接下来，我们需要打开与RabbitMQ服务器的连接。 之后，我们需要建立一个频道。每个连接可以有多个通道，通常在执行多线程任务时，建议（但不是必需）每个线程一个。 建立频道后，我们就可以开始准备信息了。 现在，我们可以通过简单
-
问题内容： 在Akka actor中，如何找到群集的节点？即，本地节点认为当前可访问的节点。 谢谢-丹尼尔 问题答案： 您实际上不需要订阅或。您可以只访问集群扩展的成员，例如，
-
我在试着检测来自另一个不和谐机器人的消息。例如，如果另一个不和谐机器人说“验证码”，我的不和谐机器人将检测到它并ping我。希望有一种方法可以检测另一个机器人的嵌入，而不仅仅是消息。
-
在RabbitMQ级别上是否有任何机制允许我使用下一个消息直到上一个消息被加密为止？还是必须在服务器之间开发某种锁定机制？
-
创建负载均衡器时出错（将重试）：获取服务测试的LB时出错/admin-api:azure.bearerAuthorizer#WithAuthorization：未能刷新向https://management.azure.com/subscriptions/****/resourcegroups/mc_****/providers/microsoft.network/loadbalancers请求的