使用 ActiveMQ 虚拟机传输未收到来自生产者的消息

Question

我现在正在使用 activeMQ tcp//localhost URL 来安静一段时间，我对此没有任何问题。目前，我正在尝试使用“vm//localhost”连接器，但在接收来自生产者的消息时遇到问题。我正在使用弹簧靴，生产者和消费者在不同的罐子里。我的消费者收到一条空消息。我错过了什么吗？下面是我的代码（取自 apache 网站）。提前致谢

生产者.jar

ActiveMQConnectionFactory connectionFactory = 
new ActiveMQConnectionFactory("vm://localhost");
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TEST.FOO");
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

String text = "Hello world! From: " + Thread.currentThread().getName() + " : " + this.hashCode();
TextMessage message = session.createTextMessage(text);

System.out.println("Sent message: " + message.hashCode() + " : " + Thread.currentThread().getName());
producer.send(message);

session.close();
connection.close();

Consumer.jar

ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory("vm://localhost");
Connection connection = connectionFactory.createConnection();
connection.start();

connection.setExceptionListener(this);

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TEST.FOO");

MessageConsumer consumer = session.createConsumer(destination);

// Wait for a message
Message message = consumer.receive(10000);

if (message instanceof TextMessage) {
    TextMessage textMessage = (TextMessage) message;
    String text = textMessage.getText();
    System.out.println("Received 1: " + text);
} else {
    System.out.println("Received 2: " + message);
}

consumer.close();
session.close();
connection.close();

Answer 1

我确定，vm 是 VM 内部的传输！并且无法在其外部访问，因此解决方案是 2 个客户端之一需要使用 vm 传输，而另一个 tcp 和 ActiveMQ 在使用 vm 传输的一个中启动，或者将您的 2 个组件嵌入到同一个 VM 中。

查看我对同一用例的另一个答案 How to send Jms message from one spring-boot application to another when both apps use embedded activemq