Spring Cloud Stream RabbitMQ消费含日期类型消息报错排查

问题本质 #

你遇到的 ClassCastException: [B cannot be cast to StationExt 是因为消息没有被正确反序列化为StationExt对象，而是以字节数组形式传入消费者方法。当createdAt为null时能正常工作，是因为此时消息的格式或消息头被默认识别为JSON；而一旦包含具体日期值，要么是消息的Content-Type设置错误，要么是Jackson对日期类型的反序列化失败，导致Spring Cloud Stream fallback传递原始字节数组。

具体解决步骤 #

1. 修正RabbitMQ控制台发送消息的Content-Type #

通过RabbitMQ管理后台发消息时，默认Content-Type可能不是application/json（比如默认是text/plain），而Spring Cloud Stream只会对Content-Type为application/json的消息做JSON反序列化。

• 操作：发送消息时，在控制台的「Properties」区域，手动添加Content-Type属性，值设为application/json。

2. 强制Spring Cloud Stream使用JSON转换器 #

如果无法保证所有消息都带正确的Content-Type，直接在application.yml里配置强制启用JSON转换，忽略消息头的Content-Type：

spring:
  cloud:
    stream:
      bindings:
        # 替换成你的消费者绑定名称
        your-consumer-input:
          content-type: application/json
      rabbit:
        bindings:
          your-consumer-input:
            consumer:
              converter-class: org.springframework.messaging.converter.MappingJackson2MessageConverter

3. 确保Jackson正确处理JDK8日期类型 #

LocalDateTime/Instant这类JDK8日期类型需要jackson-datatype-jsr310模块支持，同时实体类上的注解要配置正确：

import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.time.LocalDateTime;

public class StationExt {
    // 根据你的日期格式调整pattern，比如"yyyy-MM-dd"或"yyyy-MM-dd HH:mm:ss"
    @JsonFormat(pattern = "yyyy-MM-dd")
    @JsonDeserialize(using = LocalDateTimeDeserializer.class)
    private LocalDateTime createdAt;

    // 省略getter/setter
}

同时确认pom.xml里有这个依赖：

<dependency>
    <groupId>com.fasterxml.jackson.datatype</groupId>
    <artifactId>jackson-datatype-jsr310</artifactId>
</dependency>

4. 检查消费者方法参数声明 #

确保消费者方法直接接收StationExt类型，不要用Message<StationExt>或其他包装类型，避免不必要的类型转换：

@StreamListener(target = YourBinding.INPUT)
public void processStation(StationExt stationExt) {
    // 业务逻辑
}

5. 排查反序列化异常细节 #

日期格式不匹配会触发Jackson反序列化失败，此时Spring Cloud Stream会传递原始字节数组，导致ClassCastException。可以加个全局异常处理器看具体错误：

@ControllerAdvice
public class StreamErrorHandler {
    @ExceptionHandler(MessageConversionException.class)
    public void handleConversionError(MessageConversionException e) {
        // 打印详细异常，定位具体是日期格式还是类型匹配问题
        e.printStackTrace();
    }
}

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