Spring AMQP RabbitMQ：如何配置仅作为消息生产者的应用？

你遇到的问题根源很明确：当你定义了SimpleMessageListenerContainer这个Bean时，Spring会自动尝试注入它依赖的MessageListenerAdapter，但你让listenerAdapter()返回null，相当于没有提供该类型的有效Bean，容器启动时自然会抛出找不到Bean的异常。

要实现纯生产者应用，最核心的思路就是完全移除消费者相关的Bean定义——毕竟生产者只需要发送消息的能力，不需要监听队列的容器和适配器。下面给你两种实用的配置方案：

方案一：纯生产者极简配置 #

只保留生产者必需的核心Bean，去掉所有消费者相关的代码：

@Configuration
public class ProducerConfig {

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        // 可根据需求添加配置，比如JSON消息转换器
        // rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
        return rabbitTemplate;
    }

    // 可选：如果需要在生产者端声明队列（确保队列存在），可以添加这个Bean
    @Bean
    public Queue weatherRequestQueue() {
        return new Queue(WeatherRequestQueue.QUEUE_NAME, true); // 持久化队列
    }
}

之后在你的生产者服务里注入RabbitTemplate就能发消息了：

@Service
public class WeatherProducer {

    private final RabbitTemplate rabbitTemplate;

    // 构造方法注入（推荐）
    public WeatherProducer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    public void sendWeatherRequest(String requestContent) {
        rabbitTemplate.convertAndSend(WeatherRequestQueue.QUEUE_NAME, requestContent);
    }
}

方案二：通过条件注解灵活切换模式 #

如果你的代码需要在不同环境下切换生产者/消费者模式，可以用Spring的条件注解来控制Bean的加载：

@Configuration
public class RabbitMQConfig {

    // 生产者通用配置
    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }

    @Bean
    public Queue weatherRequestQueue() {
        return new Queue(WeatherRequestQueue.QUEUE_NAME, true);
    }

    // 仅当配置文件中关闭"纯生产者模式"时，才加载消费者Bean
    @ConditionalOnProperty(name = "spring.rabbitmq.producer-only", havingValue = "false", matchIfMissing = true)
    @Bean
    public SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setQueueNames(WeatherRequestQueue.QUEUE_NAME);
        container.setMessageListener(listenerAdapter);
        return container;
    }

    @ConditionalOnProperty(name = "spring.rabbitmq.producer-only", havingValue = "false", matchIfMissing = true)
    @Bean
    public MessageListenerAdapter listenerAdapter(WeatherQueryListener receiver) {
        // 指定消息处理的方法名，比如你的receiver里的handleMessage方法
        return new MessageListenerAdapter(receiver, "handleMessage");
    }
}

然后在生产者应用的application.properties里添加：

spring.rabbitmq.producer-only=true

这样Spring就会跳过消费者Bean的创建，启动后就是纯生产者模式。

补充说明：为什么你之前的方法行不通？ #

Spring的依赖注入机制要求@Bean方法必须返回有效的Bean实例（除非用条件注解跳过Bean创建）。返回null会被Spring判定为Bean创建失败，而container()方法又依赖这个失败的Bean，所以必然会抛出找不到Bean的异常。

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