ActiveMQ订阅多个主题

Question

我一直在尝试使用 activemq 和 java 从 tcp 服务器订阅多个主题。

据谷歌告诉我，我可以使用通配符或复合目的地来做到这一点但是主题的命名方式对通配符非常不友好。当我尝试将目的地设置为“topic1，topic2”时，我不断收到错误消息，说我无权访问这些主题，而如果我只听 topic1 或 topic2，订阅工作顺利。

有些人还建议我可以更改 activemq.xml 文件以在其中设置代理，但我不明白这些是如何工作的。如果这是解决方案，也许有人可以抽出宝贵的时间向我解释一下？

感谢您的宝贵时间。

最好的问候

更具体的代码附在这里：

import javax.jms.*;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.log4j.BasicConfigurator;

public class Consumer {
 // URL of the JMS server
 private static String url = "tcp://datafeeds.networkrail.co.uk:61619";
 private static String username = "my username";
 private static String password = "my password";
 private static String topic = "topic1";

 public static void main(String[] args) throws JMSException {
  BasicConfigurator.configure();
  // Getting JMS connection from the server
  ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
  Connection connection = connectionFactory.createConnection(username,password);
   connection.start();
  Session session = connection.createSession(false,
    Session.AUTO_ACKNOWLEDGE);
  Destination destination = session.createTopic(topic);

  MessageConsumer consumer = session.createConsumer(destination);

    while (true)
    {
        //System.out.println("Waiting for message...");
        Message message = consumer.receive();
        if (message != null && message instanceof TextMessage) {
            TextMessage txtMsg = (TextMessage)message;
            System.out.println("Received: " + txtMsg.getText());
        }
    }
    //System.out.println("Closing connection");
    //consumer.close();
    //session.close();
    //connection.close();

}}

Answer 1

你可以轻松做到

Destination your-second-destination = session.createTopic("name-of-the-second-topic");
MessageConsumer consumer2 = session.createConsumer(your-second-destination);

然后让您的主类实现 MessageListener 接口，并将其设置为您的两个消费者的消息侦听器（总比忙着等待要好）。

最后一点：您没有连接到 TCP 服务器，而是通过 TCP 连接到 ActiveMQ 代理。这可能看起来很挑剔，但用词清晰可以避免混淆。