Spring Cloud Stream中Supplier函数发送间隔修改方案咨询

哦，我懂你的问题了——在Spring Cloud Stream的函数式编程模型里，你原来的写法行不通，因为@Scheduled不能直接标注在返回Supplier的@Bean方法上。框架默认只会调用这个Supplier一次，不会定时重复执行。下面给你两种靠谱的解决办法：

方案一：用Spring Cloud Stream内置的轮询配置（推荐） #

这是最符合函数式模型设计的方式，不需要额外的调度注解，直接通过配置文件控制发送间隔：

步骤1：修改配置文件 #

在application.properties（或者application.yml）里添加轮询间隔配置：

# 每3秒触发一次Supplier
spring.cloud.stream.poller.fixed-delay=3000

如果用YAML格式：

spring:
  cloud:
    stream:
      poller:
        fixed-delay: 3000

步骤2：简化你的Supplier Bean #

去掉@EnableScheduling和@Scheduled，只保留纯函数式的Supplier：

@Configuration
public class UsageDetailSender {
    private String[] users = {"user1", "user2", "user3", "user4", "user5"};
    
    @Bean
    public Supplier<UsageDetail> sendEvents() {
        return () -> {
            UsageDetail usageDetail = new UsageDetail();
            usageDetail.setUserId(this.users[new Random().nextInt(5)]);
            usageDetail.setDuration(new Random().nextInt(300));
            usageDetail.setData(new Random().nextInt(700));
            return usageDetail;
        };
    }
}

原理：Spring Cloud Stream会自动识别这个Supplier，并按照你配置的轮询间隔定时调用它，生成的消息会自动发送到默认的绑定目标。

方案二：手动结合TaskScheduler（灵活定制场景） #

如果需要更复杂的调度规则（比如cron表达式），可以手动用@Scheduled结合StreamBridge来发送消息：

代码实现 #

@Configuration
@EnableScheduling
public class UsageDetailSender {
    private String[] users = {"user1", "user2", "user3", "user4", "user5"};
    private final StreamBridge streamBridge;

    // 构造注入StreamBridge
    public UsageDetailSender(StreamBridge streamBridge) {
        this.streamBridge = streamBridge;
    }

    @Scheduled(fixedDelay = 3000)
    public void sendEvents() {
        UsageDetail usageDetail = new UsageDetail();
        usageDetail.setUserId(this.users[new Random().nextInt(5)]);
        usageDetail.setDuration(new Random().nextInt(300));
        usageDetail.setData(new Random().nextInt(700));
        // "output"是绑定名称，需要和配置里的目标对应
        streamBridge.send("output", usageDetail);
    }
}

配套配置 #

需要在配置文件里指定绑定的目标：

spring.cloud.stream.bindings.output.destination=your-target-topic-or-queue

这种方式完全由你控制发送逻辑，适合需要自定义调度规则或者额外处理的场景。

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