给RabbitMQ发送消息时，设置请求头Header。

2024-10-14 04:15:55

消费者的请求头

生产者设置请求头

由于消费者那里，@Payload是接受的消息体，使用了@Header注解，需要请求头，生产者这边就要设置请求头，然后rabbitTemplate再调用convertAndSend方法发送，如下代码：

这是RabbitTemplate中的converAndSend（exchang,routingKey,消息体,消息头）方法。

@Override

    public void convertAndSend(String exchange, String routingKey, final Object message,

            final MessagePostProcessor messagePostProcessor) throws AmqpException {

        convertAndSend(exchange, routingKey, message, messagePostProcessor, null);

    }

最新文章

热门文章