企业官网建设流程全解析

DDD-029：遗留系统重构为 DDD 架构

本章导读

在实际工作中，我们经常面临维护和改进遗留系统的挑战。传统的贫血模型系统往往存在业务逻辑分散、代码难以维护、扩展困难等问题。本章将系统性地探讨如何将遗留系统渐进式地重构为 DDD 架构，重点介绍绞杀者模式、领域模型提取、数据库迁移等关键策略。

学习目标

1. 理解遗留系统分析的方法和重构价值评估
2. 掌握绞杀者模式的核心原理和实施步骤
3. 学会渐进式重构的具体实践方法

前置知识

• DDD 战略设计和战术设计基础
• 重构基础概念和方法
• 数据库迁移策略

阅读时长

约 50-60 分钟

【原理】遗留系统重构策略

一、遗留系统分析

1.1 遗留系统的典型问题

【历史架构问题】

// ❌ 典型遗留系统：贫血模型 + 业务逻辑分散// Entity：只有数据，没有行为@Entity@Table(name="orders")publicclassOrderEntity{@IdprivateStringid;privateStringcustomerId;privateStringstatus;privateBigDecimaltotalAmount;// 只有 getter/setter，没有业务方法// 业务规则在哪里？}// Service：所有业务逻辑都在这里@ServicepublicclassOrderService{@AutowiredprivateOrderDaoorderDao;@AutowiredprivateProductDaoproductDao;@AutowiredprivateInventoryDaoinventoryDao;@AutowiredprivatePaymentServicepaymentService;@AutowiredprivateNotificationServicenotificationService;// 创建订单：业务逻辑散落在 Service 方法中publicStringcreateOrder(CreateOrderDTOdto){// 验证逻辑if(dto.getItems()==null||dto.getItems().isEmpty()){thrownewBusinessException("订单项不能为空");}// 计算逻辑BigDecimaltotal=BigDecimal.ZERO;for(OrderItemDTOitem:dto.getItems()){ProductEntityproduct=productDao.findById(item.getProductId());if(product==null){thrownewBusinessException("商品不存在："+item.getProductId());}if(product.getStock()<item.getQuantity()){thrownewBusinessException("库存不足："+product.getName());}total=total.add(product.getPrice().multiply(BigDecimal.valueOf(item.getQuantity())));}// 创建实体OrderEntityorder=newOrderEntity();order.setId(UUID.randomUUID().toString());order.setCustomerId(dto.getCustomerId());order.setStatus("CREATED");order.setTotalAmount(total);order.setCreatedAt(LocalDateTime.now());// 保存orderDao.insert(order);// 保存订单项for(OrderItemDTOitem:dto.getItems()){OrderItemEntityitemEntity=newOrderItemEntity();itemEntity.setOrderId(order.getId());itemEntity.setProductId(item.getProductId());itemEntity.setQuantity(item.getQuantity());orderItemDao.insert(itemEntity);}returnorder.getId();}// 支付订单：更多业务逻辑publicvoidpayOrder(StringorderId,PaymentRequestrequest){OrderEntityorder=orderDao.findById(orderId);if(order==null){thrownewBusinessException("订单不存在");}if(!"CREATED".equals(order.getStatus())){thrownewBusinessException("只有待支付订单才能支付");}// 调用支付PaymentResultresult=paymentService.pay(request);// 更新状态order.setStatus("PAID");order.setPaymentId(result.getPaymentId());order.setPaidAt(LocalDateTime.now())