带 .Net 客户端的 RabbitMQ 集群

Question

此时我已经阅读了很多帖子和博客，但我仍然不确定如何正确集群我的 2 个 RabbitMQ 节点。

我已阅读 RabbitMQ 集群指南： http://www.rabbitmq.com/clustering.html

我在 API 指南中发现了一个神秘的 ClusterId，但没有解释如何获取该 Id：http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v2.4.1/rabbitmq-dotnet-client-2.4.1-api-guide.pdf

在 StackOverflow 帖子中了解到基本上我需要我的客户了解集群中的每个节点以及故障转移场景的代码：rabbitmq HA 集群

现在...如果可能的话，我想要的行为是更加透明的。我可能会在客户端上使用该“ClusterId”来让消费者集群感知，然后希望库知道随机连接到任一节点以获取消息。

当然，我知道一条消息一次只能在一台服务器上，所以我希望 DotNet 客户端库能够提供一些循环魔法来处理故障转移情况。

从发布者的角度来看，我也希望交换能够循环将消息分发到集群中的各个节点。交换机还可以感知集群并妥善处理故障转移情况。

现在根据我的阅读，它并不完全像那样工作......除非我错过了一些东西。 如果我的知识是最新的并且我必须对所有集群感知业务进行编码，那么...为什么 RabbitMQ 首先具有集群功能？它是如何使用的？

有没有一种方法可以让 RabbitMQ 产生这种行为，而无需编写那么多代码？

谢谢

Answer 1

我使用 HAProxy 在rabbitmq的集群节点之间进行故障转移和负载平衡，也在.net客户端上，当节点发生故障时，您需要手动重新连接客户端。

以下是两个节点集群的 HAProxy 配置，节点在 15672 和 25672 端口上运行。
客户端连接到 5672 端口。

global
 daemon
 log 127.0.0.1 alert
 log 127.0.0.1 alert debug

defaults
 log global
 mode http
 option  dontlognull
 option  redispatch
 retries    3
 contimeout 5000
 clitimeout 50000
 srvtimeout 50000

listen rabbitmq 0.0.0.0:5672
  mode tcp
  balance roundrobin
  option  tcpka

server rabbit01 127.0.0.1:25672 check inter 5000 downinter 500

server rabbit02 127.0.0.1:15672 check inter 5000 backup

感谢这篇博客文章 http://www.joshdevins .net/2010/04/16/rabbitmq-ha-testing-with-haproxy/