Spring Cloud Stream 4.0.4：实现按需发送的通用函数式生产者

别用Supplier Bean了，它默认就是定期轮询自动发消息的，要按需发送直接用StreamBridge就行——这玩意儿是Spring Cloud Stream提供的通用发送器，完全不绑定Kafka或Rabbit这类具体中间件，完美符合你的需求。

具体实现步骤： #

1. 依赖配置

确保项目里引入Spring Cloud Stream核心依赖，以及你需要的中间件binder（比如Kafka或Rabbit的starter，代码里不用直接依赖它们的客户端）。以Maven为例：

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream</artifactId>
    </dependency>
    <!-- 按需添加对应的binder，比如Kafka -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-binder-kafka</artifactId>
    </dependency>
</dependencies>

2. 配置文件（application.yml）

定义输出绑定的目标（比如Kafka的topic或Rabbit的exchange），绑定名格式是{自定义前缀}-out-0：

spring:
  cloud:
    stream:
      bindings:
        demo-output-out-0:
          destination: demo-topic # 替换成你的目标topic/exchange
      # 如果用Kafka，添加binder基础配置（可选，默认本地9092）
      kafka:
        binder:
          brokers: localhost:9092

3. 核心业务代码

注入StreamBridge，写一个生产者服务类，按需调用send方法发送消息：

import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.stereotype.Service;

@Service
public class CustomEventProducer {

    private final StreamBridge streamBridge;

    public CustomEventProducer(StreamBridge streamBridge) {
        this.streamBridge = streamBridge;
    }

    // 通用发送方法，支持任意类型的消息体
    public <T> boolean sendEvent(String bindingName, T payload) {
        // bindingName就是配置里的demo-output-out-0
        return streamBridge.send(bindingName, payload);
    }
}

4. 调用示例（比如接口触发）

在Controller里注入生产者服务，通过接口按需触发发送：

import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class EventTriggerController {

    private final CustomEventProducer eventProducer;

    public EventTriggerController(CustomEventProducer eventProducer) {
        this.eventProducer = eventProducer;
    }

    @PostMapping("/send-event")
    public String triggerEvent(@RequestBody String message) {
        boolean isSuccess = eventProducer.sendEvent("demo-output-out-0", message);
        return isSuccess ? "消息发送成功" : "消息发送失败";
    }
}

关键说明： #

• StreamBridge是Spring Cloud Stream的原生组件，自动适配配置的binder，换中间件只需要改配置和依赖，代码完全不用动
• 不需要定义任何Supplier Bean，彻底避免自动定期发送的问题，完全由业务逻辑触发发送
• 绑定名的-out-0后缀是函数式风格的约定，对应输出通道的默认索引

内容的提问来源于stack exchange，提问作者Half Blood Prince