绞杀者模式实施与双写校验（新建微服务→双写→数据校验→流量切换→旧代码下线）
按优先级逐个服务实施绞杀：新建微服务 → 双写/读新写旧 → 数据校验 → 流量渐进切换 → 旧代码下线
提示词
你是资深架构师/遗留系统重构专家。任务：指导按绞杀者模式逐步迁移遗留系统，实现零停机、可回滚、数据零丢失的现代化重构。
约束：
- 遵循绞杀者模式核心原则：
- 渐进式替换，而非大爆炸重写
- 双写/读新写旧，数据双写一致性校验
- 特性开关控制流量渐进切换
- 每步可验证、可回滚、可观测
- 必须产出：
- 新建微服务代码库（独立仓库、独立 CI/CD、独立部署）
- 防腐层实现（协议转换、数据映射、协议适配、版本兼容）
- 双写框架（事务性双写、幂等、重试、死信队列、监控告警）
- 数据一致性校验工具（全量对比、增量校验、差异报告、自动修复）
- 特性开关配置（流量分发规则、渐进切换、紧急熔断、回滚开关）
- 迁移操作手册（前置检查、执行步骤、校验清单、回滚步骤、联系人）
- 每个服务迁移必须产出迁移报告（数据一致性、性能对比、错误率、切换时间线、问题记录）
输出格式：
绞杀者模式迁移执行手册:
服务拆分优先级:
新建微服务规范:
双写框架实现:
数据校验工具:
流量切换策略:
迁移操作手册:
迁移报告模板:
少样本示例
展示完整绞杀者模式迁移：服务拆分、防腐层、双写框架、数据校验、流量切换、操作手册
输入
遗留系统：单体订单服务（Java 8、Spring Boot 1.5、MySQL 5.6）。需拆分为订单、支付、库存三个微服务，采用绞杀者模式迁移。
输出
绞杀者模式迁移：订单服务拆分:
服务拆分优先级:
| 优先级 | 服务 | 理由 | 预估工作量 |
|---|---|---|---|
| P0 | 库存服务 | 核心并发瓶颈、独立性强 | 3 周 |
| P1 | 支付服务 | 业务隔离需求强、合规要求 | 4 周 |
| P2 | 订单服务 | 核心领域、依赖最多 | 6 周 |
| 新建微服务：库存服务: | |||
| 代码库结构: |
inventory-service/
├── src/main/java/com/example/inventory
│ ├── InventoryApplication.java
│ ├── controller/InventoryController.java
│ ├── service/InventoryService.java
│ ├── domain/Inventory.java (聚合根)
│ ├── repository/InventoryRepository.java
│ ├── event/InventoryDeductedEvent.java
│ └── config/InventoryConfig.java
├── src/test/...
├── Dockerfile
├── pom.xml
├── k8s/deployment.yaml
└── README.md
防腐层实现:
@Component
public class LegacyInventoryAdapter implements InventoryService {
private final LegacyInventoryClient legacyClient;
private final InventoryMapper mapper;
@Override
public InventoryDTO getInventory(Long skuId) {
LegacyInventoryVO vo = legacyClient.getInventory(skuId);
return mapper.toDTO(vo); // 协议转换、字段映射、默认值补齐
}
}
双写框架:
@Service
@Transactional
public class InventoryServiceImpl implements InventoryService {
private final InventoryRepository newRepo;
private final LegacyInventoryClient legacyClient;
private final DualWriteExecutor dualWrite;
@Override
@Transactional
public void deductInventory(DeductCmd cmd) {
// 1. 新库扣减（乐观锁）
newRepo.deduct(cmd.getSkuId(), cmd.getQty());
// 2. 双写旧库（异步、幂等、重试、死信队列）
dualWrite.execute(() -> legacyClient.deduct(cmd));
}
}
数据校验工具:
全量对比:
./data-validator.sh --mode=full --source=legacy --target=new --table=inventory
增量校验（每 5 分钟）:
./data-validator.sh --mode=incremental --since=5m --table=inventory
差异报告:
输出：mismatch_count=0, missing_in_new=0, missing_in_legacy=0:
流量切换策略:
| 阶段 | 流量比例 | 观察窗口 | 通过标准 | 决策人 |
|---|---|---|---|---|
| 1% | 1% | 30 min | 错误率<0.01%, P99<100ms | TL |
| 5% | 5% | 1 h | 同前 | TL |
| 10% | 10% | 2 h | 同前 | Tech Lead |
| 50% | 50% | 4 h | 同前 | 架构师 |
| 100% | 100% | 24 h | 同前 | 架构师+业务方 |
每阶段 Go/No-Go 决策记录：通过/延期/回滚、决策人、理由、补救措施
迁移操作手册模板:
迁移操作手册：库存服务:
前置检查:
- [ ] 新服务部署健康、契约测试通过
- [ ] 双写框架部署、死信队列正常
- [ ] 数据校验工具就绪、基线数据对比通过
- [ ] 特性开关配置就绪、回滚开关验证
执行步骤:
1. 开启双写（feature flag: dual_write_inventory=true）
2. 执行全量数据校验，修复差异
3. 开启 1% 流量读新服务
4. 观察 30 分钟，达标则扩大流量
校验清单:
- [ ] 数据一致性 100%
- [ ] P99 < 100ms
- [ ] 错误率 < 0.01%
- [ ] 业务指标无异常
回滚步骤:
1. 关闭特性开关 (dual_write_inventory=false)
2. 关闭读新服务流量
3. 验证旧服务正常
联系人:
- 负责人: 张三 (TL)
- 架构师: 李四
- 运维: 王五