在ActiveMQ Artemis上的主题上加载平衡使用者

Question

我使用的是ActiveMQ Artemis 2.10和JMS Client1.1客户机。

如果我在我的地址上使用了多播路由类型，并且需要持久订阅，我如何在消费者端实现负载平衡？

在ActiveMQ5中，它将是虚拟目的地。

唯一的选择似乎是ActiveMQ Artemis2.10和JMS Client2.0，它们允许您创建共享的持久订阅，这对吗？

还有第三种选择吗？

Answer 1

我目前的理解是，Active MQ Artemis7.2和JMS Client1.1 Client意味着您不能在主题上进行负载平衡，这是正确的吗？

没有。

唯一的选择似乎是Active MQ Artemis7.2和JMS Client2.0，它们允许您创建共享的持久订阅，这对吗？

ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
Connection connection1 = cf.createConnection();
connection1.setClientID("myClientID");
Session session1 = connection1.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = new ActiveMQTopic("myTopic");
MessageConsumer consumer1 = session1.createDurableSubscriber(topic, "mySubscriptionName");

Connection connection2 = cf.createConnection();
Session session2 = connection2.createSession();
Destination destination = new ActiveMQQueue("myTopic::myClientID.mySubscriptionName");
MessageConsumer consumer2 = session2.createConsumer(destination);

// Send 2 messages
MessageProducer producer = session1.createProducer(topic);
producer.send(session1.createMessage());
producer.send(session1.createMessage());
producer.close();

// Receive the first message with the first consumer
connection1.start();
Message message1 = consumer1.receive();
consumer1.close();

// Receive the second message with the second consumer
connection2.start();
Message message2 = consumer2.receive();
consumer2.close();

由于JMS1.1不显式地允许共享持久订阅，所以您不能使用CreateDurableSubscriber在同一主题上使用相同的客户机标识符和订阅名称水平扩展应用程序。但是，如果一个应用程序使用CreateDurableSubscriber，而所有其他应用程序使用其“完全限定队列名”直接从基础订阅队列中使用，则可以水平伸缩（完全限定队列名是从第一次使用CreateDurableSubscriberCreateDurableSubscriberCreateDurableSubscriberCreateDurableSubscriber创建时使用的客户端标识符和订阅名派生出来的）。