spring-cloud-stream - Spring Cloud Stream 3.0存在生产者问题

Question

我阅读了有关Spring Cloud Stream 3.0的文档，了解了新使用java.util.function.[Supplier/Function/Consumer]来表示生产者、消费者和生产者、消费者，这应该是正确的。

但我不明白供应商。

文档指出，对供应商的轮询用于一致地为供应商生成数据，不需要程序参与。

但很多时候，我们需要在特定时间生成数据，例如网络请求，但我找不到任何相关文档或示例。

这可能就像注入(inject)供应商对象并调用 get() 方法一样简单，但如何禁用轮询调用？

感谢所有提供信息的人。

Answer 1

我们将更新 SR1 的文档，该文档将在几周后发布，但这里有完整的代码，演示如何完成您所描述的内容。我们依赖于 react 堆项目中的 EmitterProcessor:

@SpringBootApplication
@Controller
public class WebSourceApplication {

    public static void main(String[] args) {
        SpringApplication.run(WebSourceApplication.class);
    }

    EmitterProcessor<String> processor = EmitterProcessor.create();

    @RequestMapping
    @ResponseStatus(HttpStatus.ACCEPTED)
    public void delegateToSupplier(@RequestBody String body) {
        System.out.println("Sending " + body);
        processor.onNext(body);
    }

    @Bean
    public Supplier<Flux<String>> supplier() {
        return () -> processor;
    }
}

然后然后curl -H "Content-Type: text/plain"localhost:8080/-d Hello