首页 技术 正文
技术 2022年11月15日
0 收藏 529 点赞 3,990 浏览 606 个字

分布式缓存(Redis)及消息队列(Kafka)

设想一种情况,服务A频繁的调用服务B的数据,但是服务B的数据更新的并不频繁。

Spring Cloud(7):事件驱动(Stream)分布式缓存(Redis)及消息队列(Kafka)

实际上,这种情况并不少见,大多数情况,用户的操作更多的是查询。如果我们缓存读操作,这样就可以节省服务间调用及访问数据库的成本,从而极大的缩短服务A的请求时间,从而改善性能。

Spring Cloud(7):事件驱动(Stream)分布式缓存(Redis)及消息队列(Kafka)

我们发现,如果数据更新,服务B必须及时调用服务A,让服务A删除该数据的缓存。或者直接与缓存服务器,删除该数据的缓存。但是,无论使用哪种方式,都会使服务A和服务B紧密耦合。如果我们使用异步方式,使用消息在服务之间传递,可以有效改善这种缺点。
服务B每次更新数据后,就发布一条消息到消息队列,而服务A从消息队列获取消息,并删除该数据的缓存。服务B不需要知道消息发给谁,服务A也不需要知道消息从哪来。

Spring Cloud(7):事件驱动(Stream)分布式缓存(Redis)及消息队列(Kafka)

接下来几节会使用Spring Cloud Stream搭建一个如图所示的框架。

事件驱动架构(String Cloud Stream)

String Cloud可以轻松地将消息集成到基于Spring的微服务中,它是通过String Cloud Stream来实现的。String Cloud Stream是一个由注解驱动的框架,它允许开发者在String微服务架构中轻松地构建消息发布者和消费者。

String Cloud Stream中有4个组件涉及发布和接收消息:

发射器(source)

通道(channel)

绑定器(binder)

接收器(sink)

Spring Cloud(7):事件驱动(Stream)分布式缓存(Redis)及消息队列(Kafka)

Spring Cloud(7):事件驱动(Stream)分布式缓存(Redis)及消息队列(Kafka)

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,497
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,910
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,744
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,498
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:8,137
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:5,301