2

拥有多个 RabbiMQ 服务器主机(集群)的主要目标是否有任何最佳实践来实现拥有多个 RabbitMQ 主机,并在之前的连接关闭时重新连接到下一个主机。

教程说:

客户端可以正常连接到集群中的任何节点。如果该节点发生故障,而集群的其余部分仍然存在,则客户端应该注意到关闭的连接,并且应该能够重新连接到集群的某些幸存成员。通常,不建议将节点主机名或 IP 地址烘焙到客户端应用程序中

它如何从客户端实现?

4

1 回答 1

4

解决这个典型问题的一种方法是为您的集群(如HAPROXYcross-road ..或其他)配置一个负载均衡器(在 roud-robin 配置中就足够了)。

客户端--->ip-load-balacer--brokerS

通过这种方式,您只能在客户端连接中使用负载平衡器 IP。

为了获得更大的灵活性,您可以添加绑定到负载均衡器的 DNS(本地 dns),这样您也可以在不更改客户端配置的情况下更改均衡器。

客户端--->-load-balacer-DNSNAME--brokerS

如果一个客户端失去连接,您必须将其重新连接到相同的 ip 或 dns。

你应该有一个用于 c# 的 HA 客户端,就像java一样,或者只是管理连接关闭事件。

也就是说,如果您有一个小型静态集群,您可以使用客户端的 IP。

从客户端(如果您只想处理断开连接):

connection = connection = factory.CreateConnection();
channel = connection.CreateModel();
.......
connection.ConnectionShutdown += Connection_ConnectionShutdown;

 void Connection_ConnectionShutdown(IConnection connection, ShutdownEventArgs reason)
{
    Console.WriteLine("connection_ConnectionShutdown " + reason.ToString());
    Reconnect_client();
}
于 2014-04-11T12:41:31.807 回答