java - HornetQ集群队列和故障节点: are messages lost?

Question

我面临一个设计问题，我希望只有一个 JMS 生产者向两个消费者发送消息。只有两台服务器，生产者将开始生成消息，这些消息将对两个消费者进行负载平衡(通过循环)。

在假设一台服务器发生故障的情况下，我确实有一种机制，可以在剩余的服务器中激活新的生产者。但是，在发生故障的服务器中正在处理的消息会发生什么情况呢？

它们是否会被重新分配给剩余的服务器，从而由剩余的消费者处理？或者他们会丢失？

如果最后一种情况为真，则会出现另一个问题。生产者根据 NAS 中的文件创建消息，因此当服务器出现故障时，新激活的生产者将开始根据 NAS 的内容创建消息，并且可能会复制消息(但这种情况已处理)，问题是，如果出现故障的服务器不是具有 Activity 生产者的服务器，那么当服务器再次启动时，它将没有消息可供消费，也没有消息可以替代丢失的消息。

如何实现不丢失消息的设计？

注意:当一台服务器出现故障时，日志和绑定(bind)都会丢失。

Answer 1

一旦消息传输到特定节点，它就属于该节点。

如果节点出现故障，您必须使用其日志激活该节点，并且消息状态将从磁盘恢复。如果您没有更多的使用者，您最终可能会重新分发消息(当然这取决于重新分发配置)。

或者最好的方法是为每个节点都有一个备份节点。

我们一直建议使用并置拓扑，其中一个虚拟机有一个 Activity 实例，另一台服务器有一个备份实例...这样，每个 Activity 服务器也将有一个备份配置。正如我们所说，这一点在 2.4.0 中得到了改进，因为您目前需要大量手动配置。

所以，总结一下:

• 重启节点
• 配置备份节点