配置Jackson2JsonMessageConverter的@RabbitListener无法转换映射对象

以下是针对性的排查和解决步骤：

1. 确认容器工厂的转换器配置生效 #

确保你的SimpleRabbitListenerContainerFactory Bean已经正确绑定了带ClassMapper的Jackson2JsonMessageConverter，示例配置如下：

@Bean
public SimpleRabbitListenerContainerFactory customRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    
    // 配置Jackson转换器及ClassMapper
    Jackson2JsonMessageConverter converter = new Jackson2JsonMessageConverter();
    DefaultClassMapper classMapper = new DefaultClassMapper();
    // 配置信任包，或直接映射__TypeId__与DTO的对应关系
    classMapper.setTrustedPackages("com.yourproject.dto");
    // 若生产者用短类名作为__TypeId__，可添加映射：classMapper.setIdClassMapping(Map.of("EmailVerificationDto", EmailVerificationDto.class));
    converter.setClassMapper(classMapper);
    
    factory.setMessageConverter(converter);
    return factory;
}

2. @RabbitListener显式指定容器工厂 #

如果你的自定义容器工厂不是默认Bean（即Bean名称不是rabbitListenerContainerFactory），必须在@RabbitListener注解中指定使用该工厂：

@RabbitListener(queues = "email-verification-queue", containerFactory = "customRabbitListenerContainerFactory")
public void handleEmailVerification(EmailVerificationDto dto) {
    // 直接处理DTO对象
}

@RabbitListener(queues = "webhook-verification-queue", containerFactory = "customRabbitListenerContainerFactory")
public void handleWebhookVerification(WebhookVerificationDto dto) {
    // 直接处理DTO对象
}

3. 修正监听方法的参数声明 #

不要将方法参数声明为org.springframework.amqp.core.Message，直接使用目标DTO类型作为参数——Spring AMQP会通过容器工厂绑定的转换器自动完成反序列化。

4. 校验消息头与转换器的匹配性 #

• 确认生产者发送的消息包含正确的__TypeId__头，且该值与消费者DTO的全类名一致（或通过ClassMapper完成了映射）
• 确保消息的content-type头为application/json（Jackson2JsonMessageConverter默认仅处理该类型的消息）

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