如何在Spring Boot中读取RabbitMQ空Payload消息避免转换失败

针对RabbitMQ user.deleted事件的空Payload导致的消息转换异常，有以下几种实用解决方案：

方法1：直接用byte[]接收Payload #

将监听方法的Payload参数类型设为byte[]，空Payload会被自动转为长度为0的字节数组，不会触发转换异常。因为你只需要消息头信息，完全可以忽略这个空数组：

@RabbitListener(queues = "user-event-queue")
public void handleUserDeleted(byte[] payload, @Header Map<String, Object> headers) {
    // 从headers中提取用户删除相关的监控信息
    String deletedUserId = (String) headers.get("user-id");
    // 执行监控日志记录等业务逻辑
}

方法2：配置自定义消息转换器处理空Payload #

继承Spring AMQP的SimpleMessageConverter，重写fromMessage方法，专门处理空Payload的场景，返回null或自定义空对象：

@Component
public class EmptyAwareMessageConverter extends SimpleMessageConverter {
    @Override
    public Object fromMessage(Message message) throws MessageConversionException {
        byte[] body = message.getBody();
        if (body == null || body.length == 0) {
            // 空Payload时返回null，避免转换异常
            return null;
        }
        return super.fromMessage(message);
    }
}

然后在RabbitMQ配置类中，将这个转换器绑定到监听容器工厂：

@Configuration
public class RabbitConfig {
    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
            ConnectionFactory connectionFactory,
            EmptyAwareMessageConverter messageConverter) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(messageConverter);
        return factory;
    }
}

之后监听方法就可以正常接收空Payload的消息，此时Payload参数会被注入null：

@RabbitListener(queues = "user-event-queue")
public void handleUserDeleted(@Payload Object payload, @Header Map<String, Object> headers) {
    // payload为null，直接处理headers即可
}

方法3：设置@Payload(required = false) #

如果希望保持原有参数类型，只需在@Payload注解中设置required = false，这样空Payload会被注入null，不会抛出转换异常：

@RabbitListener(queues = "user-event-queue")
public void handleUserDeleted(@Payload(required = false) UserDeletedEvent payload, @Header Map<String, Object> headers) {
    // payload为null，直接处理headers中的监控信息
}

以上三种方法都能解决空Payload的转换问题，其中方法1最直接，适合你只需要消息头的场景；方法3则更简洁，无需额外配置。

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