Spring Cloud Stream结合RabbitBinder多态事件类反序列化问题

解决方案 #

问题根因 #

默认Jackson反序列化时无法识别抽象类OrderEvent对应的具体实现子类，需要配置Jackson多态序列化/反序列化规则：

步骤1：给事件类添加Jackson多态注解 #

首先给抽象父类OrderEvent加注解，同时确保type()方法返回值能被序列化为JSON字段：

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonSubTypes;
import com.fasterxml.jackson.annotation.JsonTypeInfo;

@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", visible = true)
@JsonSubTypes({
        @JsonSubTypes.Type(value = OrderCreatedEvent.class, name = "ORDER_CREATED"),
        @JsonSubTypes.Type(value = OrderLineCreatedEvent.class, name = "ORDER_LINE_CREATED")
        // 其余所有OrderEvent子类都在此处注册
})
abstract class OrderEvent {
    @JsonProperty("type") // 确保方法返回值被序列化为JSON的type字段
    abstract String type();
}

子类可以选择添加@JsonTypeName注解和父类配置对应，也可以直接在父类的@JsonSubTypes中指定映射关系：

import com.fasterxml.jackson.annotation.JsonTypeName;

@JsonTypeName("ORDER_CREATED")
class OrderCreatedEvent extends OrderEvent {
  @Override
  String type() {
   return "ORDER_CREATED";
  }
  // 其他业务属性
}

步骤2：（可选）配置自定义消息转换器 #

如果添加注解后仍不生效，可手动注册支持多态的Jackson消息转换器到Spring Cloud Stream上下文：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;
import org.springframework.messaging.converter.MappingJackson2MessageConverter;
import org.springframework.messaging.converter.MessageConverter;

@Configuration
public class StreamConfig {
    @Bean
    public MessageConverter messageConverter(Jackson2ObjectMapperBuilder builder) {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setObjectMapper(builder.build());
        converter.setSerializedPayloadClass(String.class);
        return converter;
    }
}

验证配置 #

确保配置文件中内容类型配置正确：

spring:
  cloud:
    stream:
      default:
        content-type: application/json

配置完成后发布的事件JSON会自带type字段，消费时Jackson会根据type值自动反序列化为对应的子类实例，无需修改消费端Consumer<OrderEvent>的入参类型。

注意：所有事件子类需要提供无参构造函数，确保Jackson可以正常实例化对象。

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