网站导航
> 技术文档 > 设计模式：行为型模式--＞中介者模式_中介者流程图

设计模式：行为型模式--＞中介者模式_中介者流程图

网友: 技术文档 2025-08-08 10:04:45

深入解析中介者模式：从原理到阿里/字节跳动级工程实践

一、中介者模式深度解析

4.5.1 中介者模式的定义与结构

定义：中介者模式(Mediator Pattern)是一种行为型设计模式，它通过定义一个封装一组对象交互的中介者对象，来降低对象之间的直接耦合度，使对象不必显式地相互引用。

UML类图：

#mermaid-svg-9uX4n0wWBTtzpf1n {font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-9uX4n0wWBTtzpf1n .error-icon{fill:#552222;}#mermaid-svg-9uX4n0wWBTtzpf1n .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-9uX4n0wWBTtzpf1n .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-9uX4n0wWBTtzpf1n .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-9uX4n0wWBTtzpf1n .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-9uX4n0wWBTtzpf1n .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-9uX4n0wWBTtzpf1n .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-9uX4n0wWBTtzpf1n .marker{fill:#333333;stroke:#333333;}#mermaid-svg-9uX4n0wWBTtzpf1n .marker.cross{stroke:#333333;}#mermaid-svg-9uX4n0wWBTtzpf1n svg{font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-9uX4n0wWBTtzpf1n g.classGroup text{fill:#9370DB;fill:#131300;stroke:none;font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:10px;}#mermaid-svg-9uX4n0wWBTtzpf1n g.classGroup text .title{font-weight:bolder;}#mermaid-svg-9uX4n0wWBTtzpf1n .nodeLabel,#mermaid-svg-9uX4n0wWBTtzpf1n .edgeLabel{color:#131300;}#mermaid-svg-9uX4n0wWBTtzpf1n .edgeLabel .label rect{fill:#ECECFF;}#mermaid-svg-9uX4n0wWBTtzpf1n .label text{fill:#131300;}#mermaid-svg-9uX4n0wWBTtzpf1n .edgeLabel .label span{background:#ECECFF;}#mermaid-svg-9uX4n0wWBTtzpf1n .classTitle{font-weight:bolder;}#mermaid-svg-9uX4n0wWBTtzpf1n .node rect,#mermaid-svg-9uX4n0wWBTtzpf1n .node circle,#mermaid-svg-9uX4n0wWBTtzpf1n .node ellipse,#mermaid-svg-9uX4n0wWBTtzpf1n .node polygon,#mermaid-svg-9uX4n0wWBTtzpf1n .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-9uX4n0wWBTtzpf1n .divider{stroke:#9370DB;stroke:1;}#mermaid-svg-9uX4n0wWBTtzpf1n g.clickable{cursor:pointer;}#mermaid-svg-9uX4n0wWBTtzpf1n g.classGroup rect{fill:#ECECFF;stroke:#9370DB;}#mermaid-svg-9uX4n0wWBTtzpf1n g.classGroup line{stroke:#9370DB;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n .classLabel .box{stroke:none;stroke-width:0;fill:#ECECFF;opacity:0.5;}#mermaid-svg-9uX4n0wWBTtzpf1n .classLabel .label{fill:#9370DB;font-size:10px;}#mermaid-svg-9uX4n0wWBTtzpf1n .relation{stroke:#333333;stroke-width:1;fill:none;}#mermaid-svg-9uX4n0wWBTtzpf1n .dashed-line{stroke-dasharray:3;}#mermaid-svg-9uX4n0wWBTtzpf1n #compositionStart,#mermaid-svg-9uX4n0wWBTtzpf1n .composition{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #compositionEnd,#mermaid-svg-9uX4n0wWBTtzpf1n .composition{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #dependencyStart,#mermaid-svg-9uX4n0wWBTtzpf1n .dependency{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #dependencyStart,#mermaid-svg-9uX4n0wWBTtzpf1n .dependency{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #extensionStart,#mermaid-svg-9uX4n0wWBTtzpf1n .extension{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #extensionEnd,#mermaid-svg-9uX4n0wWBTtzpf1n .extension{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #aggregationStart,#mermaid-svg-9uX4n0wWBTtzpf1n .aggregation{fill:#ECECFF!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n #aggregationEnd,#mermaid-svg-9uX4n0wWBTtzpf1n .aggregation{fill:#ECECFF!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-9uX4n0wWBTtzpf1n .edgeTerminals{font-size:11px;}#mermaid-svg-9uX4n0wWBTtzpf1n :root{--mermaid-font-family:\"trebuchet ms\",verdana,arial,sans-serif;}«interface»Mediator+mediate(Colleague)ConcreteMediator-colleague1: Colleague-colleague2: Colleague+mediate(Colleague)«abstract»Colleague-mediator: Mediator+setMediator(Mediator)+send(String)+receive(String)ConcreteColleague1+send(String)+receive(String)ConcreteColleague2+send(String)+receive(String)

