Spring Cloud Stream供应商功能模型

我正在尝试使用 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函数来达到相同的结果？

您可以使用新的StreamBridge用于执行此操作的 API。请参阅此处的文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.6.RELEASE/reference/html/spring-cloud-stream.html#_using_streambridge https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.6.RELEASE/reference/html/spring-cloud-stream.html#_using_streambridge