微服务 SpringCloud Stream消息驱动
消息驱动概述
1.概念描述
屏蔽底层消息中间件的差异,降低切换版本,统一消息的编程模型。
2.官网介绍
官网地址:
https://spring.io/projects/spring-cloud-stream#overview
https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.1.RELEASE/reference/html/
Spring Cloud Stream中文指导手册:
https://m.wang1314.com/doc/webapp/topic/20971999.html
3.适用场景
也就是当你项目中同时存在RabbitMQ与kafka的时候,可以引入SpringCloud Stream可以实现屏蔽底层消息中间件的差异,降低切换版本,统一消息的编程模型。
4.设计思想
标准MQ
为什么用Cloud Stream
Binder
INPUT对应于消费者
OUTPUT对应于生产者
Stream中消息通信方式遵循发布-订阅模式
5.Spring Cloud Stream标准流程
Spring Cloud Stream三大核心组件
Binder:很方便的连接中间件,屏蔽差异
Channel:通道,是队列Queue的一种抽象,在消息通讯系统中就是实现存储和转发的媒介,通过对Channel对队列进行配置。
Source和Sink:简单的可理解为参照对象是Spring Cloud Stream自身,从Stream发布消息就是输出,接受消息就是输入。
6.编码API和常用注解
案例说明
环境准备
Eureka,,RabbitMQ环境已经OK
消息驱动之生产者
消息驱动之消费者
分组消费与持久化
原文地址:https://blog.csdn.net/m0_37583655/article/details/113730131
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。