rabbitmq - 如何停止回复以便 @SendTo 工作

问题描述

我在一个名为“MyService”的类中有与此类似的 Java 代码，用于接收消息、处理传递的对象并返回响应，目的是使用配置的交换和路由键返回响应，如使用 @SendTo 注释指定：

@RabbitListener(containerFactory = "myContainerFactory", queues = RabbitConfig.MY_QUEUE_NAME)
@SendTo("#{T(com.acme.config.RabbitOutboundConfig).OUTBOUND_EXCHANGE_NAME + '/' + myService.getRoutingKey()}")
public OrderResponse handlePaidOrder(Order order) {
    // do processing on the input Order object here...
    OrderResponse orderResponse = new OrderResponse();
    // fill up response object here
    return orderResponse;
}

public String getRoutingKey() {
    String routingKey;
    // .. custom logic to build a routing key
    return routingKey;
}

这是有道理的并且工作正常。我遇到的问题是我无法弄清楚如何阻止“reply_to”属性进入消息。我知道我的发件人是否通过调用 setReplyAddress 来配置 RabbitTemplate，这将在消息中产生一个 reply_to 属性和一个 correlation_id。

但是，如果我只是不调用 setReplyAddress，我仍然会得到一个 reply_to 属性，它看起来像这样：

reply_to: amq.rabbitmq.reply-to.g2dkAAxyYWJiaXRAd3NK 等等

并且在消息中使用该 reply_to 时，@SendTo 无效。Spring AMQP 文档和这篇文章： Dynamic SendTo annotation state：

@SendTo 仅在消息中没有回复时使用。

此外，当我不在 RabbitTemplate 上调用 setReplyAddress 时，我也没有得到相关 ID。我很确定我会需要那个。所以，我的问题是，如何让我的发件人生成相关 ID 但不生成回复，以便我的收件人可以使用 @SendTo 注释？

提前非常感谢。

标签： rabbitmqspring-amqpspring-rabbit

correlationId 是给发送者的；由于频道已保留，因此不需要直接回复；您可以MessagePostProcessor在发送端添加一个以添加一个correlationId。

@SendTo如果没有 reply_to 标头，这是一个后备。

如果您想更改该行为，您可以添加一个afterReceivePostProcessor到侦听器容器以删除replyTo.MessageProperties

container.setAfterReceivePostProcessor(m -> {
        m.getMessageProperties().setReplyTo(null);
        return m;
}

但是请记住，如果发件人设置了一个回复，他可能会期待回复，因此将回复发送到其他地方会让他失望，并且可能会导致一些延迟，直到回复超时。

如果你的意思是你想在其他地方发送一个初始回复，做更多的工作，然后最终回复给始发者，那么你应该将replyTo保存在另一个标题中，然后恢复它（或使用引用保存的表达式标题）。

rabbitmq - 如何停止回复以便 @SendTo 工作

问题描述

解决方案

推荐阅读