核心角色：

  1. Mediator（中介者接口）：定义各同事对象通信的接口
  2. ConcreteMediator（具体中介者）：协调各同事对象实现协作行为
  3. Colleague（同事类）：定义同事对象的接口，持有中介者引用
  4. ConcreteColleague（具体同事类）：实现同事类接口，只与中介者通信

4.5.2 中介者模式的实现方式

标准实现示例
// 中介者接口public interface ChatMediator { void sendMessage(String msg, User user); void addUser(User user);}// 具体中介者public class ChatMediatorImpl implements ChatMediator { private List<User> users; public ChatMediatorImpl() { this.users = new ArrayList<>(); } @Override public void sendMessage(String msg, User user) { for (User u : users) { // 排除消息发送者 if (u != user) { u.receive(msg); } } } @Override public void addUser(User user) { this.users.add(user); }}// 同事类public abstract class User { protected ChatMediator mediator; protected String name; public User(ChatMediator med, String name) { this.mediator = med; this.name = name; } public abstract void send(String msg); public abstract void receive(String msg);}// 具体同事类public class UserImpl extends User { public UserImpl(ChatMediator med, String name) { super(med, name); } @Override public void send(String msg) { System.out.println(name + \" 发送消息: \" + msg); mediator.sendMessage(msg, this); } @Override public void receive(String msg) { System.out.println(name + \" 收到消息: \" + msg); }}
复杂交互场景实现
// 电商订单处理中介者public interface OrderMediator { void placeOrder(Order order); void processPayment(Payment payment); void updateInventory(Order order); void notifyCustomer(Order order, String message);}// 具体订单中介者public class OrderProcessingMediator implements OrderMediator { private PaymentSystem paymentSystem; private InventorySystem inventorySystem; private NotificationService notificationService; @Override public void placeOrder(Order order) { // 验证订单 Payment payment = new Payment(order.getTotalAmount()); processPayment(payment); updateInventory(order); notifyCustomer(order, \"您的订单已处理\"); } // 其他方法实现...}

4.5.3 中介者模式的优缺点

优点：

  1. 降低耦合度：将网状交互改为星型交互
  2. 简化对象协议：用一对多代替多对多交互
  3. 集中控制：将交互复杂性转移到中介者
  4. 可扩展性：新增同事类不影响现有类
  5. 职责清晰：各对象只需关注自身业务逻辑

缺点：

  1. 中介者复杂度：可能演化为\"上帝对象\"
  2. 性能影响：中介者可能成为性能瓶颈
  3. 过度设计风险：简单系统可能不需要
  4. 调试困难：交互逻辑集中在中介者

4.5.4 中介者模式的应用场景

  1. GUI组件交互：按钮、输入框等控件通过对话框协调
  2. 聊天应用：多个用户通过聊天室通信
  3. 微服务协调：服务间通过API网关交互
  4. 工作流引擎：多个处理节点通过引擎协调
  5. 航空管制系统：飞机与塔台通信
  6. 游戏开发：游戏对象通过场景管理器交互

二、大型电商平台中的中介者模式实践

在阿里/字节跳动等大型电商平台中，订单处理系统是典型的中介者模式应用场景。以下是订单处理流程：

