VIP20
本课程属于：007-消息队列任务读写分离蓝图 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

消息队列读写分离：任务调度与工作流引擎集成方法

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
消息队列基础概念
消息队列的定义 · 核心作用（解耦 · 异步
消息队列基础概念消息队列的定义
02
读写分离架构原理
读写分离的定义 · 为什么MQ需要读写分离 · 主从架构与读写分离的关系
读写分离架构原理读写分离的定义
03
生产者-消费者模型
生产者角色与职责 · 消费者角色与职责 · 消息确认机制
生产者消费者模型
04
消息队列核心组件
Broker · Topic · Partition
消息队列核心组件Broker
05
任务调度基础
任务调度的定义 · 常见调度策略（定时调度 · 事件驱动调度
任务调度基础任务调度的定义
06
工作流引擎基础
工作流引擎的定义 · BPMN标准 · 状态机模型
工作流引擎基础工作流引擎的定义
07
读写分离架构设计
Master节点与Slave节点的职… · 数据同步机制（同步复制 vs 异步复… · 故障转移策略
读写分离架构设计Master
08
消息队列高可用设计
集群部署模式 · Leader选举机制（如Raft · ZAB）
消息队列高可用设…集群部署模式
09
任务调度器与MQ集成
调度器如何将任务发布到MQ · 任务队列的设计 · 任务优先级与延迟队列
MQ任务调度器
10
工作流引擎与MQ集成
工作流节点触发消息 · 事件驱动的工作流推进 · 异步任务结果回调
MQ工作流引擎
11
消息路由与负载均衡
分区分配策略（Round Robin · Sticky） · 消费者负载均衡
消息路由负载均衡
12
消息顺序性保证
全局顺序与局部顺序 · 分区内顺序 · 顺序消息的实现方案（如Kafka单分…
消息顺序性保证全局顺序
13
消息可靠性投递
生产者确认机制（ACK） · 事务消息 · 消息重试与死信队列
消息可靠性投递ACK
14
消息消费可靠性
消费者手动提交Offset · 消费重试策略 · 幂等消费实现
消息消费可靠性Offset
15
任务调度状态管理
任务状态机（待执行 · 执行中 · 成功
任务调度状态管理任务状态机
16
工作流状态管理
工作流实例状态 · 节点状态 · 历史记录
工作流状态管理工作流实例状态
17
读写分离下的数据一致性
最终一致性模型 · CAP理论在MQ中的应用 · 分布式事务（TCC
读写分离下的数据…最终一致性模型
18
消息积压与流量控制
积压原因分析 · 背压机制 · 动态扩缩容
消息积压流量控制
19
任务调度与工作流引擎的协同
任务编排 · DAG工作流 · 条件分支与并行节点
任务调度工作流引擎的协同
20
集成架构实战案例一
基于RabbitMQ的任务调度系统设… · 代码片段）
集成架构实战案例…RabbitMQ
21
集成架构实战案例二
基于Kafka的工作流引擎集成（架构… · 代码片段）
集成架构实战案例…Kafka
22
集成架构实战案例三
基于RocketMQ的读写分离与任务… · 代码片段）
集成架构实战案例…RocketMQ
23
监控与告警
MQ集群监控指标（吞吐量 · 延迟 · 积压）
监控告警
24
日志与链路追踪
分布式日志收集 · TraceId传递 · OpenTelemetry集成
日志链路追踪
25
安全与权限控制
消息加密 · 身份认证 · 访问控制列表（ACL）
安全权限控制
26
性能优化
批量发送与消费 · 异步处理 · 零拷贝技术
性能优化批量发送
27
容灾与备份
跨机房复制 · 异地多活 · 数据备份与恢复
容灾备份
28
测试策略
单元测试 · 集成测试 · 压力测试
测试策略单元测试
29
常见问题与解决方案
消息丢失 · 重复消费 · 死锁
常见问题解决方案
30
未来趋势与总结
Serverless MQ · 云原生工作流 · AI驱动的调度优化
未来趋势Serverless