VIP20
本课程属于：009-供应链数据集成 供应链数字化与智能采购系统 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

事件总线架构：MQ实现WMS库存变更与ERP采购订单的联动

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
WMS与ERP系统概述 · 库存变更与采购订单联动的业务痛点 · 事件驱动架构的优势
课程导论WMS
02
核心概念
事件总线（Event Bus）定义 · 发布/订阅模式 · 消息队列（MQ）的角色与选型（Rab…
核心概念Event
03
业务场景分析
WMS库存变更触发ERP采购订单的典… · 自动补货 · 退货入库）
业务场景分析WMS
04
消息模型设计
Topic与Queue的选择策略 · 消息分区（Partition）与消费…
消息模型设计Topic
05
消息体（Payload）规范
库存变更事件的JSON Schema… · 字段定义（SKU · 仓库
Payload消息体
06
消息可靠性保证
生产者确认（Publisher Co… · 消费者ACK机制 · 消息持久化配置
消息可靠性保证Publisher
07
消息幂等性设计
WMS侧去重机制 · ERP侧幂等消费（唯一键 · 状态机）
消息幂等性设计WMS
08
消息顺序性
局部顺序保证（分区键设计） · 全局顺序的代价与替代方案
消息顺序性局部顺序保证
09
死信队列（DLQ）与重试机制
重试策略（指数退避） · 死信消息处理与人工介入流程
DLQ死信队列
10
WMS端实现（生产者）
库存变更事件捕获（数据库CDC/业务… · 消息发送封装（Spring Boot…
WMS端实现
11
ERP端实现（消费者）
消息监听与反序列化 · 采购订单生成逻辑（自动创建草稿单/审…
ERP端实现
12
事务消息与最终一致性
本地事务表+MQ · RocketMQ事务消息实现WMS与…
事务消息最终一致性
13
消息过滤与路由
基于Header的路由 · Tag过滤（RocketMQ） · 自定义Filter实现复杂业务规则
消息过滤路由
14
消息轨迹与链路追踪
OpenTelemetry集成 · 消息从生产到消费的全链路追踪
消息轨迹链路追踪
15
监控与告警
消息堆积监控（Prometheus… · 消费延迟告警 · 死信队列告警
监控告警
16
高可用架构
MQ集群部署（镜像队列/副本机制） · WMS与ERP的多活/灾备设计
高可用架构MQ
17
性能优化
批量发送与消费 · 异步处理 · 预创建Topic与分区
性能优化批量发送
18
安全机制
消息加密（TLS） · 身份认证（SASL/ACL） · 敏感字段脱敏
安全机制TLS
19
单元测试与集成测试
Mock生产者与消费者 · 测试消息发送与消费的端到端流程
单元测试集成测试
20
灰度发布与回滚
消息版本控制 · 消费者兼容性设计 · 灰度Topic策略
灰度发布回滚
21
案例实战一
WMS库存低于安全水位时自动触发ER…
案例实战一WMS
22
案例实战二
WMS退货入库后自动更新ERP采购订…
案例实战二WMS
23
案例实战三
WMS盘点差异通知ERP调整采购计划…
案例实战三WMS
24
异常场景处理
网络抖动导致消息丢失 · 消费者宕机恢复 · 消息重复消费
异常场景处理网络抖动导致消息…
25
数据一致性校验
对账机制（定时任务比对WMS与ERP… · 补偿脚本设计
数据一致性校验WMS
26
架构演进
从单体MQ到事件网格（Event M… · 云原生消息服务（AWS SQS/SN… · 阿里云RocketMQ）
架构演进MQ
27
与现有系统集成
遗留ERP的适配（Webhook/轮… · WMS接口改造策略
现有系统集成ERP
28
最佳实践总结
命名规范 · 日志规范 · 配置管理
最佳实践总结命名规范
29
常见问题FAQ
消息积压如何快速处理？如何选择分区数…
FAQ常见问题
30
课程总结与展望
事件驱动架构的未来（EDA + Se… · AI辅助运维
课程总结EDA