spring-boot - Spring Cloud Stream Supplier 功能模型

Question

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

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

 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 cloud stream 函数来实现相同的结果？

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