代理失败时的集群 ActiveMQ Artemis 和生产者/消费者负载平衡配置

如何解决代理失败时的集群 ActiveMQ Artemis 和生产者/消费者负载平衡配置

我创建了一个带有两个活动代理的 ActiveMQ Artemis 集群。我创建了一个自定义负载平衡器，以便能够根据我的要求和工作负载以静态方式最初分配我的队列。

<connectors>
  <connector name="broker1-connector">tcp://myhost1:61616</connector>
  <connector name="broker2-connector">tcp://myhost2:62616</connector>
</connectors>

<cluster-connections>
  <cluster-connection name="myhost1-cluster">
    <connector-ref>broker1-connector</connector-ref>
    <retry-interval>500</retry-interval>
    <use-duplicate-detection>true</use-duplicate-detection>
    <message-load-balancing>ON_DEMAND</message-load-balancing>
    <max-hops>1</max-hops>
    <static-connectors>
      <connector-ref>broker2-connector</connector-ref>
    </static-connectors>
  </cluster-connection>
</cluster-connections>

我的问题是，当 broker1 关闭时，基于此拓扑，我可以在 broker2 上重新创建其队列以避免丢失消息（通过在生产者 (tcp://myhost1:61616,tcp://myhost2:62616) 上使用连接字符串）。

但是当 broker1 再次可用时，我的生产者并不知道这一点，它仍然使用与 broker2 的连接（如果这很重要，broker2 redistribution-delay 设置为 0 并且没有注册消费者）。有没有办法或一些配置来恢复我的生产者只写到 broker1。

这会影响我最初连接到 broker1 的消费者，我不确定是否还有某种方式/配置可以使它们在这些代理之间透明地反弹，或者我是否需要创建两个消费者（实际上它们将处于空闲状态） ) 每个都针对相应的经纪人？

解决方法

代理无法告诉客户端它应该连接到加入集群的另一个节点。

我的建议是将 HA 与故障回复一起使用，这样当一个节点出现故障时，所有连接到该节点的客户端都会故障转移到备份节点，然后当原始节点恢复时，所有客户端都故障回复到原始节点。

您可能还会发现您实际上并不需要一个由 2 个代理组成的集群。许多用户从未执行必要的性能测试来确认集群甚至是必要的。他们只是假设一个集群是必要的。这种假设会不必要地使平台架构复杂化并浪费宝贵的资源。 ActiveMQ Artemis 的性能相当不错。在某些用例中，单个节点每秒可以处理数百万条消息。