SpringCloud学习笔记(五)——消息驱动 Stream

消息驱动,顾明思议,在企业级应用中,消息中间件经常用于处理非同步场景、消息通知、应用解耦等。常用的有RabbitMq、kafka、Redis等消息队列等。Spring Cloud Stream是一个构建事件消息驱动的微服务框架,提供了一个灵活的编程模型。并基于Spring的基础之上,支持发布-订阅模型、消费者分组、数据分片等功能。
一、Stream 应用模型

SpringCloud学习笔记(五)——消息驱动 Stream

  • Middleware: 消息中间件,如RabbitMq等
  • Binder:可以认为是适配器,用来将Stream与中间连接起来的,不同的Binder对应不同的中间件,需要我们配置
  • Application Core:由Stream封装的消息机制,很少情况下自定义开发
  • inputs:输入,可以自定义开发
  • outputs:输出,可以自定义开发

接下来快速开始,主要就是针对以上几个组件进行不同的配置。

使用步骤

1、引入依赖

SpringCloud学习笔记(五)——消息驱动 Stream