该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 spring-cloud-stream 5.0.0!spring-doc.cadn.net.cn

持续的发布-订阅支持

应用程序之间的通信采用发布-订阅模式,数据通过共享主题广播。 这可以在下图中看到,展示了一组互动的 Spring Cloud Stream 应用的典型部署。spring-doc.cadn.net.cn

SCSt传感器
图1。春云流 发布-订阅

传感器向HTTP端点报告的数据会发送到一个名为RAW-传感器-数据. 从目的地,数据由微服务应用程序独立处理,计算时间窗口平均值,另一个微服务应用将原始数据导入HDFS(Hadoop分布式文件系统)。 为了处理数据,两个应用程序在运行时都声明该主题作为输入。spring-doc.cadn.net.cn

发布-订阅通信模型降低了生产者和消费者的复杂性,并允许在不中断现有流程的情况下向拓扑添加新应用。 例如,在平均计算应用的下游,你可以添加一个计算显示和监控最高温度值的应用程序。 然后你可以添加另一个应用,解释相同的平均值流进行故障检测。 通过共享主题而非点对点队列完成所有通信,减少了微服务之间的耦合。spring-doc.cadn.net.cn

虽然发布-订阅消息的概念并不新鲜,但 Spring Cloud Stream 更进一步,将其作为应用模型中一个明确的选择。 通过采用原生中间件支持,Spring Cloud Stream 也简化了发布-订阅模式在不同平台上的使用。spring-doc.cadn.net.cn