Spring Boot应用能否同时作为RabbitMQ生产者与消费者？

可行性说明 #

完全可行，这是RabbitMQ消息架构中非常常见的业务场景——比如消息中转、数据格式转换、业务拆分等需求，都需要一个应用同时承担消费者（接收上游消息）和生产者（发送下游消息）的角色，你的场景完全符合这个模式。

解决RabbitTemplate为null的问题 #

你已经能正常消费queue1的消息，说明Spring Boot的RabbitMQ自动配置已经生效，出现rabbitTemplate为null的问题，大概率是依赖注入环节出了问题，常见原因和修复方案如下：

1. 消费者类未被Spring容器管理 #

如果你的消费者类没有添加@Component、@Service等Spring组件注解，Spring不会为其创建实例，也不会自动注入RabbitTemplate。

修复：给消费者类添加@Component注解，确保Spring能扫描到并管理该类的实例。

2. 错误的注入方式 #

• 不要手动new消费者类实例：如果在代码中通过new Queue1Consumer()创建实例，Spring不会为这个手动实例注入RabbitTemplate，必须使用Spring容器提供的实例。
• 推荐使用构造方法注入（而非字段注入）：构造方法注入是Spring官方推荐的方式，能避免空指针问题，同时保证依赖的不可变性。

正确的代码示例：

@Component
public class Queue1Consumer {

    private final RabbitTemplate rabbitTemplate;

    // 构造方法注入RabbitTemplate
    public Queue1Consumer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    @RabbitListener(queues = "queue1")
    public void processMessage(String originalMsg) {
        // 数据转换逻辑
        List<String> targetMessages = transformData(originalMsg);
        
        // 批量发送到queue2
        for (String msg : targetMessages) {
            // 注意替换为你的实际交换机和路由键（如果需要）
            rabbitTemplate.convertAndSend("your-exchange", "queue2-routing-key", msg);
        }
    }

    private List<String> transformData(String originalMsg) {
        // 这里实现你的数据转换逻辑
        return Arrays.asList(originalMsg.split(";"));
    }
}

3. 检查自动配置是否被禁用 #

检查application.properties中是否存在以下配置：

spring.rabbitmq.autoconfigure.enabled=false

如果有，需要删除该配置，否则Spring Boot不会自动创建RabbitTemplate实例；如果确实需要手动配置，要自行定义RabbitTemplate的Bean。

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