ActiveMQ Artemis-使用JMS获取可用地址列表

Question

我最近不得不从ActiveMQ 5.X切换到我正在进行的项目的ActiveMQ Artemis。我有一个函数可以读取可用主题并填充MySQL数据库中的表，但该函数不再适用于Artemis中方法的更改。

基本上，我不需要获得可用主题的列表(也称为多播队列)，而是需要获得可用地址的列表，以便我的消费者可以连接并为该地址创建一个同名的多播队列。

以下是我需要此功能的原因:

< li >用户使用网站(从数据库读取)从ActiveMQ中选择地址名称 < li >消费者连接到该地址名称并排队 < li>Java消费者/生产者每秒用网站的可用地址更新数据库

这是我以前在以前的ActiveMQ 5上使用的代码。x:

public class ActiveMQ {

    public ActiveMQ(String amq_url) throws JMSException, NamingException{
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(amq_url);      
        this.connection = (ActiveMQConnection) connectionFactory.createConnection();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        connection.start();
    }

    public void useTopic(String topicName) throws JMSException{
        this.topic = session.createTopic(topicName);
        this.producer = session.createConsumer(topic);
    }

    
    public void readAvailableTopics() throws JMSException{ 
         
        Set<ActiveMQTopic> topics = connection.getDestinationSource().getTopics();
        System.out.println(topics.toString());
        return topics;
    }
 

readAvailableTopics()方法就是正在讨论的方法。

我在消费者端和生产者端都尝试过.getTopics（）和.getQueues（），它们都会返回一个空集。我找不到任何JMS文档来获取可用地址。

任何帮助将不胜感激。

Answer 1

ActiveMQ 5客户端通过咨询消息更新主题和队列列表。由于ActiveMQ Artemis 2.18默认情况下禁用了咨询消息支持，请参阅Artemis-3414。要启用咨询消息支持功能，请将SupportDvisory参数添加到接收器，即。

<acceptor name="artemis">tcp://0.0.0.0:61616?protocols=OPENWIRE;supportAdvisory=true</acceptor>

Answer 2

JMS规范不包括这样的管理操作，因此每个代理实现都有不同的访问方式。ActiveMQ Artemis在许多方面与ActiveMQ“经典”类似，但访问管理操作不同。也就是说，您可以使用JMS调用管理操作。您可以使用如下代码列出所有地址：

import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueRequestor;
import javax.jms.QueueSession;
import javax.jms.Session;
...
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.api.jms.management.JMSManagementHelper;
import org.apache.activemq.artemis.api.core.management.ResourceNames;
...

QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue managementQueue = ActiveMQJMSClient.createQueue("activemq.management");
QueueRequestor requestor = new QueueRequestor(session, managementQueue);
Message m = session.createMessage();
JMSManagementHelper.putOperationInvocation(m, ResourceNames.BROKER, "getAddressNames");
Message reply = requestor.request(m);
boolean success = JMSManagementHelper.hasOperationSucceeded(reply);
if (success) {
   Object[] addresses = (Object[]) JMSManagementHelper.getResult(reply);
   for (Object address : addresses) {
      System.out.println(address);
   }
}