Spring Cloud Stream Supplier 功能模型

Question

我正在尝试使用 spring 云流和支持配置的新功能，但我无法理解如何实现与注释配置相同的结果。

每次创建用户时，我都需要向代理发送消息。使用基于注释的配置，我可以这样完成它：

 public UserProducer {
    
    @Autowired
    private final Source source;
    
    @Autowired
    private final UserRepository repository;

    public void saveUser(User user) {
        repository.save(user);
        source.output().send(MessageBuilder.withPayload(user).build());
    }
 }

是否可以使用 spring 云流函数来实现相同的结果？

Answer 1

您可以使用新的 StreamBridge API 来做到这一点。请参阅此处的文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.6.RELEASE/reference/html/spring-cloud-stream.html#_using_streambridge

Spring Cloud Stream Supplier 功能模型

Spring Cloud Stream Supplier function model

spring-boot

spring-cloud

spring-cloud-stream