Spring Boot集成RabbitMQ：队列不存在时自动创建的实现咨询

解决方案思路 #

你的现有代码直接通过routingKey发送消息到默认交换机（空字符串交换机），此时routingKey等价于目标队列名。默认情况下RabbitMQ不会自动创建不存在的队列，我们可以借助RabbitAdmin实现动态检查并创建队列的逻辑。

具体实现步骤 #

1. 注入依赖组件：Spring Boot引入spring-boot-starter-amqp后会自动配置RabbitTemplate和RabbitAdmin，直接注入即可。
2. 修改发送方法：在发送消息前检查队列是否存在，不存在则创建队列（可自定义队列属性）。

完整代码示例 #

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class RabbitMqSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Autowired
    private RabbitAdmin rabbitAdmin;

    public void sendMessage(String message, String routingKey) {
        // 检查目标队列是否存在（routingKey即队列名，默认交换机场景）
        if (rabbitAdmin.getQueueProperties(routingKey) == null) {
            // 创建持久化、非排他、非自动删除的队列（可根据需求调整参数）
            Queue queue = new Queue(routingKey, true, false, false);
            rabbitAdmin.declareQueue(queue);

            // 【可选】如果使用自定义交换机，需额外声明交换机和绑定关系
            // Exchange exchange = new DirectExchange("your-custom-exchange", true, false);
            // rabbitAdmin.declareExchange(exchange);
            // rabbitAdmin.declareBinding(BindingBuilder.bind(queue).to(exchange).with(routingKey));
        }

        rabbitTemplate.convertAndSend(routingKey, message);
    }
}

关键参数说明 #

创建Queue时的构造参数含义：

• name：队列名称（即传入的routingKey）
• durable：是否持久化（true则RabbitMQ重启后队列保留）
• exclusive：是否排他队列（仅当前连接可用，连接关闭后自动删除）
• autoDelete：是否自动删除（当最后一个消费者断开后自动删除队列）

注意事项 #

• RabbitMQ的队列声明是幂等操作：多次执行相同参数的声明不会重复创建或报错，多服务实例同时创建同一队列也不会有冲突。
• 如果使用自定义交换机，发送消息时需指定交换机名称：rabbitTemplate.convertAndSend(exchangeName, routingKey, message)，同时补充交换机和绑定关系的声明逻辑。

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