软件架构模式

         ┌─────────────┐  HTTP ──┤  Controller  │──┐         └─────────────┘  │         ┌─────────────┐  │      ┌──────────────────┐  CLI  ──┤   Command    │──┼─────►│   领域核心        │         └─────────────┘  │      │  （业务规则）      │         ┌─────────────┐  │      └──────────────────┘  MQ   ──┤   Consumer   │──┘              │         └─────────────┘                 │                                 ┌───────┴────────┐                                 │  端口（接口）    │                                 └───────┬────────┘                          ┌──────────────┼──────────────┐                     ┌────▼────┐   ┌─────▼─────┐  ┌─────▼─────┐                     │ MySQL   │   │  Redis    │  │ 第三方 API │                     │ 适配器   │   │  适配器    │  │  适配器    │                     └─────────┘   └───────────┘  └───────────┘

// ✅ 值对象：把规则内聚，避免散落各处的判断class Money {  constructor(amountInCents, currency = 'CNY') {    if (!Number.isInteger(amountInCents)) throw new Error('金额必须为整数分')    if (amountInCents < 0) throw new Error('金额不能为负')    this.amount = amountInCents    this.currency = currency    Object.freeze(this)  }  add(other) {    if (other.currency !== this.currency) throw new Error('币种不一致')    return new Money(this.amount + other.amount, this.currency)  }  multiply(n) { return new Money(Math.round(this.amount * n), this.currency) }  toString() { return (this.amount / 100).toFixed(2) }}

// ✅ 订单项只通过订单修改class Order {  addItem(product, quantity) {    if (this.status !== 'pending') throw new Error('已提交的订单不能修改')    this.items.push(new OrderItem(product, quantity))    this.recalculateTotal()  }}// ❌ 绕过聚合根直接改子对象，规则被跳过order.items.push(new OrderItem(...))

src/├── modules/│   ├── order/│   │   ├── controller.js│   │   ├── service.js│   │   ├── domain/│   │   ├── repository.js│   │   └── index.js          ← 唯一对外出口│   ├── product/│   └── user/├── shared/                   ← 共享工具、通用组件└── app.js

// modules/order/service.jsconst productModule = require('../product')      // ✅ 通过模块出口// const productRepo = require('../product/repository')  // ❌ 禁止跨模块直接访问内部class OrderService {  async create(dto) {    const product = await productModule.getForSale(dto.productId)   // 走公开接口  }}

// ❌ 分支爆炸function calcFreight(type, weight) {  if (type === 'standard') return weight * 2  else if (type === 'express') return weight * 5 + 10  else if (type === 'free') return 0  // 每加一种就要改这个函数}// ✅ 策略表const FREIGHT_STRATEGIES = {  standard: (w) => w * 2,  express: (w) => w * 5 + 10,  free: () => 0,}function calcFreight(type, weight) {  const strategy = FREIGHT_STRATEGIES[type]  if (!strategy) throw new Error('未知运费类型')  return strategy(weight)}

const PAYMENT_PROVIDERS = {  alipay: () => new AlipayProvider(cfg.alipay),  wechat: () => new WechatProvider(cfg.wechat),  balance: () => new BalanceProvider(),}function createPaymentProvider(type) {  const factory = PAYMENT_PROVIDERS[type]  if (!factory) throw new Error('不支持的支付方式')  return factory()}

// 限流 + 缓存 + 日志，用装饰器叠加，不污染业务代码const getProducts = withCache(60)(withRateLimit(100)(withLog(baseGetProducts)))

// 下单后要发短信、加积分、写报表 —— 用事件解耦，而不是在 Service 里逐个调用eventBus.on('order.created', sendSmsHandler)eventBus.on('order.created', addPointsHandler)eventBus.on('order.created', writeReportHandler)

// ✅ 依赖注入：业务层接收抽象的仓储class OrderService {  constructor(orderRepo) { this.orderRepo = orderRepo }   // 只依赖接口}// 生产环境const service = new OrderService(new MysqlOrderRepository())// 测试环境const service = new OrderService(new InMemoryOrderRepository())

# ADR-003：订单模块采用模块内分层，暂不拆微服务日期：2026-01-01状态：已采纳## 背景订单模块业务规则复杂，但团队仅 5 人，且部署时间 < 3 分钟。## 决策采用模块化单体：订单作为独立模块，模块内分层（Controller/Service/Domain/Repository），模块间只通过 index.js 公开接口通信；暂不拆分独立服务。## 备选方案- 直接拆微服务：需要引入注册中心、链路追踪，运维成本超出团队承受范围。- 纯技术分层：模块边界不清晰，订单与商品逻辑相互渗透。## 后果- 正面：开发效率高、本地事务简单、部署简单。- 负面：订单高峰期无法单独扩容。- 触发重新评估的条件：订单模块 QPS 超过单机承载的 60%，或团队规模超过 15 人。