如何使用Spring Cloud Stream创建无消费者的RabbitMQ队列？

完全可以实现这种仅用于暂存消息至过期的无消费者队列配置，核心思路是只声明该队列的生产者绑定、配置消息过期与死信转发规则，同时不定义任何针对该队列的消费者绑定，以下是具体实现步骤（以RabbitMQ为例，Kafka可类比配置）：

1. 配置延迟暂存队列的生产者绑定 #

在application.yml中仅定义输出通道，不配置对应输入通道（消费者），确保队列被创建但无消费逻辑：

spring:
  cloud:
    stream:
      bindings:
        delayed-staging-output: # 自定义输出通道名
          destination: delayed-staging-queue # 首个暂存队列名称
          producer:
            required-groups: delayed-staging-group # 强制创建队列（避免无消费者时队列不生成）
      rabbit:
        bindings:
          delayed-staging-output:
            producer:
              declare-exchange: true
              declare-queue: true
              queue-name-group-only: false

2. 设置队列的过期与死信转发规则 #

给暂存队列配置消息TTL（过期时间），并指定死信交换机和路由键，让过期消息自动转至DLQ：

spring:
  cloud:
    stream:
      rabbit:
        bindings:
          delayed-staging-output:
            producer:
              queue-properties:
                x-message-ttl: 30000 # 消息过期时间，单位毫秒（示例为30秒）
                x-dead-letter-exchange: dlq-exchange # 死信交换机名称
                x-dead-letter-routing-key: dlq-queue-routing # 死信路由键，对应DLQ的绑定规则

3. 配置DLQ的消费者绑定 #

仅给DLQ配置输入通道，让应用从这里消费过期后的消息：

spring:
  cloud:
    stream:
      bindings:
        dlq-consume-input: # DLQ的输入通道名
          destination: dlq-exchange
          group: dlq-consumer-group
          consumer:
            auto-bind-dlq: false # 禁止给DLQ再绑定死信队列，避免循环
      rabbit:
        bindings:
          dlq-consume-input:
            consumer:
              declare-exchange: true
              declare-queue: true
              queue-name-group-only: false

4. 代码层面的对应实现 #

• 生产者：仅通过StreamBridge或对应输出通道的MessageChannel发送消息到delayed-staging-output通道，无需额外逻辑。
• 消费者：仅编写监听dlq-consume-input通道的消费方法，处理从DLQ过来的消息，完全不涉及delayed-staging-queue的消费逻辑。

额外说明 #

• 若使用Kafka作为中间件，原理一致：配置延迟主题的消息过期时间，利用Kafka原生DLQ机制（或自定义异常转发逻辑），同样只声明延迟主题的生产者，不声明消费者。
• 确保所使用的消息中间件支持消息TTL和死信队列特性（RabbitMQ、Kafka均支持）。
• 由于暂存队列无消费者绑定，消息会一直留存至过期，不会被主动消费，完全符合你的延迟暂存需求。

内容的提问来源于stack exchange，提问作者RaRa