前言

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。虽然说,目前状况是Kafka更为火热,但更为广泛的应该还属老牌的RabbtiMQ和Alibaba自主研发的RocketMQ。

关于MQ相关的内容,Alibaba肯定还是很有话语权的,尤其是关于RocketMQ的使用,所以今天我们要分享的内容,实际上就是阿里P8的十年开发经验总结,写出来的这本“RabbitMQ+RocketMQ”技术手册,看完你也不得不感叹这份极品手册啊!

由于文章篇幅有限,下文中的内容只展示这份手册的目录以及部分内容截图

一、RabbitMQ部分

1.RabbitMQ简介及入门

2.客户端开发向导

连接RabbitMQ 使用交换器和队列 发送消息 消费消息 消费端的确认与拒绝 关闭连接

3.RabbitMQ进阶

消息何去何从 过期时间(TTL) 死信队列 延迟队列 优先级队列 RPC实现 持久化 生产者确认 消费端要点介绍 消息传输保障

4.RabbitMQ管理

多租户与权限 用户管理 Web端管理 应用与集群管理 服务端状态 HTTPAPI接口管理

5.RabbitMQ配置

环境变量 配置文件 参数及策略

6.RabbitMQ运维

集群搭建 查看服务日志 单节点故障恢复 集群迁移 集群监控

7.跨越集群的界限

Federation Shovel

8.RabbitMQ高阶

内存及磁盘告警 流控 镜像队列

9.网络分区

网络分区的意义 网络分区的判定 网络分区的模拟 网络分区的影响 手动处理网络分区 自动处理网络分区 案例:多分区情形

10.RabbitMQ扩展

消息追踪 负载均衡

二、RocketMQ部分

1.阅读源代码前的准备

获取和调试RocketMQ的源代码 RocketMQ源代码的目录结构 RocketMQ的设计理念和目标

2.RocketMQ路由中心NameServer

NameServer架构设计 NameSenver启动流程 NameSenve路由注册、故障剔除

3.RocketMQ消息发送

漫谈RocketMQ消息发送 认识RocketMQ消息 生产者启动流程 消息发送基本流程 批量消息发送

4.RocketMQ消息存储

存储概要设计 初识消息存储 消息发送存储流程 存储文件组织与内存映射 RocketMQ存储文件 实时更新消息消费队列与索引文 消息队列与索引文件恢复 文件刷盘机制 过期文件删除机制

5.RocketMQ消息消费

RocketMQ消息消费概述 消息消费者初探 消费者启动流程 消息拉取 消息队列负载与重新分布机制 消息消费过程 定时消息机制 消息过滤机制 顺序消息

6.消息过滤FilterServer

ClassFilten运行机制 FilterServer注册剖析 类过滤模式订阅机制 消息拉取

7.RocketMQ主从同步(HA)机制

RocketMQ主从复制原理 RocketMQ读写分离机制

8.RocketMQ事务消息

事务消息实现思想 事务消息发送流程 提交或回滚事务 事务消息回查事务状态

9.RocketMQ实战

消息批量发送 消息发送队列自选择 消息过滤 事务消息 Spring整合RocketMQ Spring Cloud整合RocketMQ RocketMQ监控与运维命令 应用场景分析

总结

实际上一般业务系统之间通信就是会采用RabbitMQ/RocketMQ,需要复杂的消息路由功能的支撑。大数据的实时计算场景才会采用Kafka,需要简单的消费模型,但是超高的吞吐量。

所以,作为Java开发,以RabbitMQ和RocketMQ为主来进行学习是比较重要的。最后,你再试问一下自己,对MQ到底掌握多少?会用到什么程度了呢?如果还不够,那就不能停下学习的脚步。

推荐阅读

评论可见,请评论后查看内容,谢谢!!!
 您阅读本篇文章共花了: