如何窃听rabbitmq rpc响应消息

Question

MessageListenerContainer MessageListenerAdapter 实施为

void handleMessage(MyRpcRequest request, MessageProperties messageProperties) {
        var correlationData = new CorrelationData(messageProperties.getCorrelationId());
        MessagePostProcessor messagePostProcessor = (m) -> {
            m.getMessageProperties().setCorrelationId(correlationData.getId());
            if (messagePostProcessorFactory != null) {
                messagePostProcessorFactory.create(exchange, routingKey).postProcessMessage(m);
            }
            return m;
        };
        MyRpcResponse response = computeResponse(request);
    rabbitTemplate.convertAndSend("", messageProperties.getReplyTo(), response, messagePostProcessor, correlationData);
}

我直接发回默认交换 - 它工作正常 - 收到 rpc 响应（更简单的是只返回响应，而不是用兔子模板发回，但我故意手动发送）。但是这样我就不能窃听响应消息。我想做的是像下面这样的东西——发送到 RESPONSE_EXCHANGE_WHICH_IS_BOUND_TO_DEFAULT_EXCHANGE，这是扇出交换——我可以窃听它的消息，然后我希望它将消息转发到默认交换——我尝试绑定我的响应交换默认交换但它不起作用

void handleMessage(MyRpcRequest request, MessageProperties messageProperties) {
    ....
    rabbitTemplate.convertAndSend("RESPONSE_EXCHANGE_WHICH_IS_BOUND_TO_DEFAULT_EXCHANGE",
        messageProperties.getReplyTo(), response, messagePostProcessor, correlationData); 
    ....
}

    @Bean
    FanoutExchange defaultExchange() {
        return new FanoutExchange("");
    }

    @Bean
    FanoutExchange myRpcResponseExchange() {
        return new FanoutExchange("RESPONSE_EXCHANGE_WHICH_IS_BOUND_TO_DEFAULT_EXCHANGE");
    }

    @Bean
    Binding bindMyRpcResponseExchangeToDefaultExchange(FanoutExchange myRpcResponseExchange, FanoutExchange defaultExchange) {
        return BindingBuilder.bind(myRpcResponseExchange).to(defaultExchange);
    }

如何修复我的代码以便能够窃听响应消息？

如何窃听对发送为以下请求的响应消息：

rabbitTemplate.convertSendAndReceiveAsType(exchange, routingKey, message, messagePostProcessor, correlationData, responseType); ?

Answer 1

您不能手动绑定任何东西到默认交易所。

查看管理UI - 没有“绑定”选项。

也不能将默认交换绑定到另一个。

您需要发布到扇出并将回复队列绑定到它。

如何窃听rabbitmq rpc响应消息

How to wiretap rabbitmq rpc response message

rabbitmq

spring-rabbit

spring-amqp

spring-boot

rabbitmq-exchange