让 JMS 消费者保持活动状态以获取消息

Question

我正在编写一个简单的 java 程序来创建一个 JMSConsumer。我希望消费者等到生产者发布一些东西，然后主程序终止。这是我的主要内容：

    JMSContext context;
    Destination destination; 
    JMSConsumer consumer;
    
    JmsConnectionFactory connectionFactory = createJMSConnectionFactory();

    setJMSProperties(connectionFactory);

    System.out.println("MQ Test: Connecting to " + HOST + ", Port " + PORT + ", Channel " + CHANNEL
    + ", Connecting to " + QUEUE_NAME);

    try {
        context = connectionFactory.createContext(); 
        destination = context.createQueue("queue:///" + QUEUE_NAME); 
        consumer = context.createConsumer(destination); 

        MessageListener ml = new DemoMessageListener(); 
        consumer.setMessageListener(ml); 
        
        System.out.println("The message listener is running."); // (Because the connection is started by default)

        context.start();
        
        
    } catch (Exception e){}

问题是当程序到达main的底部时，程序就结束了。
我试图获得的结果类似于 RabbitMq 的 basicConsuime（下面的示例）：

public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, EXCHANGE_NAME, "");

System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

DeliverCallback deliverCallback = (consumerTag, delivery) -> {
    String message = new String(delivery.getBody(), "UTF-8");
    System.out.println(" [x] Received '" + message + "'");
};
channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
}

当main结束时，读取消息的线程还活着，每次向队列发送消息时都会调用deliverCallback。

有什么想法吗？

Answer 1

在当前情况下，一旦主进程结束，所有与进程关联的线程都会终止。

有几个选项可以实现您提到的目标。

1. 您将代码部署在任何容器中，例如 tomcat 作为应用程序 这将保持进程运行。
2. 其他方法是让您的主线程忙于等待，并在需要时使用 thread.notify 终止。

Answer 2

好吧，如果您只想做与您的“基本消费”相同的事情，您可以这样做（忘记您的演示侦听器等）：

  ...
  try {
    context = connectionFactory.createContext(); 
    destination = context.createQueue("queue:///" + QUEUE_NAME); 
    consumer = context.createConsumer(destination); 

    /*
    MessageListener ml = new DemoMessageListener(); 
    consumer.setMessageListener(ml); 
    
    System.out.println("The message listener is running."); // (Because the connection is started by default)

    context.start();
    */
    
    String  body = consumer.receiveBody(String.class);
    System.out.println("Received message body: " + body);
    
} catch (Exception e){}