1. 中介者模式解耦对象交互的利器中介者模式Mediator Pattern是23种经典设计模式中行为型模式的一种它通过引入一个中介对象来封装一系列对象之间的交互。想象一下机场的塔台控制系统——如果没有塔台调度所有飞机都需要直接相互通信来确定起降顺序那将是一场灾难。中介者模式正是为了解决这种多对多复杂交互场景而生的。在实际开发中当系统出现网状结构依赖时比如一个聊天室中有多个用户相互发消息使用中介者模式可以将这些交互关系集中管理。这不仅降低了对象间的耦合度还使得交互逻辑更容易被理解和修改。作为Java开发者掌握这个模式能让你在面对复杂交互系统时游刃有余。2. 模式结构与核心思想2.1 UML类图解析中介者模式的标准UML类图包含以下核心角色[同事类A] —— [中介者接口] —— [同事类B] ^ | [具体中介者实现]Mediator抽象中介者定义同事对象到中介者对象的接口ConcreteMediator具体中介者实现协调各同事对象的逻辑Colleague同事类每个同事对象都知道它的中介者对象2.2 模式运作原理中介者模式的核心在于集中控制。所有同事对象不再直接相互引用而是通过中介者进行间接通信。当某个同事对象状态改变时它会通知中介者由中介者决定如何影响其他同事对象。这种设计带来了几个显著优势将网状结构变为星型结构降低系统复杂度减少子类生成因为中介者封装了原本分散在各个对象中的行为简化各同事类的实现使其更专注于自身职责3. Java代码实现详解3.1 基础实现示例让我们通过一个聊天室案例来具体实现中介者模式// 抽象中介者 interface ChatMediator { void sendMessage(String msg, User user); void addUser(User user); } // 具体中介者 class ChatMediatorImpl implements ChatMediator { private ListUser users; public ChatMediatorImpl() { this.users new ArrayList(); } Override public void sendMessage(String msg, User user) { for(User u : this.users) { // 不发送给消息发起者 if(u ! user) { u.receive(msg); } } } Override public void addUser(User user) { this.users.add(user); } } // 抽象同事类 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); } // 具体同事类 class UserImpl extends User { public UserImpl(ChatMediator med, String name) { super(med, name); } Override public void send(String msg) { System.out.println(this.name 发送消息: msg); mediator.sendMessage(msg, this); } Override public void receive(String msg) { System.out.println(this.name 收到消息: msg); } }3.2 客户端使用示例public class Client { public static void main(String[] args) { ChatMediator mediator new ChatMediatorImpl(); User user1 new UserImpl(mediator, 张三); User user2 new UserImpl(mediator, 李四); User user3 new UserImpl(mediator, 王五); mediator.addUser(user1); mediator.addUser(user2); mediator.addUser(user3); user1.send(大家好); user2.send(欢迎新人); } }输出结果张三 发送消息: 大家好 李四 收到消息: 大家好 王五 收到消息: 大家好 李四 发送消息: 欢迎新人 张三 收到消息: 欢迎新人 王五 收到消息: 欢迎新人4. 模式应用场景与实战技巧4.1 典型应用场景中介者模式特别适用于以下场景系统中对象之间存在复杂的引用关系导致系统结构混乱且难以理解想通过中间类来封装多个类中的行为又不想生成太多子类需要更灵活地控制对象间的交互而不是硬编码在对象内部实际开发中的常见应用包括GUI系统中的对话框控件交互消息队列系统中的消息分发游戏开发中的角色交互系统企业应用中的工作流引擎4.2 实战优化技巧中介者复杂度控制当中介者变得过于复杂时可以考虑将其拆分为多个子中介者形成分层结构异步通信实现对于需要异步处理的场景可以让中介者维护一个任务队列class AsyncMediator implements ChatMediator { private ExecutorService executor Executors.newFixedThreadPool(4); Override public void sendMessage(String msg, User user) { executor.submit(() - { // 异步处理消息 for(User u : users) { if(u ! user) { u.receive(msg); } } }); } }中介者与观察者模式结合可以使用观察者模式来实现中介者与同事对象之间的通知机制5. 模式对比与常见误区5.1 与其他模式的比较模式关注点耦合度适用场景中介者对象间交互低复杂交互系统观察者状态变化通知中一对多依赖关系外观子系统简化接口低简化复杂子系统5.2 常见实现误区过度使用中介者不是所有对象交互都需要中介者简单的直接引用可能更合适中介者变成上帝对象中介者不应知道太多业务逻辑否则会变得难以维护忽略线程安全问题在多线程环境下中介者需要正确处理并发访问// 线程安全的中介者实现 class ThreadSafeMediator implements ChatMediator { private final ListUser users new CopyOnWriteArrayList(); Override public synchronized void addUser(User user) { users.add(user); } Override public void sendMessage(String msg, User user) { users.stream() .filter(u - u ! user) .forEach(u - u.receive(msg)); } }6. 性能考量与扩展思考6.1 性能优化方向消息过滤机制为中介者添加消息路由功能避免广播所有消息interface AdvancedMediator extends ChatMediator { void sendTo(String msg, User sender, String targetType); } class RoleBasedMediator implements AdvancedMediator { private MapString, ListUser roleGroups new HashMap(); Override public void sendTo(String msg, User sender, String targetRole) { roleGroups.getOrDefault(targetRole, Collections.emptyList()) .stream() .filter(u - u ! sender) .forEach(u - u.receive(msg)); } }缓存机制对于频繁交互的对象可以缓存部分交互结果6.2 模式扩展思路中介者链类似责任链模式让多个中介者协同工作动态中介者运行时根据条件切换不同的中介者实现分布式中介者在微服务架构中中介者可以作为独立的服务存在// 分布式中介者的伪代码示例 RestController class DistributedMediator { PostMapping(/send) public void sendMessage(RequestBody MessageDTO message) { // 调用其他服务处理消息 notificationService.notifyUsers(message); } }7. 测试与调试技巧7.1 单元测试策略测试中介者模式时需要关注中介者是否正确转发消息同事对象是否正确注册到中介者消息过滤和路由逻辑是否正确class MediatorTest { Test void testMessageBroadcast() { ChatMediator mediator new ChatMediatorImpl(); TestUser user1 new TestUser(mediator, User1); TestUser user2 new TestUser(mediator, User2); mediator.addUser(user1); mediator.addUser(user2); user1.send(Hello); assertEquals(Hello, user2.lastReceivedMessage); } } class TestUser extends User { String lastReceivedMessage; public TestUser(ChatMediator med, String name) { super(med, name); } Override public void receive(String msg) { this.lastReceivedMessage msg; } }7.2 调试技巧在中介者中添加日志记录所有交互使用拦截器模式监控消息流可视化中介者的交互拓扑结构8. 实际项目案例解析8.1 电商系统中的订单处理在一个电商系统中订单创建会触发库存扣减、支付处理、物流通知等多个操作。使用中介者模式可以很好地组织这些交互class OrderMediator { private InventoryService inventory; private PaymentService payment; private LogisticsService logistics; public void placeOrder(Order order) { // 检查库存 if(!inventory.checkStock(order)) { throw new RuntimeException(库存不足); } // 处理支付 PaymentResult result payment.process(order); if(!result.isSuccess()) { throw new RuntimeException(支付失败); } // 通知物流 logistics.scheduleDelivery(order); // 更新库存 inventory.updateStock(order); } }8.2 游戏开发中的事件系统游戏中的角色、道具、场景等对象之间经常需要交互。中介者模式可以管理这些复杂的交互关系class GameEventMediator { private Player player; private ListEnemy enemies; private Environment environment; public void playerAttacked(AttackEvent event) { // 计算伤害 double damage calculateDamage(event); // 应用伤害 event.getTarget().takeDamage(damage); // 触发环境效果 if(environment.isBloody()) { addBloodEffect(event.getPosition()); } // 通知其他敌人 enemies.stream() .filter(e - e ! event.getTarget()) .forEach(e - e.onAllyDamaged(event)); } }9. 设计模式组合应用中介者模式常与其他模式配合使用形成更强大的解决方案9.1 中介者观察者// 观察者接口 interface EventListener { void onEvent(String event); } // 观察者模式的中介者 class ObservableMediator { private ListEventListener listeners new ArrayList(); public void addListener(EventListener listener) { listeners.add(listener); } public void notifyAll(String event) { listeners.forEach(l - l.onEvent(event)); } }9.2 中介者命令模式// 命令接口 interface Command { void execute(); } // 命令模式的中介者 class CommandMediator { private MapString, Command commands new HashMap(); public void registerCommand(String name, Command cmd) { commands.put(name, cmd); } public void executeCommand(String name) { Command cmd commands.get(name); if(cmd ! null) { cmd.execute(); } } }10. 代码质量与重构建议10.1 重构为中介者模式的时机当发现以下代码异味时考虑引入中介者模式类中有大量对其他对象的直接引用修改一个对象需要同时修改多个相关对象对象间的交互逻辑分散在各个类中10.2 中介者接口设计原则单一职责一个中介者应该只负责一组相关的交互接口隔离不要强迫同事类依赖它们不需要的方法依赖倒置同事类应该依赖抽象中介者而不是具体实现// 好的中介者接口设计 interface OrderProcessingMediator { void processOrder(Order order); void cancelOrder(Order order); } // 不好的设计 - 包含不相关方法 interface BadMediator { void processOrder(Order order); void cancelOrder(Order order); void sendMarketingEmail(Customer customer); // 不相关职责 }11. 框架中的中介者模式实现许多流行框架中都使用了中介者模式的变体11.1 Spring框架中的应用Spring的事件机制本质上是中介者模式的实现// 定义事件 class OrderEvent extends ApplicationEvent { public OrderEvent(Object source) { super(source); } } // 事件发布者(同事类) Service class OrderService { Autowired private ApplicationEventPublisher publisher; public void placeOrder(Order order) { // 业务逻辑... publisher.publishEvent(new OrderEvent(this)); } } // 事件监听器(同事类) Component class InventoryListener { EventListener public void handleOrderEvent(OrderEvent event) { // 处理库存更新 } }11.2 Java Message Service (JMS)JMS的消息模型也是中介者模式的典型应用// 消息生产者 MessageProducer producer session.createProducer(destination); producer.send(message); // 消息消费者 MessageConsumer consumer session.createConsumer(destination); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { // 处理消息 } });12. 反模式与过度设计警示虽然中介者模式很强大但也要警惕以下反模式万能中介者一个中介者类包含所有可能的交互逻辑变得臃肿难维护中介者循环依赖中介者知道所有同事类同事类又知道中介者形成双向依赖性能瓶颈所有交互都通过单一中介者可能成为系统瓶颈避免这些问题的建议按业务领域划分多个中介者使用接口隔离不同类别的交互考虑异步和非阻塞的实现方式13. 现代Java中的实现演进随着Java语言的发展中介者模式有了更多现代实现方式13.1 使用Lambda表达式class LambdaMediator { private MapString, ConsumerString handlers new HashMap(); public void registerHandler(String eventType, ConsumerString handler) { handlers.put(eventType, handler); } public void sendEvent(String eventType, String data) { ConsumerString handler handlers.get(eventType); if(handler ! null) { handler.accept(data); } } }13.2 响应式编程风格使用Reactive Streams实现中介者class ReactiveMediator { private final MapString, ProcessorString, String processors new ConcurrentHashMap(); public FluxString registerChannel(String channelId) { DirectProcessorString processor DirectProcessor.create(); processors.put(channelId, processor); return processor; } public void sendToChannel(String channelId, String message) { ProcessorString, String processor processors.get(channelId); if(processor ! null) { processor.onNext(message); } } }14. 设计模式在微服务架构中的变体在微服务架构中中介者模式演变为以下形态API网关作为服务间交互的中介者消息代理如Kafka、RabbitMQ等服务网格如Istio中的Sidecar代理这些现代架构组件本质上都是中介者模式在分布式系统中的体现。15. 中介者模式的替代方案当中介者模式不适用时可以考虑观察者模式适用于一对多的通知场景责任链模式适用于需要按顺序处理请求的场景命令模式适用于需要封装请求为对象的场景选择依据主要取决于交互的复杂度和变化频率。中介者模式最适合管理复杂的多对多交互关系。 Java中介者模式：解耦复杂对象交互的设计实践
1. 中介者模式解耦对象交互的利器中介者模式Mediator Pattern是23种经典设计模式中行为型模式的一种它通过引入一个中介对象来封装一系列对象之间的交互。想象一下机场的塔台控制系统——如果没有塔台调度所有飞机都需要直接相互通信来确定起降顺序那将是一场灾难。中介者模式正是为了解决这种多对多复杂交互场景而生的。在实际开发中当系统出现网状结构依赖时比如一个聊天室中有多个用户相互发消息使用中介者模式可以将这些交互关系集中管理。这不仅降低了对象间的耦合度还使得交互逻辑更容易被理解和修改。作为Java开发者掌握这个模式能让你在面对复杂交互系统时游刃有余。2. 模式结构与核心思想2.1 UML类图解析中介者模式的标准UML类图包含以下核心角色[同事类A] —— [中介者接口] —— [同事类B] ^ | [具体中介者实现]Mediator抽象中介者定义同事对象到中介者对象的接口ConcreteMediator具体中介者实现协调各同事对象的逻辑Colleague同事类每个同事对象都知道它的中介者对象2.2 模式运作原理中介者模式的核心在于集中控制。所有同事对象不再直接相互引用而是通过中介者进行间接通信。当某个同事对象状态改变时它会通知中介者由中介者决定如何影响其他同事对象。这种设计带来了几个显著优势将网状结构变为星型结构降低系统复杂度减少子类生成因为中介者封装了原本分散在各个对象中的行为简化各同事类的实现使其更专注于自身职责3. Java代码实现详解3.1 基础实现示例让我们通过一个聊天室案例来具体实现中介者模式// 抽象中介者 interface ChatMediator { void sendMessage(String msg, User user); void addUser(User user); } // 具体中介者 class ChatMediatorImpl implements ChatMediator { private ListUser users; public ChatMediatorImpl() { this.users new ArrayList(); } Override public void sendMessage(String msg, User user) { for(User u : this.users) { // 不发送给消息发起者 if(u ! user) { u.receive(msg); } } } Override public void addUser(User user) { this.users.add(user); } } // 抽象同事类 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); } // 具体同事类 class UserImpl extends User { public UserImpl(ChatMediator med, String name) { super(med, name); } Override public void send(String msg) { System.out.println(this.name 发送消息: msg); mediator.sendMessage(msg, this); } Override public void receive(String msg) { System.out.println(this.name 收到消息: msg); } }3.2 客户端使用示例public class Client { public static void main(String[] args) { ChatMediator mediator new ChatMediatorImpl(); User user1 new UserImpl(mediator, 张三); User user2 new UserImpl(mediator, 李四); User user3 new UserImpl(mediator, 王五); mediator.addUser(user1); mediator.addUser(user2); mediator.addUser(user3); user1.send(大家好); user2.send(欢迎新人); } }输出结果张三 发送消息: 大家好 李四 收到消息: 大家好 王五 收到消息: 大家好 李四 发送消息: 欢迎新人 张三 收到消息: 欢迎新人 王五 收到消息: 欢迎新人4. 模式应用场景与实战技巧4.1 典型应用场景中介者模式特别适用于以下场景系统中对象之间存在复杂的引用关系导致系统结构混乱且难以理解想通过中间类来封装多个类中的行为又不想生成太多子类需要更灵活地控制对象间的交互而不是硬编码在对象内部实际开发中的常见应用包括GUI系统中的对话框控件交互消息队列系统中的消息分发游戏开发中的角色交互系统企业应用中的工作流引擎4.2 实战优化技巧中介者复杂度控制当中介者变得过于复杂时可以考虑将其拆分为多个子中介者形成分层结构异步通信实现对于需要异步处理的场景可以让中介者维护一个任务队列class AsyncMediator implements ChatMediator { private ExecutorService executor Executors.newFixedThreadPool(4); Override public void sendMessage(String msg, User user) { executor.submit(() - { // 异步处理消息 for(User u : users) { if(u ! user) { u.receive(msg); } } }); } }中介者与观察者模式结合可以使用观察者模式来实现中介者与同事对象之间的通知机制5. 模式对比与常见误区5.1 与其他模式的比较模式关注点耦合度适用场景中介者对象间交互低复杂交互系统观察者状态变化通知中一对多依赖关系外观子系统简化接口低简化复杂子系统5.2 常见实现误区过度使用中介者不是所有对象交互都需要中介者简单的直接引用可能更合适中介者变成上帝对象中介者不应知道太多业务逻辑否则会变得难以维护忽略线程安全问题在多线程环境下中介者需要正确处理并发访问// 线程安全的中介者实现 class ThreadSafeMediator implements ChatMediator { private final ListUser users new CopyOnWriteArrayList(); Override public synchronized void addUser(User user) { users.add(user); } Override public void sendMessage(String msg, User user) { users.stream() .filter(u - u ! user) .forEach(u - u.receive(msg)); } }6. 性能考量与扩展思考6.1 性能优化方向消息过滤机制为中介者添加消息路由功能避免广播所有消息interface AdvancedMediator extends ChatMediator { void sendTo(String msg, User sender, String targetType); } class RoleBasedMediator implements AdvancedMediator { private MapString, ListUser roleGroups new HashMap(); Override public void sendTo(String msg, User sender, String targetRole) { roleGroups.getOrDefault(targetRole, Collections.emptyList()) .stream() .filter(u - u ! sender) .forEach(u - u.receive(msg)); } }缓存机制对于频繁交互的对象可以缓存部分交互结果6.2 模式扩展思路中介者链类似责任链模式让多个中介者协同工作动态中介者运行时根据条件切换不同的中介者实现分布式中介者在微服务架构中中介者可以作为独立的服务存在// 分布式中介者的伪代码示例 RestController class DistributedMediator { PostMapping(/send) public void sendMessage(RequestBody MessageDTO message) { // 调用其他服务处理消息 notificationService.notifyUsers(message); } }7. 测试与调试技巧7.1 单元测试策略测试中介者模式时需要关注中介者是否正确转发消息同事对象是否正确注册到中介者消息过滤和路由逻辑是否正确class MediatorTest { Test void testMessageBroadcast() { ChatMediator mediator new ChatMediatorImpl(); TestUser user1 new TestUser(mediator, User1); TestUser user2 new TestUser(mediator, User2); mediator.addUser(user1); mediator.addUser(user2); user1.send(Hello); assertEquals(Hello, user2.lastReceivedMessage); } } class TestUser extends User { String lastReceivedMessage; public TestUser(ChatMediator med, String name) { super(med, name); } Override public void receive(String msg) { this.lastReceivedMessage msg; } }7.2 调试技巧在中介者中添加日志记录所有交互使用拦截器模式监控消息流可视化中介者的交互拓扑结构8. 实际项目案例解析8.1 电商系统中的订单处理在一个电商系统中订单创建会触发库存扣减、支付处理、物流通知等多个操作。使用中介者模式可以很好地组织这些交互class OrderMediator { private InventoryService inventory; private PaymentService payment; private LogisticsService logistics; public void placeOrder(Order order) { // 检查库存 if(!inventory.checkStock(order)) { throw new RuntimeException(库存不足); } // 处理支付 PaymentResult result payment.process(order); if(!result.isSuccess()) { throw new RuntimeException(支付失败); } // 通知物流 logistics.scheduleDelivery(order); // 更新库存 inventory.updateStock(order); } }8.2 游戏开发中的事件系统游戏中的角色、道具、场景等对象之间经常需要交互。中介者模式可以管理这些复杂的交互关系class GameEventMediator { private Player player; private ListEnemy enemies; private Environment environment; public void playerAttacked(AttackEvent event) { // 计算伤害 double damage calculateDamage(event); // 应用伤害 event.getTarget().takeDamage(damage); // 触发环境效果 if(environment.isBloody()) { addBloodEffect(event.getPosition()); } // 通知其他敌人 enemies.stream() .filter(e - e ! event.getTarget()) .forEach(e - e.onAllyDamaged(event)); } }9. 设计模式组合应用中介者模式常与其他模式配合使用形成更强大的解决方案9.1 中介者观察者// 观察者接口 interface EventListener { void onEvent(String event); } // 观察者模式的中介者 class ObservableMediator { private ListEventListener listeners new ArrayList(); public void addListener(EventListener listener) { listeners.add(listener); } public void notifyAll(String event) { listeners.forEach(l - l.onEvent(event)); } }9.2 中介者命令模式// 命令接口 interface Command { void execute(); } // 命令模式的中介者 class CommandMediator { private MapString, Command commands new HashMap(); public void registerCommand(String name, Command cmd) { commands.put(name, cmd); } public void executeCommand(String name) { Command cmd commands.get(name); if(cmd ! null) { cmd.execute(); } } }10. 代码质量与重构建议10.1 重构为中介者模式的时机当发现以下代码异味时考虑引入中介者模式类中有大量对其他对象的直接引用修改一个对象需要同时修改多个相关对象对象间的交互逻辑分散在各个类中10.2 中介者接口设计原则单一职责一个中介者应该只负责一组相关的交互接口隔离不要强迫同事类依赖它们不需要的方法依赖倒置同事类应该依赖抽象中介者而不是具体实现// 好的中介者接口设计 interface OrderProcessingMediator { void processOrder(Order order); void cancelOrder(Order order); } // 不好的设计 - 包含不相关方法 interface BadMediator { void processOrder(Order order); void cancelOrder(Order order); void sendMarketingEmail(Customer customer); // 不相关职责 }11. 框架中的中介者模式实现许多流行框架中都使用了中介者模式的变体11.1 Spring框架中的应用Spring的事件机制本质上是中介者模式的实现// 定义事件 class OrderEvent extends ApplicationEvent { public OrderEvent(Object source) { super(source); } } // 事件发布者(同事类) Service class OrderService { Autowired private ApplicationEventPublisher publisher; public void placeOrder(Order order) { // 业务逻辑... publisher.publishEvent(new OrderEvent(this)); } } // 事件监听器(同事类) Component class InventoryListener { EventListener public void handleOrderEvent(OrderEvent event) { // 处理库存更新 } }11.2 Java Message Service (JMS)JMS的消息模型也是中介者模式的典型应用// 消息生产者 MessageProducer producer session.createProducer(destination); producer.send(message); // 消息消费者 MessageConsumer consumer session.createConsumer(destination); consumer.setMessageListener(new MessageListener() { public void onMessage(Message message) { // 处理消息 } });12. 反模式与过度设计警示虽然中介者模式很强大但也要警惕以下反模式万能中介者一个中介者类包含所有可能的交互逻辑变得臃肿难维护中介者循环依赖中介者知道所有同事类同事类又知道中介者形成双向依赖性能瓶颈所有交互都通过单一中介者可能成为系统瓶颈避免这些问题的建议按业务领域划分多个中介者使用接口隔离不同类别的交互考虑异步和非阻塞的实现方式13. 现代Java中的实现演进随着Java语言的发展中介者模式有了更多现代实现方式13.1 使用Lambda表达式class LambdaMediator { private MapString, ConsumerString handlers new HashMap(); public void registerHandler(String eventType, ConsumerString handler) { handlers.put(eventType, handler); } public void sendEvent(String eventType, String data) { ConsumerString handler handlers.get(eventType); if(handler ! null) { handler.accept(data); } } }13.2 响应式编程风格使用Reactive Streams实现中介者class ReactiveMediator { private final MapString, ProcessorString, String processors new ConcurrentHashMap(); public FluxString registerChannel(String channelId) { DirectProcessorString processor DirectProcessor.create(); processors.put(channelId, processor); return processor; } public void sendToChannel(String channelId, String message) { ProcessorString, String processor processors.get(channelId); if(processor ! null) { processor.onNext(message); } } }14. 设计模式在微服务架构中的变体在微服务架构中中介者模式演变为以下形态API网关作为服务间交互的中介者消息代理如Kafka、RabbitMQ等服务网格如Istio中的Sidecar代理这些现代架构组件本质上都是中介者模式在分布式系统中的体现。15. 中介者模式的替代方案当中介者模式不适用时可以考虑观察者模式适用于一对多的通知场景责任链模式适用于需要按顺序处理请求的场景命令模式适用于需要封装请求为对象的场景选择依据主要取决于交互的复杂度和变化频率。中介者模式最适合管理复杂的多对多交互关系。