使用Spring cloud函数对rabbitmq进行Spring cloud流dlq处理

Question

我已经阅读了Spring Cloud stream binder参考文档，其中提到了使用@RabbitListener进行DLQ处理。https://docs.spring.io/spring-cloud-stream-binder-rabbit/docs/3.0.10.RELEASE/reference/html/spring-cloud-stream-binder-rabbit.html#rabbit-dlq-processing

我们可以通过Spring Cloud功能实现同样的功能吗？就像我们可以为消费者做同样的事情一样？喜欢

@Bean
    public Consumer<Message> dlqprocess(DLQProcess dlqprocess) {
        return t -> dlqprocess.do(t);
    }

我不确定我们是否能做到这一点。如果这允许，我们必须做的其他配置是什么？

Answer 1

如果您的目标是重新请求失败的消息，该函数可以按照文档中的描述抛出异常。

此外，如果您需要对发送和重新请求的消息进行更细粒度的控制，可以使用StreamBrdidge。在这里，您需要在配置文件中明确定义DLQ绑定：

spring.cloud.stream.bindings.myDlq-out-0.destination=DLX
spring.cloud.stream.rabbit.bindings.myDlq-out-0.producer.exchangeType=direct
spring.cloud.stream.rabbit.bindings.myDlq-out-0.producer.routingKeyExpression='myDestination.myGroup'
spring.cloud.stream.source=myDlq

最后，该函数控制是否发送和重新发送消息：

@Bean
public Consumer<Message> process(StreamBridge streamBridge) {
    return t -> {
        // ....
        if(republish) streamBridge.send("myDlq-out-0", t);
        if(sendToDestination) streamBridge.send("myDestination-out-0", t);
        // ....
    };
}