系统流程图：

#mermaid-svg-L6UdQrai8hA5caso {font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-L6UdQrai8hA5caso .error-icon{fill:#552222;}#mermaid-svg-L6UdQrai8hA5caso .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-L6UdQrai8hA5caso .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-L6UdQrai8hA5caso .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-L6UdQrai8hA5caso .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-L6UdQrai8hA5caso .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-L6UdQrai8hA5caso .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-L6UdQrai8hA5caso .marker{fill:#333333;stroke:#333333;}#mermaid-svg-L6UdQrai8hA5caso .marker.cross{stroke:#333333;}#mermaid-svg-L6UdQrai8hA5caso svg{font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-L6UdQrai8hA5caso .label{font-family:\"trebuchet ms\",verdana,arial,sans-serif;color:#333;}#mermaid-svg-L6UdQrai8hA5caso .cluster-label text{fill:#333;}#mermaid-svg-L6UdQrai8hA5caso .cluster-label span{color:#333;}#mermaid-svg-L6UdQrai8hA5caso .label text,#mermaid-svg-L6UdQrai8hA5caso span{fill:#333;color:#333;}#mermaid-svg-L6UdQrai8hA5caso .node rect,#mermaid-svg-L6UdQrai8hA5caso .node circle,#mermaid-svg-L6UdQrai8hA5caso .node ellipse,#mermaid-svg-L6UdQrai8hA5caso .node polygon,#mermaid-svg-L6UdQrai8hA5caso .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-L6UdQrai8hA5caso .node .label{text-align:center;}#mermaid-svg-L6UdQrai8hA5caso .node.clickable{cursor:pointer;}#mermaid-svg-L6UdQrai8hA5caso .arrowheadPath{fill:#333333;}#mermaid-svg-L6UdQrai8hA5caso .edgePath .path{stroke:#333333;stroke-width:2.0px;}#mermaid-svg-L6UdQrai8hA5caso .flowchart-link{stroke:#333333;fill:none;}#mermaid-svg-L6UdQrai8hA5caso .edgeLabel{background-color:#e8e8e8;text-align:center;}#mermaid-svg-L6UdQrai8hA5caso .edgeLabel rect{opacity:0.5;background-color:#e8e8e8;fill:#e8e8e8;}#mermaid-svg-L6UdQrai8hA5caso .cluster rect{fill:#ffffde;stroke:#aaaa33;stroke-width:1px;}#mermaid-svg-L6UdQrai8hA5caso .cluster text{fill:#333;}#mermaid-svg-L6UdQrai8hA5caso .cluster span{color:#333;}#mermaid-svg-L6UdQrai8hA5caso div.mermaidTooltip{position:absolute;text-align:center;max-width:200px;padding:2px;font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:12px;background:hsl(80, 100%, 96.2745098039%);border:1px solid #aaaa33;border-radius:2px;pointer-events:none;z-index:100;}#mermaid-svg-L6UdQrai8hA5caso :root{--mermaid-font-family:\"trebuchet ms\",verdana,arial,sans-serif;}用户下单订单服务支付服务库存服务物流服务通知服务用户

时序图：

