如何在Java中使用Spring Cloud实现Azure Service Bus的序列化与反序列化

内置反序列化支持 #

Spring Cloud Azure 4.5.0版本的spring-cloud-azure-starter-integration-servicebus提供了内置的消息反序列化能力，无需从头手动实现核心转换逻辑。它基于Spring的Message Converter机制工作，默认支持Jackson JSON序列化，可直接将消息体转换为自定义ExampleMessage对象。

快速配置步骤 #

1. 依赖确认：当前使用的starter已内置Jackson相关组件，无需额外引入依赖。
2. 配置Jackson消息转换器
   在配置类中注册MappingJackson2MessageConverter，可自定义序列化规则（如字段校验、日期格式）：

   @Configuration
   public class ServiceBusConfig {
       @Bean
       public MappingJackson2MessageConverter jacksonMessageConverter() {
           MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
           ObjectMapper objectMapper = new ObjectMapper()
                   // 开启未知字段校验，避免非法数据流入
                   .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, true)
                   .registerModule(new JavaTimeModule()); // 支持Java 8日期类型
           converter.setObjectMapper(objectMapper);
           return converter;
       }
   
       @Bean
       public MessageChannel inputChannel() {
           return new DirectChannel();
       }
   
       @Bean
       public ServiceBusInboundChannelAdapter serviceBusInboundAdapter(
               ServiceBusContainerFactory containerFactory,
               MessageChannel inputChannel) {
           ServiceBusInboundChannelAdapter adapter = new ServiceBusInboundChannelAdapter(containerFactory, "your-queue-name");
           adapter.setOutputChannel(inputChannel);
           adapter.setMessageConverter(jacksonMessageConverter()); // 绑定转换器
           return adapter;
       }
   }
   

3. 消费端直接接收对象
   在消息处理方法中直接指定参数类型为ExampleMessage，Spring会自动完成反序列化：

   @ServiceActivator(inputChannel = "inputChannel")
   public void processMessage(ExampleMessage message) {
       // 直接处理ExampleMessage实例
       System.out.println("Received message ID: " + message.getId());
   }
   

校验逻辑实现 #

如果需要类似DataTypeProvider的类型校验和数据合法性验证，可通过两种方式实现：

• JSR-380注解校验：在ExampleMessage类上添加校验注解，消费方法中用@Valid触发校验：

  public class ExampleMessage {
      @NotNull(message = "消息ID不能为空")
      private String id;
  
      @Size(min = 5, max = 200, message = "内容长度需在5-200之间")
      private String content;
  
      // getter、setter方法
  }
  
  @ServiceActivator(inputChannel = "inputChannel")
  public void processMessage(@Valid ExampleMessage message) {
      // 校验通过后执行业务逻辑，不通过会抛出MethodArgumentNotValidException
  }
  

• 自定义MessageConverter：若内置转换器无法满足特殊格式（如XML、二进制协议）或复杂校验需求，可实现MessageConverter接口，在fromMessage方法中自行处理反序列化和校验逻辑，替换配置中的Jackson转换器即可。

总结 #

• Spring Cloud Azure 提供开箱即用的Jackson反序列化能力，无需手动实现基础转换；
• 通过配置MappingJackson2MessageConverter可快速完成JSON到自定义对象的映射；
• 校验逻辑可结合注解或自定义转换器实现，灵活适配业务需求。

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