springcloud17:stream消息驱动
admin
2024-02-13 01:11:01
0次
- 解决了什么?
MQ(消息中间件) ActiveMQ RabbitMQ Kafka RocketMQ
学习消息中间件负担重
一整个工程可能存在多个MQ,技术切换和维护开发都很困难 - 新技术诞生
不再关注具体MQ的细节,只需要直接适配绑定自动在各种MQ内替换
Stream 屏蔽底层插件,统一消息的编程模型 - springcloud stream(构建消息驱动微服务的框架)
binder:绑定器(通过binder来交互) - springcloud stream 涉及思想
binder的设计思想
发送消息Message,然后到消息通道MessageChnnel,最后订阅MessageHandler的来取消息
引入stream:定义绑定器实现了屏蔽应用程序和消息中间件的细节
Binder作为中间层:Output消费者 Input生产者(发布订阅模式) - stream常用流程套路和注解
流程套路:消息生产者-》channel队列(存储转发)-》Binder-》MQ组件-》Binder-》channel队列(存储转发)-》消息消费者
注解:@Input 接受者 @Output 发送者 @StreamListener 接受队列
案例说明:新建三个子模块和RabbitMQ
相关内容