#mermaid-svg-e92l5KlQLGSkT8HX {font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-e92l5KlQLGSkT8HX .error-icon{fill:#552222;}#mermaid-svg-e92l5KlQLGSkT8HX .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-e92l5KlQLGSkT8HX .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-e92l5KlQLGSkT8HX .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-e92l5KlQLGSkT8HX .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-e92l5KlQLGSkT8HX .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-e92l5KlQLGSkT8HX .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-e92l5KlQLGSkT8HX .marker{fill:#333333;stroke:#333333;}#mermaid-svg-e92l5KlQLGSkT8HX .marker.cross{stroke:#333333;}#mermaid-svg-e92l5KlQLGSkT8HX svg{font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-e92l5KlQLGSkT8HX .actor{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-e92l5KlQLGSkT8HX text.actor>tspan{fill:black;stroke:none;}#mermaid-svg-e92l5KlQLGSkT8HX .actor-line{stroke:grey;}#mermaid-svg-e92l5KlQLGSkT8HX .messageLine0{stroke-width:1.5;stroke-dasharray:none;stroke:#333;}#mermaid-svg-e92l5KlQLGSkT8HX .messageLine1{stroke-width:1.5;stroke-dasharray:2,2;stroke:#333;}#mermaid-svg-e92l5KlQLGSkT8HX #arrowhead path{fill:#333;stroke:#333;}#mermaid-svg-e92l5KlQLGSkT8HX .sequenceNumber{fill:white;}#mermaid-svg-e92l5KlQLGSkT8HX #sequencenumber{fill:#333;}#mermaid-svg-e92l5KlQLGSkT8HX #crosshead path{fill:#333;stroke:#333;}#mermaid-svg-e92l5KlQLGSkT8HX .messageText{fill:#333;stroke:#333;}#mermaid-svg-e92l5KlQLGSkT8HX .labelBox{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-e92l5KlQLGSkT8HX .labelText,#mermaid-svg-e92l5KlQLGSkT8HX .labelText>tspan{fill:black;stroke:none;}#mermaid-svg-e92l5KlQLGSkT8HX .loopText,#mermaid-svg-e92l5KlQLGSkT8HX .loopText>tspan{fill:black;stroke:none;}#mermaid-svg-e92l5KlQLGSkT8HX .loopLine{stroke-width:2px;stroke-dasharray:2,2;stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);}#mermaid-svg-e92l5KlQLGSkT8HX .note{stroke:#aaaa33;fill:#fff5ad;}#mermaid-svg-e92l5KlQLGSkT8HX .noteText,#mermaid-svg-e92l5KlQLGSkT8HX .noteText>tspan{fill:black;stroke:none;}#mermaid-svg-e92l5KlQLGSkT8HX .activation0{fill:#f4f4f4;stroke:#666;}#mermaid-svg-e92l5KlQLGSkT8HX .activation1{fill:#f4f4f4;stroke:#666;}#mermaid-svg-e92l5KlQLGSkT8HX .activation2{fill:#f4f4f4;stroke:#666;}#mermaid-svg-e92l5KlQLGSkT8HX .actorPopupMenu{position:absolute;}#mermaid-svg-e92l5KlQLGSkT8HX .actorPopupMenuPanel{position:absolute;fill:#ECECFF;box-shadow:0px 8px 16px 0px rgba(0,0,0,0.2);filter:drop-shadow(3px 5px 2px rgb(0 0 0 / 0.4));}#mermaid-svg-e92l5KlQLGSkT8HX .actor-man line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;}#mermaid-svg-e92l5KlQLGSkT8HX .actor-man circle,#mermaid-svg-e92l5KlQLGSkT8HX line{stroke:hsl(259.6261682243, 59.7765363128%, 87.9019607843%);fill:#ECECFF;stroke-width:2px;}#mermaid-svg-e92l5KlQLGSkT8HX :root{--mermaid-font-family:\"trebuchet ms\",verdana,arial,sans-serif;}UserOrderServicePaymentServiceInventoryServiceLogisticsServiceNotificationService提交订单处理支付支付结果扣减库存库存结果创建物流物流单号通知用户发送通知UserOrderServicePaymentServiceInventoryServiceLogisticsServiceNotificationService

500字详细实现：

在电商平台订单系统中，我们设计了OrderProcessingMediator作为核心中介者，协调以下服务：

  1. 支付服务：处理支付宝/微信/银行卡支付
  2. 库存服务：实时扣减库存，处理预占逻辑
  3. 物流服务：生成运单，对接第三方物流
  4. 风控服务：实时风险检测
  5. 通知服务：短信/邮件/APP推送
