没有合适的资源?快使用搜索试试~ 我知道了~
一份学习RocketMQ比较全,比较详细的资料
资源推荐
资源详情
资源评论
RocketMQ 基本理论及架构
1 MQ介绍
1.1 为什么要⽤MQ
1.1.1 异步解耦
1.1.2 削峰填⾕
1.1.3 其他
1.2 MQ的缺点
1.3 RocketMQ的前世今⽣
1.4 各种MQ产品的⽐较
2 快速⼊⻔
2.1 准备⼯作
2.2 安装RocketMQ
2.3 启动RocketMQ
2.4 测试RocketMQ
2.5 关闭RocketMQ
3 消息样例
3.1普通消息
3.1.1消息发送
3.1.2消费消息
3.2 顺序消息
3.3 ⼴播消息
3.4 延时消息
3.4.1 延时消息介绍
3.4.2 RocketMQ中的延迟消息
3.5 批量消息
3.6 过滤消息
3.6.1 TAG模式过滤
3.6.2 SQL表达式过滤
3.6.3 类过滤模式(基于4.2.0版本)
3.7 事务消息
3.7.1 概念介绍
3.7.2 交互流程
3.7.3 注意事项
3.7.4 事务消息原理
3.7.5 TransactionListener接⼝
3.7.6 示例
4 ⻆⾊介绍
4.1 NameServer
4.1.1 服务发现机制
4.1.2 为什么要使⽤NameServer
4.1.3 NameServer如何保证数据的最终⼀致?
4.1.4 客户端NameServer选择策略
4.1.5 特点
4.2 Broker
4.3 Producer
4.4 Consumer
4.5 Topic
4.6 Queue
4.7 Producer Group
4.8 Consumer Group
4.9 Message
4.10 Tag
4.11 Offset
4.12 ⽹络模型
5 集群搭建
5.1 集群搭建⽅式
5.2 双主双从集群搭建
5.2.1 总体架构
5.2.2 集群⼯作流程
5.2.3 2m-2s-sync集群搭建
6 管理⼯具
6.1 mqadmin管理⼯具
6.2 RocketMQ-Console
6.2.1 下载解压
6.2.2 修改部分参数并编译
6.2.3 运⾏编译后的jar包
6.2.4 打开浏览器验证
6.2.6 开启登录验证
7 ⾼级功能
7.1 消息存储
7.1.1 存储介质
7.1.2 性能对⽐
7.1.3 顺序存储
7.1.4 消息存储结构
7.1.4.1 ConsumeQueue
7.1.4.2 CommitLog
7.1.4.3 存储结构图
7.1.4.4 commitLog与offset
7.1.4.5 IndexFile
7.1.4.7 清理机制
7.1.5 ZeroCopy
7.1.6 刷盘机制
7.1.6.1 同步刷盘
7.1.6.2 异步刷盘
7.1.6.3 配置
7.2 ⾼可⽤机制
7.2.1 架构⾼可⽤
7.2.2 消息发送⾼可⽤
7.2.2 消息消费⾼可⽤
7.2.3 消息主从复制
7.2.3.1 同步复制
7.2.3.2 异步复制
7.2.3.3 配置
7.2.3.4 总结
7.3 消息投递机制
7.3.1 ⽣产者(Producer)投递消息的策略
1 默认投递⽅式:基于Queue队列轮询算法投递
2 默认投递⽅式的增强:基于Queue队列轮询算法和消息投递延迟最⼩的策略投递
3 顺序消息的投递⽅式
7.3.2 如何为消费者分配queue队列
7.3.2.1 ⼴播模式
7.3.2.2 集群模式
7.3.3 Consumer⽅式
7.4 消息重试
7.4.1 顺序消息的重试
7.4.2 ⽆序消息的重试
7.4.2.1 配置⽅式
1 消费失败后,重试配置⽅式
2 消费失败后,⽆需重试的配置⽅式
7.4.3 ⾃定义消息最⼤重试次数
7.5 死信队列
7.5.1 队列特征
7.5.2 查看死信消息
7.5.3 如何处理死信
7.6 消费幂等
7.6.1 什么是消息幂等
7.6.2 适⽤场景
7.6.3 实现消息幂等
7.6.4 RocketMQ如何处理消息幂等
7.6.5 消费端常⻅的幂等操作
7.7 消息堆积
7.7.1 消息堆积本质
7.7.2 如何处理消息堆积
7.7.2.1 发送端性能优化
7.7.2.2 消费端性能优化
7.7.3 如何快速处理
7.8 消息查询
7.8.1 消息查询介绍
7.8.2 消息查询⼯具
7.8.2.1 命令⾏⼯具
7.8.2.2 管理平台
7.8.2.3 客户端API
7.8.3 实现原理
7.8.4 Unique Key作⽤
7.8.5 批量发送模式下的Unique Key
7.8.6 Message Id
7.8.7 总结
7.9 Rebalance
7.9.1 介绍
7.9.2 触发场景
7.9.3 协调机制
7.9.3.1 队列信息变化
7.9.3.2 消费者组信息变化
1 ConsumerManager
2 ConsumerOffsetManager
3 SubscriptionGroupManager
8 源码分析
8.1 环境搭建
8.1.1 源码拉取
8.1.2 导⼊IDEA
8.1.3 调试
8.2 NameServer
8.2.1 启动流程
8.2.3 初始化及⼼跳机制
8.2.4 优雅停机
8.3 Broker
8.3.1 Broker作⽤
8.3.2 Broker启动流程分析
8.3.3 BrokerController创建
8.3.4 BrokerController启动
8.3.5 路由注册
8.3.6 路由删除
8.3.7 路由发现
8.4 Producer
8.4.1 消息⽣产者组件
8.4.2 RocketMQ 消息
8.4.3 ⽣产者启动流程
8.4.4 消息发送流程
8.4.4.1 同步发送
8.4.4.2 查找路由
8.4.4.3 选择消息队列
8.4.7 批量发送
8.5 消息存储
8.5.1 ⽂件存储路径
8.5.2 ⽂件介绍概览
8.5.4 CommitLog
8.5.4.1 存储的内容到底⻓什么样⼦
8.5.4.2 commitlog特点
8.5.4.3 刷盘策略 :FlushCommitLogService
8.5.5 ConsumeQueue
8.5.5.1 解析⽂件
8.5.5.2 消费消息
8.5.6 Index
8.5.6.1 index索引⽂件
8.5.6.2 构建索引
8.5.7 checkpoint⽂件
8.5.8 ⽂件清除机制
8.6 Consumer
8.6.1 消费者类图
8.6.2 消费者的启动
剩余182页未读,继续阅读
资源评论
Lewis·fk
- 粉丝: 18
- 资源: 14
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功