无法使用使用 MessageProducer.send() 创建的 JmsTemplate.receive() 检索消息

Question

我正在使用Spring Boot来启动嵌入式ActiveMQ代理，并且我正在使用spring-jms在运行时为主题动态注册JMS端点。我让这部分工作，当我创建一个 JMS 消息并将其发送到主题时，它最终会被我的听众使用。目前为止，一切都好。在侦听器内部，如果在消息中设置了 JMS 标头"JMSReplyTo"，我想向其他主题发送一条简单的 ACK 消息。如果是，我将创建一个消息生产者，并将目标设置为标头中设置的主题，然后发送 ACK 消息。代码似乎有效，或者至少我认为是这样，因为我没有收到任何错误。但是，在我的测试用例中，在发送初始消息后，我正在尝试读取返回另一个主题的 ACK，并且调用超时。我正在使用 JmsTemplate 来发送原始消息，以及使用 ACK。我确定我错过了一些东西，但我不确定是什么。这是相关的Spring Java配置部分，显示了SessionAwareMessageListener：

@Bean(name = "sessionAwareMessageListener")
SessionAwareMessageListener<TextMessage> createSessionAwareMessageListener() {
  return new SessionAwareMessageListener<TextMessage>() {
    @Override
    public void onMessage(TextMessage message, Session session) throws JMSException {
      log.info(" Received: {} ", message.getText());
      // Prepare an ACK reply message
      final ActiveMQTextMessage textMessage = new ActiveMQTextMessage();
      textMessage.setText("ACK");
      // Send the ACK message back to the replyTo address of the incoming
      // message. 
      if (message.getJMSReplyTo() != null) {
        log.info("Sending ACK message to {}", message.getJMSReplyTo());
        // session.createTopic(message.getJMSReplyTo().toString());
        MessageProducer producer = session.createProducer(message.getJMSReplyTo());
        producer.send(textMessage);
      }
    }
  };
}

在我的 Spock 集成测试中，我创建了一个 MessageProducer 并通过 JmsTemplate 实例发送消息：

...other stuff here...
MessageCreator messageCreator = new MessageCreator() {
  @Override
  public Message createMessage(Session session) throws JMSException {
    log.info("Sending text message")
    TextMessage message = session.createTextMessage("This is a test")
    message.setJMSReplyTo(new ActiveMQTopic("test"))
    return message
  }
}
... code that registers the JMS endpoint goes here...
JmsTemplate jmsTemplate = context.getBean(JmsTemplate)
assert jmsTemplate
jmsTemplate.send("bar", messageCreator)

消息发送成功，最终由前面所示的 SessionAwareMessageListener 处理。但是当我尝试使用 JmsTemplate.receive（） 检索 ACK 消息时，它会阻塞，直到调用超时并返回 null。没有在 ACK 消息的主题上注册特定的侦听器或动态创建的端点，因此我认为可以使用 JmsTemplate.receive（） 使用消息。显然我在这里做错了什么，但我真的想不通是什么。这是我尝试接收 ACK 的代码片段：

jmsTemplate.setReceiveTimeout(2000L)
Message received = jmsTemplate.receive("test")
assert received instanceof ActiveMQTextMessage
log.info("Received message: ${received}")
assert ((ActiveMQTextMessage) received).text == "ACK"

我将不胜感激能提供更好的方法。在这一点上，我真的只是在做实验。我知道我需要动态注册终结点，并可能将消息转发到其他主题。谢谢。

Answer 1

使用主题进行请求/回复消息传递通常不是一个好主意，尤其是在回复端。

1. 回复可能会在receive()订阅主题之前到达;代理将丢弃此类消息，除非该订阅是持久的。
2. 您通常只希望将回复发送给发起人。

使用队列而不是主题，尤其是对于回复。

请考虑使用JmsTemplate进行回复，而不是创建自己的生成者;如果您使用的是DefaultMessageListenerContainer和会话事务（应始终将sessionTransacted与 DMLC 一起使用以避免丢失消息），则模板将自动使用相同的会话。

如果您希望对一条消息有多个响应，则可以在请求端使用主题，但同样，除非订阅是持久的，否则回复的数量将是不确定的 - 您无法在生产者端告诉有多少消费者会收到它。