Artemis 集群 - 使用多个接受器进行负载平衡

Question

我有一个包含 4 个节点（2 个主节点，2 个备份节点）的 Artemis 集群。每个代理都有 2 个接受器 - 一个用于核心协议，一个用于 stomp 协议（因为 stomp 需要前缀属性）。所以他们有不同的端口。

当我使用 jms-client 2.x 和 ConnectionFactory 从 Spring Boot 应用程序连接集群时，地址和消息在节点之间进行负载平衡。但是当我尝试与 stomp 客户端交互时，它根本没有负载平衡。似乎无法以某种方式识别集群连接。我不确定可能是什么问题。

The documentation 表示消息通过集群连接进行负载平衡：

这些集群连接允许消息在集群的节点之间流动以平衡负载。

所以也许我需要更多的集群连接和连接器，它们在broker.xml 中配置？

我有一个 STOMP 客户端，它使用端口 61613 连接到第一个主节点。当我将消息发送到第一个主节点时，我可以使用来自另一个节点的消息，并且我可以看到两个节点上都创建了地址.一种是带有齿条轮的被动模式，另一种是带有文件夹符号的主动模式，可以扩展。从应用程序创建的地址都只在一个节点上。

以下显示了一个主代理和一个备份代理的代理配置的 sn-ps：

主人：

<connectors>
   <connector name="netty-connector">tcp://localhost:61616</connector>
</connectors>

<acceptors>
   <acceptor name="artemis">tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>
   <acceptor name="stomp">tcp://localhost:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;anycastPrefix=/queue/;multicastPrefix=/topic/</acceptor>
</acceptors>


<!-- failover config -->
<ha-policy>
   <replication>
      <master>
         <check-for-live-server>true</check-for-live-server>
      </master>
   </replication>   
</ha-policy>

<broadcast-groups>
   <broadcast-group name="my-broadcast-group">
      <broadcast-period>5000</broadcast-period>
      <jgroups-file>test-jgroups-jdbc_ping.xml</jgroups-file>
      <jgroups-channel>active_broadcast_channel</jgroups-channel>
      <connector-ref>netty-connector</connector-ref>
   </broadcast-group>
</broadcast-groups>

<discovery-groups>
   <discovery-group name="my-discovery-group">
      <jgroups-file>test-jgroups-jdbc_ping.xml</jgroups-file>
      <jgroups-channel>active_broadcast_channel</jgroups-channel>
      <refresh-timeout>10000</refresh-timeout>
   </discovery-group>
</discovery-groups>

<cluster-connections>
   <cluster-connection name="my-cluster">
      <connector-ref>netty-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>
      <discovery-group-ref discovery-group-name="my-discovery-group"/>
   </cluster-connection>       
</cluster-connections>

备份：

<connectors>
   <connector name="netty-connector">tcp://localhost:61617</connector>
   <connector name="server1-netty-live-connector">tcp://localhost:61616</connector>  
</connectors>

<acceptors>
   <acceptor name="artemis">tcp://localhost:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>
   <acceptor name="stomp">tcp://localhost:61614?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;anycastPrefix=/queue/;multicastPrefix=/topic/</acceptor>
</acceptors>

<cluster-user>user</cluster-user>
<cluster-password>pw</cluster-password>

<!-- failover config -->
<ha-policy>
   <replication>
      <slave>
         <allow-failback>true</allow-failback>
      </slave>
   </replication>
</ha-policy>

<broadcast-groups>
   <broadcast-group name="my-broadcast-group">
      <broadcast-period>5000</broadcast-period>
      <jgroups-file>test-jgroups-jdbc_ping.xml</jgroups-file>
      <jgroups-channel>active_broadcast_channel</jgroups-channel>
      <connector-ref>netty-connector</connector-ref>
   </broadcast-group>
</broadcast-groups>

<discovery-groups>
   <discovery-group name="my-discovery-group">
      <jgroups-file>test-jgroups-jdbc_ping.xml</jgroups-file>
      <jgroups-channel>active_broadcast_channel</jgroups-channel>
      <refresh-timeout>10000</refresh-timeout>
   </discovery-group>
</discovery-groups>

<cluster-connections>
   <cluster-connection name="my-cluster">
      <connector-ref>netty-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>
      <discovery-group-ref discovery-group-name="my-discovery-group"/>
   </cluster-connection>
</cluster-connections>

谁能帮忙？

Answer 1

根据您迄今为止提供的所有信息，一切似乎都运行良好。您引用的文档说：

这些集群连接允许消息在集群的节点之间流动以平衡负载。

当您向一个节点发送 STOMP 消息时，您可以从另一个节点使用它，这意味着消息会按需通过节点之间的集群连接流动以平衡负载。

您不需要任何额外的集群连接或连接器。

需要明确的是，集群中的每个代理都将拥有自己的一组地址、队列和消息，具体取决于连接到它们的客户端正在做什么。您不必期望在集群的所有不同节点上看到所有相同的地址或队列 - 特别是如果您依赖自动创建地址和队列而不是在 broker.xml 中预先配置它们。

也就是说，您将看到使用 JMS 客户端的应用程序（例如您的 Spring 应用程序）和使用 STOMP 的应用程序的一些不同行为。这是因为 STOMP 协议没有定义与连接负载平衡、故障转移等高级概念相关的任何内容。STOMP 是一个非常简单的协议，客户端通常也非常简单。此外，Spring 应用程序通常会创建多个连接。这些连接以循环方式在集群中的节点之间平衡，这几乎可以肯定为什么那些相关的地址和队列出现在所有节点上，而单个 STOMP 客户端的那些却没有。客户端连接负载平衡在the documentation 中进一步讨论。

消息由节点自己分发，与使用的协议无关。这就是集群连接的全部目的——将消息转发到其他节点。

客户端连接不能由节点自己自动分发，因为这需要重定向，而且并非所有协议（例如 STOMP）都支持这些语义。