码迷,mamicode.com
首页 > 编程语言 > 详细

【SpringCloud】Spring Cloud Stream 消息驱动(二十三)

时间:2020-05-07 00:25:01      阅读:104      评论:0      收藏:0      [点我收藏+]

标签:信道   输入   bit   需要   overview   png   info   发布-订阅   应用   

Spring Cloud Stream介绍

  Spring Cloud Stream,官方定义Spring Cloud Stream是一个构建消息驱动微服务的框架

  应用程序通过 inputs 或者 outputs 来与 Spring Cloud Stream 中的binder对象交互,通过配置binding(绑定),而 Spring Cloud Stream 的binder对象负载与消息中间件交互,所以,我们只需要高清楚如何与 Spring Cloud Stream 交互就可以方便使用消息驱动的方式,通过使用Spring Integration 来连接消息代理中间件以实现消息事件驱动。

  Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现,引用了发布-订阅、消费组、分区的三个核心概念

  目前仅支持RabbitMQ、Kafka

  官网:https://spring.io/projects/spring-cloud-stream

  中文手册:https://www.springcloud.cc/spring-cloud-greenwich.html#spring-cloud-stream-overview-introducing

Spring Cloud Stream处理架构

  技术图片  

组成说明
Middleware 中间件,目前只支持RabbitMQ和Kafka
Binder Binder是应用与消息中间件之间的封装,目前实行了Kafka和RabbitMQ的Binder,通过Binder可以很方便的连接中间件,可以动态的改变消息类型(对应于Kafka的topic,RabbitMQ的exchange),这些都可以通过配置文件来实现
@Input 注解标识输入通道,通过该输入通道接收到的消息进入应用程序
@Output 注解标识输出通道,发布的消息将通过该通道离开应用程序
@StreamListener 监听队列,用于消费者的队列的消息接收
@EnableBinding 指信道channel和exchange绑定在一起

 

【SpringCloud】Spring Cloud Stream 消息驱动(二十三)

标签:信道   输入   bit   需要   overview   png   info   发布-订阅   应用   

原文地址:https://www.cnblogs.com/h--d/p/12840086.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!