Spring RabbitMQ：如何不使用@RabbitListener配置消费者？

完全可以不用@RabbitListener来配置RabbitMQ消费者，你对SimpleMessageListenerContainer和MessageListenerAdapter的判断存在误区——这两者都能支持多队列、多消费逻辑的场景，下面具体说明：

1. SimpleMessageListenerContainer 支持多队列与多处理器 #

你认为它无法设置多个onMessage处理器是错误的。每个SimpleMessageListenerContainer实例可以监听多个队列，同时你可以为不同的容器实例绑定不同的MessageListener（也就是自定义的onMessage处理器），以此实现多队列、多逻辑的消费需求：

@Bean
public SimpleMessageListenerContainer orderQueueContainer(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    container.setQueueNames("order-queue", "order-backup-queue"); // 同时监听多个队列
    container.setMessageListener(new OrderMessageListener()); // 绑定专属消息处理器
    container.setConcurrentConsumers(3); // 配置多线程消费实例
    return container;
}

@Bean
public SimpleMessageListenerContainer paymentQueueContainer(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    container.setQueueNames("payment-queue");
    container.setMessageListener(new PaymentMessageListener()); // 另一个消息处理器
    return container;
}

通过创建多个容器实例，就能分别对应不同的队列组和消费逻辑。

2. MessageListenerAdapter 并非仅适用于单消费者场景 #

MessageListenerAdapter的作用是把普通POJO包装成MessageListener，它同样可以配合多个容器实例实现多队列消费：

// 普通POJO形式的消息处理器
@Component
public class OrderHandler {
    public void handleOrderMessage(String message) {
        // 订单消息处理逻辑
    }
}

@Component
public class PaymentHandler {
    public void handlePaymentMessage(byte[] message) {
        // 支付消息处理逻辑
    }
}

@Bean
public SimpleMessageListenerContainer orderContainer(ConnectionFactory connectionFactory, OrderHandler orderHandler) {
    MessageListenerAdapter adapter = new MessageListenerAdapter(orderHandler);
    adapter.setDefaultListenerMethod("handleOrderMessage");

    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    container.setQueueNames("order-queue");
    container.setMessageListener(adapter);
    return container;
}

@Bean
public SimpleMessageListenerContainer paymentContainer(ConnectionFactory connectionFactory, PaymentHandler paymentHandler) {
    MessageListenerAdapter adapter = new MessageListenerAdapter(paymentHandler);
    adapter.setDefaultListenerMethod("handlePaymentMessage");

    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    container.setQueueNames("payment-queue");
    container.setMessageListener(adapter);
    return container;
}

你还可以为同一个队列配置多个容器实例（绑定不同适配器），实现不同逻辑的消费，或者通过setConcurrentConsumers配置多线程消费。

3. 结合配置标志实现消费源切换 #

要实现Kafka/RabbitMQ的无缝切换，你可以用@ConditionalOnProperty注解根据配置值创建对应消费者容器，同时抽离统一的消息处理逻辑：

@Configuration
public class ConsumerConfiguration {

    @Value("${message.consumer.source}")
    private String consumerSource;

    // RabbitMQ消费者容器：仅当配置为rabbitmq时生效
    @Bean
    @ConditionalOnProperty(name = "message.consumer.source", havingValue = "rabbitmq")
    public SimpleMessageListenerContainer rabbitMqOrderContainer(ConnectionFactory connectionFactory, CommonMessageHandler handler) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
        container.setQueueNames("order-queue");
        container.setMessageListener(message -> handler.process(message.getBody()));
        return container;
    }

    // Kafka消费者容器：仅当配置为kafka时生效
    @Bean
    @ConditionalOnProperty(name = "message.consumer.source", havingValue = "kafka")
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaOrderContainerFactory(ConsumerFactory<String, String> consumerFactory, CommonMessageHandler handler) {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory);
        factory.setRecordMessageListener(record -> handler.process(record.value().getBytes()));
        return factory;
    }

    // 统一的核心消息处理逻辑，供两种消费源调用
    @Bean
    public CommonMessageHandler commonMessageHandler() {
        return new CommonMessageHandler();
    }
}

补充：RabbitAdmin的角色 #

你提到的RabbitAdmin主要负责自动声明队列、交换器和绑定关系，和消费者容器配置互不冲突。可以提前用它初始化RabbitMQ的基础资源：

@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
    RabbitAdmin admin = new RabbitAdmin(connectionFactory);
    admin.declareQueue(new Queue("order-queue"));
    admin.declareQueue(new Queue("payment-queue"));
    admin.declareBinding(BindingBuilder.bind(new Queue("order-queue")).to(new TopicExchange("exchange.order")).with("order.#"));
    return admin;
}

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