架构演进，先做一条可回退的最小链路

架构演进先做一条可回退的最小链路遗留系统改造可以先从一条边界清晰的链路开始。防腐层的目标是隔离模型差异而不是把所有旧代码一次搬走。上个月团队需要为老单体系统接入全新的微服务化结算中台。初出茅庐的工程师在老系统的 OrderService 里直接注入了新中台的 RPC Client。结果为了适配新中台要求的枚举格式老系统修改了十几张数据库表的读写逻辑。在随后的上线发布中因为老系统内部复杂的事务嵌套新 RPC 接口耗时一长立马触发了数据库 Connection 泄漏与死锁连带导致原有的下单、退款、履约全部瘫痪。在重构遗留架构时直接把新接口硬编码连入旧逻辑是极其危险的。我们需要在遗留模型与新系统之间架设一座隔离污染的防腐层ACL, Anti-Corruption Layer并借由领域事件Domain Event实现异步解耦。1. 遗留大单体的泥潭与防腐隔离必要性在漫长的演进过程中遗留单体系统往往存在以下“架构腐化”特征贫血与充血模型混杂DTO、DO、PO 被无序透传一个OrderPO字段多达 90 个被上百个 Service 互相引用。模型语义严重漂移老系统里的order_type 1在新中台对应的是SetlementCategory.RETAIL直接在老代码里写if-else会导致污染迅速蔓延。事务边界模糊旧代码中大量使用Transactional大事务里面既有 DB 读写又有同步 HTTP 调用极易引起线程池锁死。如果直接用新中台的模型去修改老系统老系统的坏味道就会瞬间污染新架构。防腐层ACL的核心使命就是充当一个“双向翻译官 隔离沙箱”。它负责将老系统的遗留模型Legacy Model转换为干净的领域模型Domain Model并拦截一切强耦合的同步调用。2. 基于 DDD 防腐层与 Spring Event 的解耦架构我们采用“最小可行防腐层MVP ACL”策略。遗留业务不再直接调用新中台 API而是只向 Spring 内部发布一个OrderCompletedEvent领域事件。防腐层监听该事件在独立线程池中进行上下文翻译再异步推送到新结算中台3. 生产级 ACL 适配器与 Spring Event 管道代码在 Spring Boot 框架下我们利用Async与ApplicationEventPublisher构建轻量级、零代码侵入的 ACL 防腐隔离层。3.1 领域事件定义与遗留模型隔离package com.example.legacy.acl.event; import org.springframework.context.ApplicationEvent; /** * 遗留订单完成事件仅包含最小化主键与关键状态绝不直接透传数据库 PO */ public class LegacyOrderCompletedEvent extends ApplicationEvent { private final String orderNo; private final Long userId; private final Long totalAmountCents; public LegacyOrderCompletedEvent(Object source, String orderNo, Long userId, Long totalAmountCents) { super(source); this.orderNo orderNo; this.userId userId; this.totalAmountCents totalAmountCents; } public String getOrderNo() { return orderNo; } public Long getUserId() { return userId; } public Long getTotalAmountCents() { return totalAmountCents; } }3.2 防腐层翻译器与异步隔离 Listenerpackage com.example.legacy.acl.service; import com.example.legacy.acl.event.LegacyOrderCompletedEvent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.event.EventListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; Component public class SettlementAntiCorruptionFacade { private static final Logger log LoggerFactory.getLogger(SettlementAntiCorruptionFacade.class); private final NewSettlementAdapter settlementAdapter; public SettlementAntiCorruptionFacade(NewSettlementAdapter settlementAdapter) { this.settlementAdapter settlementAdapter; } /** * 监听遗留系统的订单事件使用 Async 强制脱离遗留系统的 DB 事务上下文 */ Async(aclAsyncExecutor) EventListener public void handleLegacyOrderCompleted(LegacyOrderCompletedEvent event) { log.info(ACL Intercepted Legacy Order Event: OrderNo{}, event.getOrderNo()); try { // 1. ACL 模型翻译将老系统的字段如分单位分翻译为新中台的标准数据模型 TargetSettlementRequest request translateToNewDomainModel(event); // 2. 调用防腐隔离适配器向新中台同步 boolean success settlementAdapter.invokeNewSettlementSystem(request); if (!success) { log.warn(ACL Settlement Sync Warning! OrderNo{} will enter retry queue., event.getOrderNo()); } } catch (Exception ex) { log.error(ACL Translation or Invocation Failed for OrderNo{}, event.getOrderNo(), ex); // 隔离异常防止防腐层报错导致老系统单体事务回滚 } } private TargetSettlementRequest translateToNewDomainModel(LegacyOrderCompletedEvent event) { TargetSettlementRequest request new TargetSettlementRequest(); request.setOutTradeNo(event.getOrderNo()); request.setCustomerRefId(String.valueOf(event.getUserId())); // 防腐层处理逻辑分转元、处理精度问题 request.setSettlementAmount(new java.math.BigDecimal(event.getTotalAmountCents()).divide(new java.math.BigDecimal(100))); request.setChannelSource(LEGACY_MONOLITH_V1); return request; } }4. 依赖分析与生产现场终端调试在剥离遗留架构时最忌讳“剪不断理还乱”的循环依赖Circular Dependencies。我们需要在跳板机与 CI 环境中使用 JDK 自带的jdeps命令行工具分析包之间的物理依赖图谱。分析老系统的jar包检测是否有代码绕过 ACL 直接引用了新中台的类# 1. 使用 jdeps 分析应用 Class 文件的包依赖结构过滤出反向依赖 jdeps -verbose:class -e com.example.newdomain.* /var/app/legacy-monolith.jar # 输出示例如果发现老 Service 绕过了 ACL 直连新类直接预警 # com.example.legacy.service.OrderService - com.example.newdomain.client.SettlementClient (BUG: 违反 ACL 隔离)使用mvn dependency:analyze治理 POM 文件中的死锁依赖# 2. 检查 Maven 依赖树清理没有用到但被隐式引入的二方库 mvn dependency:analyze -DignoreNonCompiletrue在生产环境中通过 Spring Actuator 动态检查 ACL 专属线程池aclAsyncExecutor的积压情况# 检查 ACL 线程池队列是否有未完成的任务积压 curl -s http://localhost:8080/actuator/metrics/executor.queued | grep aclAsyncExecutor通过这一套手段我们确保防腐层在独立线程池中稳健运行即便新结算中台全部宕机老单体系统的下单主流程也不会受到半点影响。5. 遗留系统重构的“三不”原则防线绝不跨界修改老 PO 数据结构新增业务需要任何字段一律在新微服务的 DB 中创建老单体数据库结构保持冻结Freeze。防腐层只做单向数据映射禁止将新业务字段硬挤进老表。绝不在老事务Transactional中同步调用新 RPC所有跨系统交互必须通过 Spring Event 或 MQ 剥离成异步非阻塞过程。防腐层方法必须拥有独立的线程池隔离杜绝大事务拖垮数据库连接池。防腐层ACL生命周期必须明确定义防腐层是一种“过渡期脚手架”。在设计 ACL 时必须编写单元测试覆盖模型映射逻辑。当遗留单体彻底退役时直接整块物理删除 ACL 包无需二次重构新系统。