消息队列在Python后端中的应用 · 课程目录

消息队列概述

什么是消息队列、为什么需要、核心概念：生产者、消费者、队列、主题

RabbitMQ 入门

RabbitMQ简介、Exchange/Queue/Binding、安装启动、pika基础使用

RabbitMQ 工作模式（一）

简单队列、Work Queues、消息确认机制

RabbitMQ 工作模式（二）

发布/订阅、Routing、Topics 模式

RabbitMQ 高级特性

消息持久化、公平分发、RPC、死信队列、延迟队列

Redis 作为消息队列

List实现MQ、Pub/Sub、Stream数据类型详解

核心概念(Topic/Partition/Consumer Group)、安装配置、kafka-python基础

Kafka 生产者详解

分区策略、acks确认、重试机制、批量发送与压缩

Kafka 消费者详解

消费者组与再均衡、偏移量提交、幂等性与事务

Kafka 高级特性

日志压缩、时间戳索引、Kafka Connect & Streams

消息队列对比与选型

RabbitMQ vs Kafka vs Redis vs Pulsar，场景选型

Celery简介、Task/Broker/Backend、安装配置、第一个任务

Celery 任务管理

任务绑定、重试、过期、状态跟踪、结果存储

Celery 高级用法

任务路由、Canvas工作流、定时Beat、Flower监控

Celery 最佳实践

任务拆分、连接池、序列化、错误处理与日志

消息队列与微服务

微服务中的角色、异步通信、事件驱动架构

消息队列与分布式事务

最终一致性、本地消息表、事务消息、Saga模式

消息队列与异步任务

异步处理模式、任务队列设计、优先级与限流

消息队列与日志收集

ELK Stack + 消息队列、Kafka日志管道、采集最佳实践

消息队列与实时流处理

流处理概念、Kafka Streams/Flink、实时计算场景

消息队列与事件溯源

事件溯源模式、事件存储、CQRS结合

消息队列安全

SASL/SSL认证、加密传输、ACL、安全最佳实践

消息队列监控与运维

监控指标、Prometheus+Grafana、告警策略

消息队列性能调优

生产者/消费者优化、Broker参数、网络磁盘优化

消息队列高可用设计

集群部署(主从/镜像/分区)、故障转移、数据复制

消息队列常见问题与排查

消息丢失/重复/堆积、顺序消费、死信处理

实战项目一：异步邮件发送系统

基于RabbitMQ · 架构设计、代码实现、测试

实战项目二：实时日志分析系统

基于Kafka · 架构设计、代码实现、测试

实战项目三：分布式爬虫调度系统

基于Celery · 架构设计、代码实现、测试

课程总结与展望

技术总结、云原生/Serverless趋势、学习路径建议