课程目录

• 视频
• 001-课程简介
• 002-MQ简介
• 003-MQ用途
• 004-常见的MQ产品简介
• 005-MQ常见协议
• 006-RocketMQ发展历程
• 007-基本概念之消息与主题
• 008-基本概念之队列Queue
• 009-基本概念之消息标识
• 010-生产者与生产者组
• 011-消费者与消费者组
• 012-NameServer的整体功能介绍
• 013-NameServer的路由注册
• 014-NameServer的路由剔除
• 015-NameServer的路由发现
• 016-Client对NameServer的选择策略
• 017-Broker功能介绍
• 018-RocketMQ工作流程
• 019-Topic的创建模式
• 020-读写队列问题
• 021-克隆一台Linux系统
• 022-安装前的准备工作
• 023-修改bin中的两个文件配置
• 024-rocketMQ的启动
• 025-发送接收消息测试与关闭server
• 026-控制台的安装与启动
• 027-数据复制与刷盘策略
• 028-单Master与多Master集群模式
• 029-多Master多Slave集群模式
• 030-Broker集群模式最佳实践
• 031-RAID历史与等级简介
• 032-RAID关键技术与分类
• 033-JBOD与RAID0等级详解
• 034-RAID1与RAID0等级详解
• 035-RAID10与RAID01等级详解
• 036-集群搭建实践之rocketmqOS1的克隆与配置
• 037-集群搭建实践之rocketmqOS2的克隆与配置
• 038-集群搭建实践之启动集群
• 039-mqadmin命令
• 040-消息的生产过程
• 041-Queue选择算法
• 042-store目录简介
• 043-commitlog文件
• 044-commitlog文件的消息单元
• 045-consumequeue
• 046-对文件的读写
• 047-性能提升
• 048-与Kafka的对比
• 049-indexFile的结构
• 050-indexFile的创建
• 051-indexFile的查询流程
• 052-两种消息获取方式
• 053-两种消息消费模式
• 054-查看Broker中的消费进度
• 055-Rebalance的限制与危害
• 056-Rebalance产生的原因与过程
• 057-Queue分配算法
• 058-Queue分配算法对比
• 059-至少一次原则
• 060-订阅关系的一致性
• 061-offset的两种管理模式
• 062-offset远程管理模式
• 063-消费幂等及消息重复场景分析
• 064-幂等操作的通用解决方案
• 065-支付场景中的解决方案
• 066-消费幂等的实现
• 067-消息堆积与消费延迟及产生原因分析
• 068-消费耗时的深入分析
• 069-消费并发度的深入分析
• 070-单机线程数计算
• 071-如何避免消息堆积与消费延迟
• 072-消息的清理
• 073-消息发送的三种方式
• 074-同步消息发送代码举例
• 075-异步消息发送代码举例
• 076-单向消息发送代码举例
• 077-消费者消费代码举例
• 078-顺序消息的必要性分析
• 079-消息的有序性分类
• 080-顺序消息代码举例
• 081-什么是延迟消息
• 082-延迟等级划分与设置
• 083-延迟消息实现原理之修改消息
• 084-延迟消息实现原理之再次投递消息
• 085-延迟消费代码举例
• 086-转账场景中的事务消息解决方案
• 087-事务消息基础
• 088-XA模式三剑客
• 089-XA模式架构
• 090-事务消息代码举例
• 091-批量发送消息
• 092-批量消费消息
• 093-批量消息代码举例
• 094-消息过滤
• 095-消息过滤代码举例
• 096-开启SQL过滤功能
• 097-消息发送重试机制
• 098-消息发送重试的三种策略
• 099-顺序消息的消费重试机制
• 100-无序消息的消费重试机制
• 101-重试队列及其实现原理
• 102-消费重试配置方式
• 103-死信队列与死信消息
• 104-课程总结
• 笔记
• 代码