0
点赞
收藏
分享

微信扫一扫

微服务:高并发带来的问题的容错方案

泠之屋 03-19 07:00 阅读 1

搭建RocketMQ
安装步骤 https://www.imooc.com/article/290089
前往http://rocketmg.apache.org/release notes/release-notes-4.51/,下载 Binary 文件即可。
在这里插入图片描述
搭建RocketMQ控制台
https://www.imooc.com/article/290092
在这里插入图片描述
访问RocketMQ首页
在这里插入图片描述
RocketMQ的术语和概念
在这里插入图片描述
RocketMQ开发者指南
https://git.imooc.com/coding-358/rocketmq-dev-guide
服务引入RocketMQ生产者
加依赖
在这里插入图片描述
写配置
在这里插入图片描述
写代码
注入 private final RocketMQTemplate rocketMQTemplate;
在这里插入图片描述
启动后,访问。再看RocketMQ控制台
在这里插入图片描述
在这里插入图片描述
生产者模型
在这里插入图片描述
服务引入RocketMQ消费者
配置同上,上代码
在这里插入图片描述
消费者模型
在这里插入图片描述
消息实现分布式事务(发送半消息,就是需要二次确认)
在这里插入图片描述
半消息和消息回查
在这里插入图片描述
分布式事务消息的三种状态(半消息不属于消息事务状态)
在这里插入图片描述
Spring Cloud Stream
用于构建消息驱动的微服务的框架
在这里插入图片描述
Spring Cloud Stream编程模型
在这里插入图片描述
微服务集成了Stream,Stream的Destination Binder创建了两个Binding,左边的Binding连接Rabbit MQ右边的Binding连接Kafka,左边的Binding从Rabbit MQ消费消息,然后通过中间这段代码处理,把处理结果输送到Kafka里面。
在这里插入图片描述
在这里插入图片描述
Spring Cloud Stream可以进行消息的生产、消费、监控、异常处理、分布式事务。
Spring Cloud Stream知识点盘点和总结,包括:
Stream注解
Spring Integration(Spring Cloud Stream的底层)注解
Spring Messaging(Spring消息编程模型)注解
Spring Cloud Stream APl

举报

相关推荐

0 条评论