Spring Boot中RabbitMQ队列数据转换问题求助

问题现象 #

构建微服务接收另一个微服务的RabbitMQ消息时，数据转换环节报错，无法将消息体转换为CasoLV实体类。

错误截图 #

现有代码 #

消息转换配置类 #

@Configuration
public class MensagemConfig {

    @Value("${crud.rabbitmq.exchange}")
    String exchange;

    @Bean
    public Exchange exchange() {
        return ExchangeBuilder.directExchange(exchange).durable(true).build();
    }

    @Bean
    public MessageConverter jsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }
} 

消费者类 #

@Component
public class CasoConsumer {
    
    private final CasoLVRepository repository;

    public CasoConsumer(CasoLVRepository repository) {
        this.repository = repository;
    }

    @RabbitListener(queues = "crud.statistics.caso")
    public void consumer(@Payload CasoLV caso){
        repository.save(caso);
    }
}

问题原因及解决方案 #

1. 转换器未绑定到监听容器工厂 #

你已定义Jackson2JsonMessageConverter的Bean，但Spring AMQP不会自动将其关联到RabbitListenerContainerFactory，导致消费者仍使用默认的SimpleMessageConverter，无法解析JSON格式消息。

解决方式：自定义监听容器工厂并绑定转换器：

@Configuration
public class MensagemConfig {

    @Value("${crud.rabbitmq.exchange}")
    String exchange;

    @Bean
    public Exchange exchange() {
        return ExchangeBuilder.directExchange(exchange).durable(true).build();
    }

    @Bean
    public MessageConverter jsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    // 新增容器工厂配置，绑定转换器
    @Bean
    public RabbitListenerContainerFactory<?> rabbitListenerContainerFactory(ConnectionFactory connectionFactory,
                                                                           MessageConverter jsonMessageConverter) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(jsonMessageConverter);
        return factory;
    }
}

2. 生产者消息格式不匹配 #

确保发送消息的生产者使用Jackson2JsonMessageConverter发送JSON格式消息，且消息的contentType设置为application/json。若生产者发送字符串或其他格式，消费者的JSON转换器无法解析。

3. 实体类序列化问题 #

检查CasoLV类是否符合Jackson序列化要求：

• 有无无参构造函数（Jackson默认依赖）
• 字段的getter/setter是否齐全
• 若消息体字段名与实体类字段名不一致，是否使用@JsonProperty注解修正映射

4. 显式指定转换器（备选方案） #

若不想修改容器工厂，可在@RabbitListener注解中直接指定转换器：

@RabbitListener(queues = "crud.statistics.caso", messageConverter = "jsonMessageConverter")
public void consumer(@Payload CasoLV caso){
    repository.save(caso);
}

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