拥有多个 RabbiMQ 服务器主机(集群)的主要目标是否有任何最佳实践来实现拥有多个 RabbitMQ 主机,并在之前的连接关闭时重新连接到下一个主机。
教程说:
客户端可以正常连接到集群中的任何节点。如果该节点发生故障,而集群的其余部分仍然存在,则客户端应该注意到关闭的连接,并且应该能够重新连接到集群的某些幸存成员。通常,不建议将节点主机名或 IP 地址烘焙到客户端应用程序中
它如何从客户端实现?
拥有多个 RabbiMQ 服务器主机(集群)的主要目标是否有任何最佳实践来实现拥有多个 RabbitMQ 主机,并在之前的连接关闭时重新连接到下一个主机。
教程说:
客户端可以正常连接到集群中的任何节点。如果该节点发生故障,而集群的其余部分仍然存在,则客户端应该注意到关闭的连接,并且应该能够重新连接到集群的某些幸存成员。通常,不建议将节点主机名或 IP 地址烘焙到客户端应用程序中
它如何从客户端实现?
解决这个典型问题的一种方法是为您的集群(如HAPROXY、cross-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();
}