public class OrderProcessingMediator implements OrderMediator { // 依赖的服务 private final PaymentGateway paymentGateway; private final InventoryManager inventoryManager; private final LogisticsService logisticsService; private final RiskControlService riskControl; private final NotificationSender notifier; @Override public void processOrder(Order order) { // 1. 风控检查 RiskCheckResult riskResult = riskControl.check(order); if (!riskResult.isPassed()) { notifier.notify(order.getUser(), \"订单风控审核未通过\"); return; } // 2. 支付处理 PaymentResult paymentResult = paymentGateway.process( new PaymentRequest(order)); if (!paymentResult.isSuccess()) { notifier.notify(order.getUser(), \"支付失败\"); return; } // 3. 库存扣减 InventoryUpdateResult inventoryResult = inventoryManager.update(order); if (!inventoryResult.isSuccess()) { // 支付退款 paymentGateway.refund(order); notifier.notify(order.getUser(), \"库存不足已退款\"); return; } // 4. 物流处理 LogisticsTicket ticket = logisticsService.create(order); // 5. 通知用户 notifier.notify(order.getUser(), \"订单已发货，物流单号: \" + ticket.getNumber()); }}

这种设计带来的优势：

  • 订单处理逻辑集中维护，修改不影响各服务
  • 新增服务只需修改中介者，不改变现有服务
  • 便于实现分布式事务的SAGA模式
  • 支持灵活的动态流程调整

三、大厂面试深度追问与解决方案

追问1：如何避免中介者演变为\"上帝对象\"？

\"上帝对象\"问题是中介者模式的主要反模式，以下是阿里/字节跳动级别的解决方案：

  1. 职责拆分：
// 将大中介者拆分为多个专业中介者public interface OrderMediator { void processOrder(Order order);}public interface PaymentMediator { PaymentResult processPayment(Order order); RefundResult processRefund(Order order);}public interface LogisticsMediator { LogisticsTicket arrangeDelivery(Order order); TrackingResult trackDelivery(String ticketNo);}
  1. 分层设计：

#mermaid-svg-nFsUx594GVwbkSQx {font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-nFsUx594GVwbkSQx .error-icon{fill:#552222;}#mermaid-svg-nFsUx594GVwbkSQx .error-text{fill:#552222;stroke:#552222;}#mermaid-svg-nFsUx594GVwbkSQx .edge-thickness-normal{stroke-width:2px;}#mermaid-svg-nFsUx594GVwbkSQx .edge-thickness-thick{stroke-width:3.5px;}#mermaid-svg-nFsUx594GVwbkSQx .edge-pattern-solid{stroke-dasharray:0;}#mermaid-svg-nFsUx594GVwbkSQx .edge-pattern-dashed{stroke-dasharray:3;}#mermaid-svg-nFsUx594GVwbkSQx .edge-pattern-dotted{stroke-dasharray:2;}#mermaid-svg-nFsUx594GVwbkSQx .marker{fill:#333333;stroke:#333333;}#mermaid-svg-nFsUx594GVwbkSQx .marker.cross{stroke:#333333;}#mermaid-svg-nFsUx594GVwbkSQx svg{font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:16px;}#mermaid-svg-nFsUx594GVwbkSQx g.classGroup text{fill:#9370DB;fill:#131300;stroke:none;font-family:\"trebuchet ms\",verdana,arial,sans-serif;font-size:10px;}#mermaid-svg-nFsUx594GVwbkSQx g.classGroup text .title{font-weight:bolder;}#mermaid-svg-nFsUx594GVwbkSQx .nodeLabel,#mermaid-svg-nFsUx594GVwbkSQx .edgeLabel{color:#131300;}#mermaid-svg-nFsUx594GVwbkSQx .edgeLabel .label rect{fill:#ECECFF;}#mermaid-svg-nFsUx594GVwbkSQx .label text{fill:#131300;}#mermaid-svg-nFsUx594GVwbkSQx .edgeLabel .label span{background:#ECECFF;}#mermaid-svg-nFsUx594GVwbkSQx .classTitle{font-weight:bolder;}#mermaid-svg-nFsUx594GVwbkSQx .node rect,#mermaid-svg-nFsUx594GVwbkSQx .node circle,#mermaid-svg-nFsUx594GVwbkSQx .node ellipse,#mermaid-svg-nFsUx594GVwbkSQx .node polygon,#mermaid-svg-nFsUx594GVwbkSQx .node path{fill:#ECECFF;stroke:#9370DB;stroke-width:1px;}#mermaid-svg-nFsUx594GVwbkSQx .divider{stroke:#9370DB;stroke:1;}#mermaid-svg-nFsUx594GVwbkSQx g.clickable{cursor:pointer;}#mermaid-svg-nFsUx594GVwbkSQx g.classGroup rect{fill:#ECECFF;stroke:#9370DB;}#mermaid-svg-nFsUx594GVwbkSQx g.classGroup line{stroke:#9370DB;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx .classLabel .box{stroke:none;stroke-width:0;fill:#ECECFF;opacity:0.5;}#mermaid-svg-nFsUx594GVwbkSQx .classLabel .label{fill:#9370DB;font-size:10px;}#mermaid-svg-nFsUx594GVwbkSQx .relation{stroke:#333333;stroke-width:1;fill:none;}#mermaid-svg-nFsUx594GVwbkSQx .dashed-line{stroke-dasharray:3;}#mermaid-svg-nFsUx594GVwbkSQx #compositionStart,#mermaid-svg-nFsUx594GVwbkSQx .composition{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #compositionEnd,#mermaid-svg-nFsUx594GVwbkSQx .composition{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #dependencyStart,#mermaid-svg-nFsUx594GVwbkSQx .dependency{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #dependencyStart,#mermaid-svg-nFsUx594GVwbkSQx .dependency{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #extensionStart,#mermaid-svg-nFsUx594GVwbkSQx .extension{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #extensionEnd,#mermaid-svg-nFsUx594GVwbkSQx .extension{fill:#333333!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #aggregationStart,#mermaid-svg-nFsUx594GVwbkSQx .aggregation{fill:#ECECFF!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx #aggregationEnd,#mermaid-svg-nFsUx594GVwbkSQx .aggregation{fill:#ECECFF!important;stroke:#333333!important;stroke-width:1;}#mermaid-svg-nFsUx594GVwbkSQx .edgeTerminals{font-size:11px;}#mermaid-svg-nFsUx594GVwbkSQx :root{--mermaid-font-family:\"trebuchet ms\",verdana,arial,sans-serif;}TopLevelMediator-paymentMediator: PaymentMediator-logisticsMediator: LogisticsMediator+processOrder(Order)PaymentMediatorImpl+processPayment(Order)LogisticsMediatorImpl+arrangeDelivery(Order)

