Artemis集群-具有多个接收器的负载平衡

提问者：小点点

Artemis集群-具有多个接收器的负载平衡

我有一个由4个节点组成的Artemis集群（2个主节点，2个备份）。每个代理都有2个接收者——一个用于核心协议，一个用于跺脚协议（因为跺脚需要前缀属性）。所以它们有不同的端口。

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

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

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

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

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

以下显示了一个主代理和一个备份代理的代理配置片段：

大师：

<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>

有人能帮忙吗？

共1个答案

匿名用户

根据你目前提供的所有信息，一切似乎都很好。你引用的留档说：

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

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

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

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

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

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

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