Spring AMQP接收RabbitMQ消息时如何将消息体转为自定义类型？

首先需要明确项目A中JMS模板序列化消息的方式（因为无法修改项目A，必须对齐它的序列化逻辑），常见有两种场景，对应不同的处理方式：

场景1：项目A使用默认Java序列化（Spring JMS默认行为） #

Spring JMS的SimpleMessageConverter默认会对实现Serializable接口的自定义对象进行Java序列化，消息体是序列化后的字节数组。

处理步骤： #

1. 确保项目B能访问到项目A的自定义类型：
   • 引入包含该自定义类的Jar包，或者在项目B中复制完全相同的类定义（包名、类名、字段、serialVersionUID必须和项目A完全一致，否则反序列化会失败）。
2. 反序列化字节数组为自定义对象：
   可以手动处理，也可以借助Spring AMQP的消息转换器自动处理。

手动反序列化示例：

@RabbitListener(queues = "theQueueName")
public void listen(org.springframework.amqp.core.Message incomingMessage) {
    try (ByteArrayInputStream bis = new ByteArrayInputStream(incomingMessage.getBody());
         ObjectInputStream ois = new ObjectInputStream(bis)) {
        // 替换为项目A的自定义类型
        YourCustomType customObject = (YourCustomType) ois.readObject();
        // 处理自定义对象逻辑
        System.out.println("Received custom object: " + customObject);
    } catch (IOException | ClassNotFoundException e) {
        // 处理反序列化异常，比如日志记录、消息重试等
        e.printStackTrace();
    }
}

用Spring AMQP转换器自动处理：

配置SimpleMessageConverter作为消息转换器，方法参数可以直接接收自定义类型：

@Configuration
public class RabbitConfig {
    @Bean
    public MessageConverter messageConverter() {
        return new SimpleMessageConverter();
    }
}

@RabbitListener(queues = "theQueueName")
public void listen(YourCustomType customObject) {
    // 直接处理自定义对象
    System.out.println("Received custom object: " + customObject);
}

场景2：项目A使用JSON序列化（如配置了MappingJackson2MessageConverter） #

如果项目A配置了JMS的JSON转换器，消息体是自定义对象的JSON字节数组。

处理步骤： #

1. 确保项目B的自定义类型和项目A的字段结构完全一致（包名、类名、字段名、类型匹配，无需实现Serializable）。
2. 使用Jackson的ObjectMapper反序列化，或者配置Spring AMQP的JSON转换器自动处理。

手动反序列化示例：

import com.fasterxml.jackson.databind.ObjectMapper;

@Component
public class MessageListener {
    private final ObjectMapper objectMapper = new ObjectMapper();

    @RabbitListener(queues = "theQueueName")
    public void listen(org.springframework.amqp.core.Message incomingMessage) {
        try {
            YourCustomType customObject = objectMapper.readValue(incomingMessage.getBody(), YourCustomType.class);
            // 处理自定义对象逻辑
            System.out.println("Received custom object: " + customObject);
        } catch (IOException e) {
            // 处理反序列化异常
            e.printStackTrace();
        }
    }
}

用Spring AMQP转换器自动处理：

配置Jackson2JsonMessageConverter，方法参数直接接收自定义类型：

@Configuration
public class RabbitConfig {
    @Bean
    public MessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}

@RabbitListener(queues = "theQueueName")
public void listen(YourCustomType customObject) {
    // 直接处理自定义对象
    System.out.println("Received custom object: " + customObject);
}

关键注意事项： #

• 无论哪种场景，项目B中的自定义类型必须和项目A的完全匹配：Java序列化场景要保证serialVersionUID一致；JSON场景要保证字段名、类型、嵌套结构完全一致。
• 如果项目A使用了自定义序列化规则（比如自定义的Jackson模块、特殊的日期格式化等），项目B必须复制完全相同的序列化配置，否则会反序列化失败。

内容的提问来源于stack exchange，提问作者İlkay Gunel