Spring Cloud Stream Supplier 功能模型

Posted

技术标签:

【中文标题】Spring Cloud Stream Supplier 功能模型【英文标题】:Spring Cloud Stream Supplier function model 【发布时间】:2020-10-23 00:16:32 【问题描述】:

我正在尝试使用 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函数来达到同样的效果?

【问题讨论】:

【参考方案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

【讨论】:

链接已过时。正确的是docs.spring.io/spring-cloud-stream/docs/current/reference/html/…

以上是关于Spring Cloud Stream Supplier 功能模型的主要内容,如果未能解决你的问题,请参考以下文章

spring cloud-stream 和 spring cloud-bus 有啥区别?

Spring Cloud(12)——基于Kafka的Stream实现

Spring Cloud 2020.0.0 中的 Spring Cloud Bus/Stream 问题

spring cloud 2.x版本 Spring Cloud Stream消息驱动组件基础教程(kafaka篇)

使用 spring-boot:1.5.1 和 spring-cloud-stream 时无法启动 bean 'inputBindingLifecycle'

spring-cloud-stream 整合 rabbitmq