培训对象: 面向后端开发工程师、架构师、中间件运维人员及技术负责人。也适合需要构建异步解耦、流量削峰、可靠消息系统的技术人员。
培训目标: 深入理解消息队列的核心模型与设计思想,掌握Kafka与RocketMQ的架构原理、关键特性和适用场景。具备独立进行技术选型、集群部署、生产消费开发及故障排查的能力。
培训内容介绍:
消息队列概述与技术选型:学习消息队列的核心价值(解耦、异步、削峰),对比RabbitMQ、Kafka、RocketMQ、Pulsar等主流MQ的架构差异与适用场景。
Kafka架构与核心概念:深入理解Kafka的Topic、Partition、Replica、Consumer Group等核心概念,掌握分区与副本机制对高吞吐的支撑作用。
Kafka生产者设计:学习生产者分区策略、消息发送确认机制(acks)、幂等发送与事务支持,掌握批量发送与压缩的优化技巧。
Kafka消费者设计:掌握消费者组与再平衡机制,学习消息拉取模型、位移提交方式(自动/手动)及消费进度管理。
Kafka高吞吐日志采集实战:通过模拟点赞/浏览量异步统计的案例,演练Kafka在日志采集场景下的应用,掌握高吞吐写入与消费的实现。
RocketMQ架构与核心概念:深入理解RocketMQ的NameServer、Broker、Producer、Consumer的协同机制,掌握Topic与Queue的设计思想。
RocketMQ消息类型与特性:学习普通消息、顺序消息、延时消息、事务消息的实现原理与适用场景,掌握消息过滤与标签的使用。
消息可靠性保障:学习消息确认机制(ACK/NACK/重试)、死信队列(DLX)的配置与应用,掌握消息不丢失的端到端保障方案。
延时消息与定时任务:通过定时关闭未支付订单的案例,学习RocketMQ延时消息与RabbitMQ死信队列实现延时任务的两种方案。
分布式事务消息:深入讲解RocketMQ事务消息的实现原理(半消息+回查机制),学习跨服务数据一致性的解决方案。
集群监控与运维管理:学习Kafka与RocketMQ的集群监控指标,掌握消息积压排查、集群扩容、数据迁移的运维技巧。
云原生消息队列演进:了解存算分离架构、分层存储、Serverless/Event架构等消息队列的最新演进方向,掌握消息中台的建设思路