rocketmq 消息的序列化

RocketMQ 支持多种消息序列化方式，包括 JSON、Protobuf、Avro 等，可以根据实际需求选择适合的序列化方式。

在 Spring Boot 集成 RocketMQ 中，默认使用的是 `org.apache.rocketmq.spring.support.RocketMQMessageConverter` 类来将消息序列化成 byte 数组。该类默认使用的是 JDK 自带的序列化方式，可以通过实现 `org.apache.rocketmq.spring.support.RocketMQMessageConverter` 接口来自定义消息序列化方式。

下面是一个使用 Jackson 序列化方式的示例：

1. 添加 Jackson 的依赖

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.9.8</version>
</dependency>

2. 自定义消息转换器

public class JacksonMessageConverter implements RocketMQMessageConverter {
    private ObjectMapper objectMapper = new ObjectMapper();

    @Override
    public Message toMessage(Object payload, MessageHeaders headers) throws MessageConversionException {
        byte[] bytes;
        try {
            bytes = objectMapper.writeValueAsBytes(payload);
        } catch (JsonProcessingException e) {
            throw new MessageConversionException("Failed to convert message payload to JSON", e);
        }
        org.apache.rocketmq.common.message.Message rocketMsg = new org.apache.rocketmq.common.message.Message();
        rocketMsg.setBody(bytes);
        return rocketMsg;
    }

    @Override
    public Object fromMessage(Message message, Class<?> targetClass) throws MessageConversionException {
        byte[] bytes = message.getBody();
        Object payload;
        try {
            payload = objectMapper.readValue(bytes, targetClass);
        } catch (IOException e) {
            throw new MessageConversionException("Failed to convert message payload from JSON", e);
        }
        return payload;
    }
}

3. 在配置文件中配置使用 JacksonMessageConverter

spring.rocketmq.producer.message-converter=JacksonMessageConverter
spring.rocketmq.consumer.message-converter=JacksonMessageConverter

通过这种方式，就可以使用 Jackson 序列化方式来序列化 RocketMQ 消息了。