Act as a seasoned senior softw…

# Spring Boot单体拆微服务：订单+库存先行方案

一、拆分前准备

• 梳理依赖：先分析订单、库存模块在单体中的调用关系、共享表、公共工具类
• 数据库先行规划：订单库（orders）、库存库（inventory）独立，彻底禁止跨库join，这是拆分成功的前提
• 基础设施：Kafka集群、注册中心（Nacos/Eureka）、网关（Spring Cloud Gateway）、分布式事务方案（本地消息表/Seata）

二、服务边界划分

订单服务

• 职责：订单创建、状态流转（待支付/已支付/已取消）、订单查询
• 表：订单主表、订单明细表
• 对外接口：创建订单、取消订单、订单状态查询

库存服务

• 职责：库存扣减、回滚、库存查询、预占库存管理
• 表：库存表、库存流水表
• 对外接口：扣减库存、释放库存、库存查询

边界原则

• 订单服务不直接操作库存表，只通过消息/接口与库存服务交互
• 公共能力（用户信息、商品基础信息）后续再拆，或先通过API调商品服务/复制必要冗余字段（如订单中冗余商品名称快照）

三、Kafka消息通信方案

核心Topic设计

• order.created（订单创建成功）：订单服务发布 → 库存服务消费，执行扣减
• order.cancelled（订单取消/超时）：订单服务发布 → 库存服务消费，释放库存
• inventory.deducted / inventory.deduct.failed：库存服务发布 → 订单服务消费，更新订单状态（扣减成功→待支付；失败→自动取消）

关键技术点

• 消息可靠性：生产端开启confirm + 本地消息表；消费端幂等处理（消费记录表，按订单号+事件类型去重）
• 消费顺序：同一订单的消息走相同partition（以orderId为key）
• 死信队列：消费失败重试N次后进DLQ，人工/定时补偿
• 最终一致性流程：

1. 订单服务：创建订单（状态=处理中）→ 发order.created

2. 库存服务：扣减库存 → 发inventory.deducted/failed

3. 订单服务：消费结果更新状态；超时未收到回执则定时任务对账补偿

四、实施步骤建议

1. 单体内先做模块化改造（独立module、独立数据访问）

2. 抽取订单服务，库存暂留单体（API调用过渡）

3. 抽取库存服务，切换为Kafka异步通信

4. 引入链路追踪（SkyWalking）和监控，灰度切流

核心原则：先解耦数据，再解耦服务；优先异步消息而非同步RPC，降低服务间耦合。