如何在仅作为生产者的Spring Boot应用中通过Spring Cloud Stream定义RabbitMQ队列且无需监听器

当然可以做到！你遇到的Dispatcher has no subscribers for channel错误，根源在于你配置了@Input注解但没有为这个输入通道设置订阅者——而作为纯生产者的应用，其实根本不需要输入通道。结合你使用的Spring Cloud Stream 3.2.10版本，我给你整理了具体的解决方法：

一、移除不必要的输入通道配置 #

• 删掉代码中所有和@Input相关的定义，只保留用于发送消息的@Output接口。比如你的消息源接口可以写成这样：

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

public interface ProducerSource {
    String OUTPUT_CHANNEL = "myProducerOutput";

    @Output(OUTPUT_CHANNEL)
    MessageChannel output();
}

• 启动类上只需要绑定这个生产者源接口：@EnableBinding(ProducerSource.class)，不用管任何输入相关的绑定配置。

二、配置application.yml（仅保留生产者相关设置） #

完全去掉input绑定的配置，只配置output通道的属性，同时通过RabbitMQ专属配置来自动创建并绑定队列：

spring:
  cloud:
    stream:
      bindings:
        myProducerOutput:
          destination: myBusinessExchange # 自定义的交换器名称
          content-type: application/json
          # 如果需要分组的话可以加上group，不过纯生产者场景可选
          # group: myProducerGroup
      rabbit:
        bindings:
          myProducerOutput:
            producer:
              exchangeType: direct # 按需设置交换器类型，比如direct、topic、fanout
              bindQueue: true # 开启自动将队列绑定到交换器
              queueNameGroupOnly: false # 设为false才能自定义队列名
              queueName: myTargetQueue # 你要创建的队列名称
              routingKey: myRoutingKey # direct类型交换器需要指定路由键
              # 可选：如果需要死信队列的话可以配置
              # autoBindDlq: true

这里给你解释下几个核心配置的作用：

• bindQueue: true：让Spring Cloud Stream自动帮你完成队列和交换器的绑定操作
• queueName：直接指定你想要创建的队列名称，不用依赖自动生成
• 全程不用配置任何input相关的属性，彻底避免订阅者缺失的错误

三、验证效果 #

• 启动应用后，打开RabbitMQ管理面板，你会看到目标交换器和队列已经被创建，并且成功绑定
• 调用你的消息发送代码（通过@Output的MessageChannel发送），消息会正常路由到队列中
• 此时应用不会对这个队列做任何监听，完全满足你纯生产者的需求

额外注意点 #

如果你之前的代码里残留了@Input相关的配置或者通道定义，一定要彻底移除，否则Spring Cloud Stream还是会尝试初始化这些输入通道，进而触发订阅者缺失的错误。3.2.10版本的Spring Cloud Stream对这种纯生产者场景的支持是很完善的，按照上面的配置来就没问题。

备注：内容来源于stack exchange，提问作者Luis Manrique