使用Micronaut构建微服务时RabbitMQ仅创建交换机不生成队列、订阅者无法接收消息问题排查

你的核心问题出在消费者的连接和通道被自动关闭，导致RabbitMQ自动删除了你创建的队列，自然无法接收消息。

看你的receive()方法代码：

try (final Connection connection = factory.newConnection();
     final Channel channel = connection.createChannel()){
    // 队列声明、绑定、消费逻辑
}

你用了Java的try-with-resources语法，这个语法会在代码块执行完毕后自动关闭Connection和Channel。而你声明队列时用了autoDelete=true（queueDeclare的第四个参数），RabbitMQ的规则是：当某个队列的最后一个消费者断开连接，且autoDelete=true时，队列会被自动删除。

所以你的代码执行流程是：

1. 创建连接和通道
2. 声明队列并绑定到交换机
3. 设置消费回调
4. try块结束，连接和通道被关闭
5. RabbitMQ检测到队列没有活跃消费者，自动删除队列

这就是为什么你在控制台看不到队列，也收不到消息——队列在应用启动后很快就被删了。

1. 手动管理连接和通道的生命周期 #

不要用try-with-resources来包裹Connection和Channel，而是把它们作为类成员变量，在服务启动时初始化，在服务关闭时手动清理。

修改你的RabbitMQ订阅实现类：

import jakarta.annotation.PreDestroy;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.TimeoutException;

public class RabbitMQBrokerSubscriber implements BrokerSubscriber {
    private static final Logger LOG = LoggerFactory.getLogger(RabbitMQBrokerSubscriber.class);
    
    private Connection connection;
    private Channel channel;
    private final List<String> exchanges;
    private final ConnectionFactory connectionFactory;

    // 通过构造函数注入依赖
    public RabbitMQBrokerSubscriber(List<String> exchanges, ConnectionFactory connectionFactory) {
        this.exchanges = exchanges;
        this.connectionFactory = connectionFactory;
    }

    @Override
    public void receive() throws BrokerSubscribeException {
        try {
            // 初始化连接和通道，不放在try-with-resources里
            connection = connectionFactory.newConnection();
            channel = connection.createChannel();

            for (final String exchange : exchanges) {
                channel.exchangeDeclare(exchange, BuiltinExchangeType.TOPIC, true);
                // 调整队列参数：autoDelete设为false（根据业务需求，也可以保留true，但要确保连接持续）
                // durable=true保证队列重启后不丢失，exclusive=true表示只有当前连接能访问这个队列
                final String queueName = channel.queueDeclare(UUID.randomUUID().toString(), true, true, false, null).getQueue();
                channel.queueBind(queueName, exchange, "#");
                LOG.info("Waiting for messages on exchange '{}', with bound queue '{}'", exchange, queueName);
                
                final DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                    final String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
                    LOG.info("Received '{}' with message\n:{}", delivery.getEnvelope().getRoutingKey(), message);
                };
                // 启动消费
                channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});
            }
        } catch (final IOException | TimeoutException e) {
            throw new BrokerSubscribeException("Failed when subscribing to messages", e);
        }
    }

    // 服务关闭时手动清理连接和通道
    @PreDestroy
    public void cleanup() {
        try {
            if (channel != null && channel.isOpen()) {
                channel.close();
            }
            if (connection != null && connection.isOpen()) {
                connection.close();
            }
        } catch (IOException | TimeoutException e) {
            LOG.warn("Failed to close broker connection or channel", e);
        }
    }
}

2. 关于多连接的疑问 #

你问同一个Micronaut应用创建两个连接到RabbitMQ是否有问题——技术上没问题，但不推荐。RabbitMQ的Connection是重量级资源，创建和销毁开销大，而Channel是轻量级的，一个Connection可以创建多个Channel。所以建议发布者和订阅者复用同一个Connection，各自使用独立的Channel，这样更高效。

3. 队列参数调整建议 #

• durable=true：保证队列在RabbitMQ重启后不会丢失
• autoDelete=false：避免队列因为消费者临时断开被自动删除（如果你的业务需要队列长期存在）
• 如果不需要队列在应用重启后保留，autoDelete=true是可以的，但必须保证连接持续活跃

修改后重启应用，你应该能在RabbitMQ控制台看到对应的队列，并且当商品服务发送事件时，支付服务的消费者能正常打印接收到的消息。

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