如何在Docker Compose中创建带Topic的JMS队列？Spring Boot测试疑问

你的思路完全没问题，本地用Docker Compose搭建ActiveMQ + Spring Boot的测试环境，是验证JMS消费逻辑的合理方案。下面针对你的问题给出具体解决方法：

一、解决ActiveMQ队列创建问题 #

ActiveMQ本身支持自动创建队列，只要你的Spring Boot应用中@JmsListener指定了队列名称，当应用启动并尝试连接ActiveMQ时，队列会被自动创建，不需要手动提前配置。如果确实需要预创建队列，有两种简单方式：

• 通过配置文件预定义：在Docker Compose中挂载自定义的activemq.xml到容器的/opt/activemq/conf/目录，在配置里添加队列定义：

  <broker ...>
      <destinations>
          <queue physicalName="your-queue-name"/>
      </destinations>
  </broker>
  

• 通过初始化脚本创建：编写一个shell脚本（比如init-queues.sh），内容如下：

  #!/bin/bash
  /opt/activemq/bin/activemq-admin queue create --queueName your-queue-name
  

  然后在Docker Compose中挂载这个脚本到/opt/activemq/bin/init.d/目录，容器启动时会自动执行脚本创建队列。

二、更简便的触发JmsListener的方式 #

除了SOAP UI/Postman（这类工具需要额外插件才能发送JMS消息），推荐几种更直接的方法：

• 单元测试直接发送：在Spring Boot测试类中注入JmsTemplate，直接发送测试消息：

  @SpringBootTest
  class JmsConsumerTest {
      @Autowired
      private JmsTemplate jmsTemplate;
  
      @Test
      void triggerJmsListener() {
          jmsTemplate.convertAndSend("your-queue-name", "测试触发消息");
      }
  }
  

• 添加HTTP接口快速触发：写一个简单的Controller，提供HTTP接口来发送消息，无需额外工具：

  @RestController
  @RequestMapping("/message")
  public class MessageTriggerController {
      @Autowired
      private JmsTemplate jmsTemplate;
  
      @PostMapping("/send")
      public String sendToQueue(@RequestParam String queue, @RequestParam String content) {
          jmsTemplate.convertAndSend(queue, content);
          return "消息已发送至队列：" + queue;
      }
  }
  

  启动应用后，用curl或浏览器就能调用接口：

  curl -X POST "http://localhost:8080/message/send?queue=your-queue-name&content=测试消息"
  

• ActiveMQ命令行工具：进入运行中的ActiveMQ容器，执行内置命令发送消息：

  docker exec -it <activemq-container-id> /opt/activemq/bin/activemq-admin produce --queueName your-queue-name --message "测试消息"
  

内容的提问来源于stack exchange，提问作者en93