修改消息内容等）

@FunctionalInterfacepublic interface MessagePostProcessor {    Message postProcessMessage(Message message) throws AmqpException;}

(3) UserContextMessageAdvice

• UserContextMessageAdvice 是一个拦截器（Advice），用于在消息处理前后执行自定义逻辑。

• 拦截器可以用于实现以下功能：

  • 在消息处理前，记录日志或设置上下文信息（例如用户身份信息）。

  • 拦截器可以用于实现以下功能：

    • 在消息处理前，记录日志或设置上下文信息（例如用户身份信息）。

      二、

    三、

  (2) MessageConverter

  • MessageConverter 用于将 RabbitMQ 的消息体（通常是字节数组）转换为 Java 对象，或者将 Java 对象转换为消息体。它的主要作用包括：

    • 配置消息监听器的连接工厂（ConnectionFactory）。

    ---

    2. 代码解析

    @Beanpublic SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(        ConnectionFactory connectionFactory,         MessageConverter messageConverter,         UserContextMessageAdvice userContextMessageAdvice) {    // 创建 SimpleRabbitListenerContainerFactory 实例    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();        // 设置连接工厂    factory.setConnectionFactory(connectionFactory);        // 设置消息转换器    factory.setMessageConverter(messageConverter);        // 设置拦截器链    factory.setAdviceChain(userContextMessageAdvice);        return factory;}

    (1) ConnectionFactory

    • ConnectionFactory 是 RabbitMQ 的连接工厂，用于创建与 RabbitMQ 服务器的连接。

    • 消息消费后的处理：在消息从 RabbitMQ 消费之后，对消息进行额外的处理（例如记录日志、

    • 在消息处理后，清理上下文或执行后续操作。

      ---

      1. MessagePostProcessor 的作用

      MessagePostProcessor 允许你在消息的生命周期中插入自定义逻辑，通常用于以下场景：

      • 消息发送前的处理：在消息发送到 RabbitMQ 之前，修改消息的属性（例如设置消息头、

      • 通过 factory.setAdviceChain(userContextMessageAdvice)，将拦截器添加到监听器容器的拦截器链中。

      • 返回值：返回处理后的消息对象。

      • 通过 factory.setMessageConverter(messageConverter)，为监听器容器设置消息转换器，使得监听器可以直接处理 Java 对象，而不需要手动解析消息体。

      ---

      2. 代码解析

      @Beanpublic SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(        ConnectionFactory connectionFactory,         MessageConverter messageConverter,         UserContextMessageAdvice userContextMessageAdvice) {    // 创建 SimpleRabbitListenerContainerFactory 实例    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();        // 设置连接工厂    factory.setConnectionFactory(connectionFactory);        // 设置消息转换器    factory.setMessageConverter(messageConverter);        // 设置拦截器链    factory.setAdviceChain(userContextMessageAdvice);        return factory;}

      (1) ConnectionFactory

      • ConnectionFactory 是 RabbitMQ 的连接工厂，用于创建与 RabbitMQ 服务器的连接。解决方案

        生产者

        首先在生产者服务中实现MessagePostProcessor接口，实现postProcessMessage方法，在该方法中向消息头部设置用户信息。

    四、

  • 添加拦截器链（AdviceChain），用于在消息处理前后执行自定义逻辑。

    并通过setBeforePublishPostProcessors为rabbitmq设置MessagePostProcessor

    @Configuration@Slf4j@RequiredArgsConstructorpublic class RabbitMQConfig {    public MessageConverter messageConverter() {        Jackson2JsonMessageConverter jackson2JsonMessageConverter = new Jackson2JsonMessageConverter();        jackson2JsonMessageConverter.setCreateMessageIds(true);        return jackson2JsonMessageConverter;    }    public MessagePostProcessor messagePostProcessor() {        return message -> {            User currentUser = UserContext.getUser();            String messageId = message.getMessageProperties().getMessageId();            if (currentUser != null) {                message.getMessageProperties().setHeader(MqConstants.USER_INFO, JSONUtil.toJsonStr(currentUser));            }            log.info("Message ID: {},User:{}", messageId, currentUser);            return message;};    }    @Bean    public RabbitTemplate rabbitTemplate(RabbitTemplateConfigurer configurer, ConnectionFactory connectionFactory) {        RabbitTemplate rabbitTemplate = new RabbitTemplate();        configurer.configure(rabbitTemplate, connectionFactory);        rabbitTemplate.setBeforePublishPostProcessors(messagePostProcessor());        rabbitTemplate.setMessageConverter(messageConverter());        return rabbitTemplate;    }}

    消费者

    实现MethodInterceptor接口，在方法内从消息头部获取用户信息，将其注入UserContext，通过SimpleRabbitListenerContainerFactory添加拦截器链，将我们自己的拦截器加入。优先级等）。

    一、前面我们的做法比较麻烦，至少要做两件事：

    • 消息发送者在消息体中传递登录用户

    • 消费者获取消息体中的登录用户，处理业务

    这样做不仅麻烦，而且编程体验也不统一。

  • 通过 factory.setConnectionFactory(connectionFactory)，将连接工厂注入到监听器容器中，确保监听器能够与 RabbitMQ 建立连接。修改消息内容等）。