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'