  1. 领域驱动设计：
  • 每个限界上下文有自己的中介者
  • 通过领域事件进行上下文间通信
  1. 动态责任链：
public class ChainableMediator implements OrderMediator { private List<OrderProcessor> processors; @Override public void processOrder(Order order) { for (OrderProcessor processor : processors) { if (!processor.process(order)) { break; } } }}
  1. 监控与治理：
  • 为中介者方法添加Metrics监控
  • 实现熔断机制防止雪崩
  • 使用代码扫描工具检测过大类

在字节跳动电商系统中，我们采用\"微中介者\"架构：

  • 每个业务阶段有独立中介者
  • 通过工作流引擎协调中介者执行
  • 每个中介者不超过5个依赖服务
  • 代码行数控制在300行以内

追问2：如何在中介者模式中实现分布式事务？

在微服务架构下，中介者需要协调跨服务的分布式事务，以下是解决方案：

  1. SAGA模式实现：
public class OrderSagaMediator { public void processOrder(Order order) { Saga saga = newSaga(\"orderProcessing\") .activity(\"支付\", () -> paymentService.process(order)) .compensation(\"支付回滚\", () -> paymentService.refund(order)) .activity(\"库存\", () -> inventoryService.update(order)) .compensation(\"库存回滚\", () -> inventoryService.revert(order)) .activity(\"物流\", () -> logisticsService.create(order)); saga.execute(); }}
  1. TCC模式实现：
public class OrderTccMediator { public void processOrder(Order order) { // Try阶段 boolean paymentReserved = paymentService.reserve(order); boolean inventoryReserved = inventoryService.reserve(order); if (paymentReserved && inventoryReserved) { // Confirm阶段 paymentService.confirm(order); inventoryService.confirm(order); logisticsService.create(order); } else { // Cancel阶段 if (paymentReserved) paymentService.cancel(order); if (inventoryReserved) inventoryService.cancel(order); } }}
  1. 本地消息表+事件驱动：
public class EventDrivenMediator { @Transactional public void processOrder(Order order) { // 1. 本地事务 orderRepository.save(order); eventStore.save(new PaymentEvent(order)); // 2. 消息队列异步处理 eventPublisher.publish(new PaymentEvent(order)); } @EventListener public void handlePaymentSuccess(PaymentSuccessEvent event) { Order order = orderRepository.find(event.getOrderId()); eventStore.save(new InventoryEvent(order)); eventPublisher.publish(new InventoryEvent(order)); }}

在阿里电商系统中，我们采用混合方案：

  • 核心支付流程使用TCC保证强一致性
  • 非核心流程使用SAGA实现最终一致性
  • 异步通知使用本地消息表
  • 所有方案都实现幂等性和重试机制

四、中介者模式的高级应用

1. 反应式中介者

public class ReactiveMediator { private final PaymentService paymentService; private final InventoryService inventoryService; public Mono<OrderResult> processOrder(Order order) { return paymentService.process(order) .flatMap(paymentResult -> inventoryService.update(order)) .flatMap(inventoryResult -> logisticsService.create(order)) .onErrorResume(e -> compensation(order, e)); } private Mono<OrderResult> compensation(Order order, Throwable e) { // 补偿逻辑 }}

2. 智能路由中介者

public class SmartRouterMediator implements OrderMediator { private Map<OrderType, OrderProcessor> processors; @Override public void processOrder(Order order) { OrderProcessor processor = processors.get(order.getType()); if (processor == null) { processor = defaultProcessor; } processor.process(order); }}

3. 策略化中介者

public class StrategyMediator { private ProcessingStrategy strategy; public void setStrategy(ProcessingStrategy strategy) { this.strategy = strategy; } public void process(Order order) { strategy.process(order); }}public interface ProcessingStrategy { void process(Order order);}

五、性能优化与最佳实践

  1. 异步非阻塞设计：
public CompletableFuture<Void> processOrderAsync(Order order) { return CompletableFuture.runAsync(() -> processPayment(order)) .thenRunAsync(() -> updateInventory(order)) .thenRunAsync(() -> createLogistics(order));}
  1. 缓存优化：
public class CachingMediator { private Cache<Long, OrderContext> cache; public void processOrder(Order order) { OrderContext context = cache.get(order.getId(), () -> createContext(order)); // 使用缓存上下文处理 }}
  1. 批量处理：
public class BatchMediator { public void processBatch(List<Order> orders) { List<Payment> payments = preparePayments(orders); paymentService.batchProcess(payments); List<InventoryUpdate> updates = prepareInventoryUpdates(orders); inventoryService.batchUpdate(updates); }}

在阿里/字节跳动级别的系统中，中介者模式的这些优化可以带来：

  • 吞吐量提升5-10倍（通过异步处理）
  • 响应时间降低80%（通过缓存和批处理）
  • 系统可用性达到99.99%（通过熔断和降级）

六、总结

中介者模式在复杂业务系统中具有不可替代的价值，特别是在阿里/字节跳动这样的大型电商平台中：

  1. 核心价值：解耦复杂交互，集中控制逻辑
  2. 实现关键：平衡中介者职责，避免过度膨胀
  3. 高级技巧：结合反应式编程、SAGA模式等
  4. 性能优化：异步、缓存、批处理等手段

面试中，面试官通过中介者模式主要考察：

  • 复杂系统架构能力
  • 分布式事务处理经验
  • 性能优化意识
  • 设计模式灵活运用能力

建议开发者：

  1. 研究Spring Mediator等框架实现
  2. 在复杂业务流程中实践此模式
  3. 学习相关模式如外观模式、代理模式
  4. 关注领域驱动设计中的上下文映射
网络标签：

相关问题