用ActiveMQ Artemis解决集群测试问题

Question

我有两个ActiveMQ Artemis实例，只需使用命令/.Artemis创建Artemis/server1和

/.Artemis创建Artemis/server2

以下是服务器1的broker.xml：

  <acceptors>
     <!-- Acceptor for every supported protocol -->
     <acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>

  </acceptors>

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

 <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>STRICT</message-load-balancing>
        <max-hops>1</max-hops>
        <static-connectors>
           <connector-ref>server1-connector</connector-ref>
        </static-connectors>
     </cluster-connection>
  </cluster-connections>

下面是服务器2的broker.xml：

     <!-- Acceptor for every supported protocol -->
   <acceptor name="artemis">tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300</acceptor>
  </acceptors>

  <connectors>
     <connector name="netty-connector">tcp://localhost:61617</connector>
     <!-- connector to the server0 -->
     <connector name="server0-connector">tcp://localhost:61616</connector>
  </connectors>

  <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>STRICT</message-load-balancing>
        <max-hops>1</max-hops>
        <static-connectors>
           <connector-ref>server0-connector</connector-ref>
        </static-connectors>
     </cluster-connection>
  </cluster-connections>

同样在server2中，Bootstrap.xml中的更改更改了web绑定端口

<web bind="http://localhost:8163" path="web">

我正在用StaticClusteredQueueExample和这个示例工作文件测试它。

现在我正在对我的集群运行ActiveMQ Artemis JMeter性能，我正在使用JMeter测试示例，下面是

现在，当我使用Jmeter运行点对点测试时，消费者中的错误率接近50%（Jmeter中的聚合报告），

但是当我在ubantu系统中只运行一个节点（server1或server2)时，它工作得很好，0%的错误率（Jmeter中的聚合报告）。

你能帮我解释一下为什么我在使用docker运行多个实例（节点）时会得到50%的错误率（Jmeter中的聚合报告）吗

Answer 1

问题是，您将一个示例（即JMeter示例）与一个确实不兼容的集群配置（即来自clustered-statist-discovery示例）混合在一起。

集群的 是严格的，这意味着消息将在集群中进行负载平衡，而不管使用者是否存在。此外，默认的 是-1，这意味着由于严格的消息负载平衡类型而发送到集群中其他节点的消息将留在这些节点上，不会根据用户需求进行重新分发。

JMeter示例是在编写时考虑到一个节点，因此它只向一个节点发送消息并使用来自一个节点的消息，这意味着它只接收它发送的消息的一半，因为另一半消息由于配置而被转发到集群中的另一个节点。

如果将 更改为ON_DEMAND，则不会看到任何错误，因为所有消息都将留在特定发送它们的节点上，也是连接使用者的节点。