MQ消息处理

消息后置处理器

这个方法的目的是在消息发送之前对消息进行后处理，具体地，它向消息的属性中添加了一个名为 "user-info" 的头信息，这个头信息的值是通过 UserContext.getUser() 方法获取的当前用户信息。

public class RelyUserInfoMessageProcessor implements MessagePostProcessor {
    @Override
    public Message postProcessMessage(Message message) throws AmqpException {
        message.getMessageProperties().setHeader("user-info", UserContext.getUser());
        return message;
    }
}

MessagePostProcessor 接口：这个接口是Spring AMQP提供的，用于在消息发送之前对消息进行自定义处理。通过实现这个接口，您可以修改消息的头部、属性、负载等。

消息转换器

在处理发送对象的时候使用 JSON 格式来对信息进行序列化，首先引入依赖

    <dependency>
        <groupId>com.fasterxml.jackson.dataformat</groupId>
        <artifactId>jackson-dataformat-xml</artifactId>
    </dependency>