Spring Cloud Stream:所有绑定的默认死信队列

Spring Cloud Stream 是一个用于构建基于消息传递的微服务应用程序的框架

要为所有绑定的默认死信队列配置，请按照以下步骤操作：

在 application.yml 或 application.properties 文件中，添加以下配置：

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: your-input-topic
          group: your-input-group
          binder: your-binder
          consumer:
            max-attempts: 3
            back-off-initial-interval: 1000
            back-off-max-interval: 10000
            back-off-multiplier: 2.0
        output:
          destination: your-output-topic
          binder: your-binder
      binders:
        your-binder:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: localhost:9092
      default-retryable: true
      bindings:
        input:
          consumer:
            use-native-decoding: true
        output:
          producer:
            use-native-encoding: true

在这个例子中，我们配置了一个名为 your-input-topic 的输入主题和一个名为 your-output-topic 的输出主题。我们还配置了一个名为 your-binder 的绑定器，它使用 Kafka 作为消息中间件。

我们还为输入主题配置了一个消费者，设置了最大重试次数、退避初始间隔、退避最大间隔和退避乘数。这些设置将应用于所有绑定的默认死信队列。

创建一个名为 DLQBinding 的接口，用于定义死信队列的绑定：

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface DLQBinding {
    String INPUT = "dlqInput";
    String OUTPUT = "dlqOutput";

    @Input(INPUT)
    SubscribableChannel dlqInput();

    @Output(OUTPUT)
    MessageChannel dlqOutput();
}

在 application.yml 或 application.properties 文件中，添加以下配置以启用死信队列：

spring:
  cloud:
    stream:
      bindings:
        dlqInput:
          destination: your-dlq-topic
        dlqOutput:
          destination: your-dl齐topic

在这个例子中，我们配置了一个名为 your-dlq-topic 的死信队列主题。