课程试听
正在播放
第一章 RocketMQ核心功能
1-1 RocketMQ核心功能(含课程配套资料)
  • RocketMQ专题大纲介绍
  • 本章知识概要
  • MQ作用介绍
  • MQ优缺点比较
  • 各大MQ产品比较
  • RocketMQ安装
  • 测试发送消息和接受消息
  • RocketMQ各角色介绍
  • RocketMQ集群特点
  • RocketMQ各种集群模式介绍
  • 双主双从(2m-2s)集群介绍和工作流程说明
  • 集群搭建1
  • 集群搭建2
  • 集群搭建3
  • 集群搭建小结
  • mqadmin命令介绍
  • rocketmq-console集群监控平台搭建
  • 消息发送样例介绍和步骤分析
  • 发送同步消息
  • 发送异步消息
  • 发送单向消息
  • 消息消费基本流程
  • 消费者广播模式和负载均衡模式
  • 顺序消息分析
  • 顺序消息发送者
  • 顺序消息消费者
  • 延迟消息
  • 批量消息发送
  • 过滤消息的两种方式
  • Tag过滤
  • SQL语法过滤
  • 事务消息的流程分析
  • 事务消息的实现
  • 总结
第二章 RocketMQ项目实战
2-1 RocketMQ项目实战
  • 本章内容介绍
  • 综合案例功能介绍
  • 下单问题分析及解决方式
  • 支付回调问题分析和解决方式
  • 项目技术介绍
  • springboot集成rocketmq生产者
  • springboot集成rocketmq消费者
  • dubbo概述
  • zookeeper集群搭建
  • dubbo服务接口开发
  • dubbo服务提供方
  • dubbo-admin管理平台搭建
  • dubbo服务消费方
  • 数据库表结构介绍
  • 项目工程初始化
  • mybatis逆向工程使用
  • 项目公共类介绍
  • 下单功能时序图分析
  • 下单接口定义和编码步骤分析
  • 校验订单流程分析
  • 校验订单实现
  • 生成预订单流程分析1
  • 生成预订单代码实现1
  • 生成预订单代码实现2
  • 生成预订单流程分析2
  • 扣减库存代码实现1
  • 扣减库存代码实现2
  • 更新优惠券
  • 更新余额1
  • 更新余额2
  • 下单基本流程小结
  • SpringBoot集成JUNIT测试下单基本流程
  • 下单异常问题演示
  • 发送确认订单失败消息
  • 发送确认订单失败消息演示
  • 消息消费方准备工作
  • 回退库存流程分析
  • 回退库存幂等性处理
  • 回退优惠券
  • 回退用户余额
  • 取消订单
  • 失败补偿机制测试
  • 创建支付订单流程
  • 创建支付订单实现
  • 支付回调处理流程分析
  • 支付回调代码实现
  • 线程池优化消息发送
  • 订单微服务处理支付成功消息
  • 支付业务服务端测试
  • web端项目开发
  • Rest测试准备工作
  • Rest方式测试下单
  • Rest方式测试支付下单和支付回调
  • 总结
第三章 RocketMQ高级功能和源码解析
3-1 RocketMQ高级功能和源码解析
  • 本章介绍
  • 消息存储方式介绍
  • RocketMQ消息存储和发送性能保证
  • RocketMQ消息存储结构
  • RocketMQ刷盘机制
  • RocketMQ高可用性
  • RocketMQ主从复制
  • 负载均衡-消息生产者
  • 负载均衡-消费消费者
  • 消息重试
  • 死信队列介绍
  • 消息幂等性处理
  • 源码结构介绍和导入
  • 源码环境调试
  • 回顾NameServer架构设计
  • NameServer启动步骤一
  • NameServer启动步骤二
  • NameServer启动步骤三
  • NameServer路由元数据
  • 路由注册之发送心跳包
  • 路由注册之处理请求包
  • 路由删除
  • 路由发现和小结
  • 生产者核心类介绍
  • 生产者启动流程
  • 消息发送1-消息校验
  • 消息发送2-消息路由查找
  • 消息发送3-选择队列
  • 消息发送4-发送消息
  • 消息发送4-总结
  • 批量消息发送
  • 消息存储核心类介绍
  • 消息存储流程
  • 消息存储文件介绍
  • 存储文件内存映射-MappedFileQueue
  • 存储文件内存映射-MappedFile
  • 存储文件内存映射-TransientStorePool
  • 实时更新消息消费队列与索引文件流程说明
  • 转发数据到ConsumerQueue文件
  • 转发IndexFile文件
  • 消息队列和索引文件恢复
  • 正常恢复和异常恢复
  • 同步刷盘分析
  • 异步刷盘说明
  • 删除过期文件机制分析
  • 消息存储总结
  • 消息消费概述1
  • 消息消费概述2
  • 消息消费启动流程
  • 消息拉取介绍
  • 客户端发起拉取消息请求
  • Broker组装消息
  • 消息拉取客户端处理服务端响应
  • 拉取消息的流程小结
  • 拉取消息长轮询机制
  • 消息达到后实时推送机制
  • 消息消费负载和重新分布机制
  • 消息并发处理
  • 定时消息处理机制
  • 顺序消息原理