activemq-artemis - Apache artemis は、STRICT 構成でサーバー ノードと同じ数の接続を作成する必要があります。

Question

clustered-static-discoveryと udp ベースのクラスタリングを確認しました。クラスター内に 2 つのノードがある場合は 2 つの接続が必要です。

接続またはリスナーを1つだけ作成した場合、2つの接続が必要な2つのサーバーがあり、10のメッセージを生成すると、5つのメッセージが失われるとします。

多数の接続を作成する代わりに、1 つの接続でメッセージを受信する方法 (使用されるサーバー ノードの数によって異なります)。実行時ノードが追加された場合のシナリオがあるため、実行時追加ノードに来るメッセージを見逃す可能性があります。

これは、2つのノード（クラスター内）と1つの接続がある例です

import javax.jms.*;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.core.client.impl.ClientSessionInternal;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.util.ServerUtil;
/**
 * A simple example that demonstrates server side load-balancing of messages between the queue instances on different
 * nodes of the cluster. The cluster is created from a static list of nodes.
 */
public class StaticClusteredQueueExample {
   public static void main(final String[] args) throws Exception {
      Connection connection0 = null;
      try {
         
         Topic topic = ActiveMQJMSClient.createTopic("exampleTopic");
        
         ConnectionFactory cf0 = new ActiveMQConnectionFactory("tcp://localhost:9616");
         Thread.sleep(2000);
         
         connection0 = cf0.createConnection();
         final String clientID = "admin";
         connection0.setClientID(clientID);
         final String subscriptionName = "mySub";
      
         Session session0 = connection0.createSession(false, Session.AUTO_ACKNOWLEDGE);
         connection0.start();
         
         MessageConsumer subscriber0 = session0.createDurableSubscriber(topic, subscriptionName);
         Thread.sleep(2000);
         
         MessageProducer producer = session0.createProducer(topic);
         //  We send 20 messages to server 
         final int numMessages = 20;
         for (int i = 0; i < numMessages; i++) {
            TextMessage message = session0.createTextMessage("This is text message " + i);
            producer.send(message);
            System.out.println("Sent message: " + message.getText());
         }
         Thread.sleep(2000);
                  
         for (int i = 0; i < numMessages; i += 2) {
            try {
               TextMessage message0 = (TextMessage) subscriber0.receive(5000);
               System.out.println("" + message0.getText() + ": from node " + ServerUtil.getServer(connection0));
            } catch (Exception e) {}
         }
      } finally {
         // Step 15. Be sure to close our resources!
         if (connection0 != null) {
            connection0.close();
         }
      }
   }
}

上記の例では、プロデューサーによって 20 のメッセージを送信しますが、出力を印刷しているときは、20 ではなく 10 のメッセージしか印刷しません。