RabbitMQ连接工厂无法自动注入及JSON消息转换异常问题

一、ConnectionFactory无法自动注入问题 #

原因分析 #

Spring Boot自动创建RabbitMQ的ConnectionFactory需满足以下前提，任一条件不满足都会导致自动注入失败：

• 未引入正确的Starter依赖：仅单独引入spring-rabbit不会触发自动配置，必须使用spring-boot-starter-amqp；
• 缺失RabbitMQ基础配置：即使默认连接localhost，依赖正确但无基础配置时，自动配置逻辑可能不生效；
• 禁用了RabbitMQ自动配置：@SpringBootApplication注解中添加了exclude = RabbitAutoConfiguration.class，导致自动配置失效。

解决步骤 #

1. 检查并修正依赖配置
   确保项目依赖中引入Spring Boot RabbitMQ Starter：

   <!-- Maven -->
   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-amqp</artifactId>
   </dependency>
   

   // Gradle
   implementation 'org.springframework.boot:spring-boot-starter-amqp'
   

2. 添加基础RabbitMQ配置
   在application.properties或application.yml中补充基础配置（即使使用默认值）：

   # application.properties
   spring.rabbitmq.host=localhost
   spring.rabbitmq.port=5672
   spring.rabbitmq.username=guest
   spring.rabbitmq.password=guest
   

3. 确认自动配置未被禁用
   检查@SpringBootApplication注解，确保未排除RabbitMQ自动配置类：

   @SpringBootApplication
   public class RedisToRabbitApplication {
       // ... 业务代码
   }
   

二、消费者接收消息为字节数组问题 #

原因分析 #

• 仅在生产者的RabbitTemplate中配置了Jackson2JsonMessageConverter，但消费者端默认使用SimpleMessageConverter，不会自动完成JSON转换；
• 消费者方法参数使用Message类型，其body属性本身就是字节数组，直接调用toString()会显示字节数组的内存引用。

解决步骤 #

方案1：配置消费者端消息转换器

创建RabbitListenerContainerFactory Bean，指定消息转换器为已定义的Jackson2JsonMessageConverter：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setMessageConverter(jsonConverter()); // 复用已有的Jackson转换器Bean
    return factory;
}

方案2：直接接收实体类参数

修改消费者方法，将参数替换为对应业务实体类（需确保实体类可被Jackson序列化/反序列化），Spring会自动使用上下文内的Jackson2JsonMessageConverter完成转换：

@RabbitListener(queues = RedisToRabbitApplication.QUEUE_NAME)
public void consumeMessage(final CasesEntity casesEntity) { // 替换为你的业务实体类
    log.info("received: " + casesEntity.toString());
}

方案3：手动转换（不推荐）

若暂时无法修改配置，可手动将字节数组转为JSON字符串再反序列化：

@RabbitListener(queues = RedisToRabbitApplication.QUEUE_NAME)
public void consumeMessage(final Message message) throws JsonProcessingException {
    String jsonStr = new String(message.getBody(), StandardCharsets.UTF_8);
    CasesEntity casesEntity = new ObjectMapper().readValue(jsonStr, CasesEntity.class);
    log.info("received: " + casesEntity.toString());
}

内容的提问来源于stack exchange，提问作者T.Huss