Spring整合RabbitMQ时@RabbitListener如何正确获取Payload实体对象

• 非静态内部类实例化失败：DTO中定义的Customer类是普通内部类，没有static修饰，Jackson反序列化时无法独立实例化该类（非静态内部类必须依附外部类实例存在），会直接导致customers字段为空，甚至抛出反序列化异常。
• 字段映射规则缺失：其余字段都通过@JsonProperty显式指定了JSON键名映射，唯独customers字段未配置，若生产者发送的JSON中对应键名不是小驼峰格式的customers（比如首字母大写的Customers），会直接匹配不到值。
• 手动创建ObjectMapper配置不全：每次调用方法时新建ObjectMapper实例，不会加载Spring环境中全局配置的序列化规则（比如Java 8时间类型支持、特殊类型转换器、序列化脱敏规则等），容易和生产者端的序列化配置不匹配，导致转换异常。
• 键名大小写匹配风险：DTO中配置的JSON键名存在大小写混用的情况（比如Entity/IdCuco首字母大写，processType为小驼峰），Jackson默认大小写敏感，只要生产者传输的键名大小写和注解配置有差异，就会出现字段丢失。

1. 修正DTO定义 #

将Customer内部类改为静态类，显式添加无参构造，同时给customers字段配置和生产者一致的键名映射：

@Data
@NoArgsConstructor
@AllArgsConstructor
@JsonIgnoreProperties(ignoreUnknown=true)
@JsonInclude(JsonInclude.Include.NON_NULL)
public class PeopleCoresConsumerDTO {

    @JsonProperty(value = "processType")
    @NotNull(message = "ProcessType is mandatory")
    private String processType;

    @JsonProperty(value = "operation")
    @NotNull(message = "Operation is mandatory")
    private String operation;

    @JsonProperty(value = "Entity")
    @NotNull(message = "Entity is mandatory")
    private String entity;

    @JsonProperty(value = "EntityType")
    @NotNull(message = "EntityType is mandatory")
    private String entityType;

    @JsonProperty(value = "IdCuco")
    @NotNull(message = "IdCuco is mandatory")
    private Long idCuco;

    @JsonProperty(value = "PersonF")
    private PersonF personF;

    @JsonProperty(value = "Address")
    private Address address;

    @JsonProperty(value = "Document")
    private Document document;

    @JsonProperty(value = "Ban")
    private Ban ban;

    @JsonProperty(value = "Dates")
    private PeopleDate date;

    // 加static修饰为静态内部类，添加无参构造供Jackson实例化
    @Getter
    @Setter
    @NoArgsConstructor
    public static class Customer {
        private String systemId;
        private String customerId;
    }

    // 这里的value要和生产者发送的JSON对应键名完全一致，示例为常见的首字母大写格式
    @JsonProperty(value = "Customers")
    private List<Customer> customers;

}

注意：所有嵌套引用的自定义类（PersonF/Address/Document/Ban/PeopleDate）都需要保证有无参构造，如果是内部类同样要加static修饰。

2. 替换手动转换逻辑（推荐） #

直接使用Spring AMQP提供的Jackson消息转换器，框架自动完成消息转DTO的逻辑，避免手动处理编码、配置不一致的问题。
首先配置消息转换器（如果项目中未配置）：

@Configuration
public class RabbitMqConfig {
    @Bean
    public Jackson2JsonMessageConverter jackson2JsonMessageConverter(ObjectMapper objectMapper) {
        // 复用Spring容器全局的ObjectMapper配置，和其他模块序列化规则保持一致
        return new Jackson2JsonMessageConverter(objectMapper);
    }
}

修改消费者代码，直接接收解析完成的DTO：

@Component
public class RabbitMQService {

    private final Logger logger = LoggerFactory.getLogger(RabbitMQService.class);

    @RabbitListener(queues = "${peopleevents.queue}")
    public void receivedMessage(@Payload PeopleCoresConsumerDTO consumerDTO) {
        logger.info("接收到解析完成的消息: {}", consumerDTO);
        // 直接使用consumerDTO做业务处理即可
    }
}

如果需要保留手动转换逻辑，不要自行创建ObjectMapper，直接注入容器中已配置好的实例：

@Component
public class RabbitMQService {

    private final Logger logger = LoggerFactory.getLogger(RabbitMQService.class);
    private final ObjectMapper objectMapper;

    // 构造注入全局ObjectMapper
    public RabbitMQService(ObjectMapper objectMapper) {
        this.objectMapper = objectMapper;
    }

    @RabbitListener(queues = "${peopleevents.queue}")
    public void receivedMessage(Message message) throws JsonProcessingException {
        String json = new String(message.getBody(), StandardCharsets.UTF_8);
        logger.info("接收到原始消息: {}", json);
        PeopleCoresConsumerDTO consumerDTO = objectMapper.readValue(json, PeopleCoresConsumerDTO.class);
        logger.info("消息解析完成: {}", consumerDTO);
    }
}

3. 异常排查 #

如果修改后仍有字段缺失，先打印收到的原始JSON字符串，逐字段核对键名和DTO中@JsonProperty配置的value是否完全一致，重点检查大小写、命名格式（驼峰/下划线）的差异。

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