培训对象: 后端开发工程师、系统架构师、大数据工程师、需要处理异步消息的技术人员。
培训目标:
理解消息队列的核心概念和适用场景。
掌握RabbitMQ、Kafka、RocketMQ三大主流MQ的架构和使用。
能够根据业务需求选择合适的消息中间件。
具备消息队列的高可用部署和性能优化能力。
培训内容介绍:
二、 RabbitMQ架构与AMQP协议: 解析RabbitMQ的Exchange、Queue、Binding核心组件,深入AMQP 0-9-1协议模型。
三、 RabbitMQ实战与高级特性: 实现消息确认、持久化、死信队列、延迟队列,构建可靠的消息传递系统。
四、 Kafka架构与分布式存储: 深入Kafka的分区机制、副本机制、日志存储,理解其高吞吐量的设计原理。
五、 Kafka生产消费实战: 实现生产者分区策略、消费者组与重平衡,处理精确一次语义和流式处理。
六、 RocketMQ架构与特性: 解析RocketMQ的NameServer、Broker、Producer、Consumer架构,理解其事务消息和延迟消息机制。
七、 RocketMQ实战应用: 实现顺序消息、批量消息、过滤消息和分布式事务消息,适用于电商交易等场景。
八、 消息可靠性保障: 对比各MQ的消息持久化、确认机制、同步刷盘策略,确保消息不丢失不重复。
九、 消息顺序性与幂等消费: 解决全局顺序和局部顺序的需求,实现消费者幂等处理防止重复消费。
十、 集群部署与高可用架构: 部署RabbitMQ镜像队列集群、Kafka多副本集群、RocketMQ多Master多Slave集群。
十一、 性能压测与监控告警: 使用压测工具测试MQ吞吐量和延迟,集成Prometheus + Grafana监控队列积压和集群状态。
十二、 实战项目:构建异步消息系统: 在电商订单、日志收集、实时计算等场景中综合运用三大MQ,对比选型效果。