当前位置: 首页 > news >正文

springcloud3 springcloud stream的学习以及案例(了解)

一 springcloud stream的作用

1.1 springcloud stream作用

stream屏蔽底层消息中间件的差异,降低切换成本,统一消息的编程模型。

stream中的消息通信模式遵循了“发布-订阅”模式。

1.2 Binder作用

通过定义绑定器Binder作为中间层,实现了应用程序与消息中间件细节之间的隔离

1.3 重复消费的解决

1.3.1 解决逻辑

微服务应用放置同一个group中,就能够保证消息被同一个消费者进行消费。不同的组是可以消费的,同一个组存在竞争关系,只有其中一个消费者可以消费。

 1.3.2 核心实现

1.4 常用api

 二  案例实现

2.1 流程图

2.2 rabbitmq的搭建

1.安装

2.查看

 2.3 provider8081的配置

1.service

 2.yml

 2.4 consumer8082的配置

1.service

 2.yml文件

  2.5 consumer8083的配置

1.service

 2.yml

   2.6 eureka的配置

    2.7 测试

2.7.1 8801访问

 1.8801 访问

 2.控制台

2.7.2 8802接收消费

3.8802 接收

 2.7.3 8803接收消费

5.rabbitmq查看

 

 

http://www.lryc.cn/news/119882.html

相关文章:

  • Kotlin理解内置函数
  • 手机app测试
  • Centos部署Git
  • k8s 控制器
  • 谷歌关闭跨域限制.(生成一个开发浏览器),Chrome关闭跨域
  • 实践指南-前端性能提升 270% | 京东云技术团队
  • 8月11日上课内容 nginx的多实例和动静分离
  • 腾讯云CVM服务器端口在安全组中打开!
  • k8s、docker添加daemon.json添加“exec-opts“: [“native.cgroupdriver=systemd“]后无法启动的问题
  • React组件性能优化实践
  • SpringBoot复习:(29)静态资源的配置路径
  • mysql延时问题排查
  • 接口设置了responseType:‘blob‘后,接收不到后端错误信息
  • 无涯教程-Perl - mkdir函数
  • css3 瀑布流布局遇见截断下一列展示后半截现象
  • C++初阶之一篇文章教会你list(理解和使用)
  • 如何给Linux开启swap虚拟内存
  • spring按条件注入@Condition及springboot对其的扩展
  • MySQL多表连接查询3
  • 【从零开始学习JAVA | 第四十五篇】反射
  • 顺丰科技数据治理实践
  • Nginx+Tomcat负载均衡、动静分离实例详细部署
  • Java多线程(3)---锁策略、CAS和JUC
  • Linux:Shell编辑之文本处理器(awk)
  • 探索FSM (有限状态机)应用
  • 6.continue break
  • 如何在Linux中强制关闭卡住的PyCharm
  • c# Excel数据的导出与导入
  • Kotlin~Mediator中介者模式
  • 石子合并问题