Spring嵌入式ActiveMQ：如何配置可自动注入的命名队列？

嗨，这个问题很常见，我来给你一步步说明怎么实现：

首先，你已经用VM模式启动了ActiveMQ，这种情况下Broker和你的应用在同一个JVM里，所以我们可以很方便地直接创建并注册命名队列到Spring容器，同时确保队列在Broker中被初始化。

方法一：直接注册Queue Bean（最简单） #

你只需要在Spring配置类中添加一个Queue类型的Bean，使用ActiveMQ的ActiveMQQueue实现类即可。这样Spring会自动管理这个队列实例，你可以在任何需要的地方通过@Autowire注入它：

@Bean
public Queue myBusinessQueue() {
    // 这里传入队列的名称，比如"order-processing-queue"
    return new ActiveMQQueue("order-processing-queue");
}

然后在你的业务类里直接注入：

@Autowired
private Queue myBusinessQueue;

额外配置（可选） #

如果需要给队列设置特殊属性（比如持久化、排他性等），可以直接在Bean定义里配置：

@Bean
public Queue persistentExclusiveQueue() {
    ActiveMQQueue queue = new ActiveMQQueue("exclusive-persistent-queue");
    // 设置队列持久化（默认就是true，这里显式声明）
    queue.setPersistent(true);
    // 设置为排他队列，只有第一个连接的消费者能接收消息
    queue.setExclusive(true);
    return queue;
}

方法二：通过BrokerService显式注册队列（更可控） #

如果你希望确保队列在ActiveMQ Broker启动时就被创建（虽然VM模式下，当你发送消息到不存在的队列时Broker会自动创建，但显式注册更可控），可以修改你原来的jms1 Bean配置，获取Broker实例并添加队列：

@Bean @Qualifier("jms1") 
public JmsComponent jms1() throws Exception { 
    ActiveMQConnectionFactory f = new ActiveMQConnectionFactory("vm://localhost:7777");
    
    // 获取VM模式下的BrokerService实例
    BrokerService broker = f.getBrokerService();
    // 如果Broker还没启动，手动启动（Spring可能已经帮你启动了，但保险起见）
    if (!broker.isStarted()) {
        broker.start();
    }
    
    // 创建队列并添加到Broker
    Queue targetQueue = new ActiveMQQueue("inventory-update-queue");
    broker.addDestination(targetQueue);
    
    return JmsComponent.jmsComponentAutoAcknowledge(f); 
}

然后同样注册这个队列到Spring容器（和方法一一样），这样就能正常注入了。

为什么这样可行？ #

VM模式的ActiveMQ Broker运行在你的应用JVM内部，所以我们可以直接通过ActiveMQConnectionFactory获取到Broker的实例，进而管理队列等目的地。而ActiveMQQueue实现了标准的javax.jms.Queue接口，所以Spring可以直接把它作为Bean管理，支持依赖注入。

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