Java基于中介者模式实现多人聊天室功能示例

2019-11-26 10:02:24

字体：大中小

来源：转载

供稿：网友

本文实例讲述了Java基于中介者模式实现多人聊天室功能。分享给大家供大家参考，具体如下：

一模式定义

中介者模式，用一个中介对象来封装一系列对象之间的交互，使各个对象中不需要显示地引用其他对象实例，从而降低各个对象之间的耦合度，并且可以独立地改变对象间的交互关系。

二模式举例

1 模式分析

我们借用多人聊天室来说明这一模式

2 中介模式静态类图

3 代码示例

3.1中介者接口――IMediator

package com.demo.mediator;import com.demo.colleague.IUser;/** * 中介者接口 * * @author * */public interface IMediator {  /**   * 注册用户信息   *   * @param user   */  public void regist(IUser user);  /**   * 发送消息给所有人   *   * @param user   *      发送消息人   */  public void notifyAllMessage(IUser user);}

3.2 中介者实现――ConcreteMediator

package com.demo.mediator;import java.util.ArrayList;import java.util.Iterator;import java.util.List;import com.demo.colleague.IUser;/** * 中介者实现类 * * @author * */public class ConcreteMediator implements IMediator {  private final List<IUser> list = new ArrayList<IUser>();  /**   * 注册用户信息   *   * @param user   */  public void regist(IUser user) {    if (user != null && !list.contains(user)) {      list.add(user);    }  }  /**   * 发送消息   *   * @param user   *      发送消息人   */  public void notifyAllMessage(IUser user) {    Iterator<IUser> iterator = list.iterator();    IUser tmpUser = null;    while (iterator.hasNext()) {      tmpUser = iterator.next();      if (tmpUser != null && !tmpUser.equals(user)) {        // 排除发送消息用户        tmpUser.receiveMessage(user.getMessage());      }    }  }}

3.3 用户接口――IUser

package com.demo.colleague;/** * 用户接口 * * @author * */public interface IUser{  /**   * 接收消息   *   * @param message   *      消息   */  public void receiveMessage(String message);  /**   * 发送消息   *   * @param message   *      消息   */  public void sendMessage(String message);  /**   * 获得发送的消息内容   *   * @return   */  public String getMessage();}

3.4 抽象用户――AbstractUser

package com.demo.colleague;import com.demo.mediator.IMediator;/** * 抽象用户信息 * * @author * */public abstract class AbstractUser implements IUser{  // 中介者  protected IMediator mediator;  // 姓名  protected String name;  // 消息  protected String message;  public AbstractUser(IMediator mediator, String name)  {    this.mediator = mediator;    this.name = name;  }  /**   * 发送消息   *   * @param message   *      消息   */  public void sendMessage(String message)  {    this.message = message;    System.out.println(this.name + " 说:" + this.message);    mediator.notifyAllMessage(this);  }  public String getMessage()  {    return message;  }}

3.5 用户A――UserA

package com.demo.colleague;import com.demo.mediator.IMediator;/** * 用户A * * @author * */public class UserA extends AbstractUser {  public UserA(IMediator mediator, String name) {    super(mediator, name);    // 注册到中介者对象中    mediator.regist(this);  }  /**   * 接收消息方法   */  public void receiveMessage(String message) {    System.out.println("User A Received Message : " + message);  }}

3.6 用户B――UserB

package com.demo.colleague;import com.demo.mediator.IMediator;/** * 用户B * * @author * */public class UserB extends AbstractUser {  public UserB(IMediator mediator, String name) {    super(mediator, name);    // 注册到中介者对象中    mediator.regist(this);  }  /**   * 接收消息方法   */  public void receiveMessage(String message) {    System.out.println("User B Received Message : " + message);  }}

3.7 用户C――UserC

package com.demo.colleague;import com.demo.mediator.IMediator;/** * 用户C * * @author * */public class UserC extends AbstractUser {  public UserC(IMediator mediator, String name) {    super(mediator, name);    // 注册到中介者对象中    mediator.regist(this);  }  /**   * 接收消息方法   */  public void receiveMessage(String message) {    System.out.println("User C Received Message : " + message);  }}

3.8 运行多人聊天室

package com.demo;import com.demo.colleague.IUser;import com.demo.colleague.UserA;import com.demo.colleague.UserB;import com.demo.colleague.UserC;import com.demo.mediator.ConcreteMediator;import com.demo.mediator.IMediator;/** * * 主应用程序 * * @author * */public class Client {  /**   * @param args   */  public static void main(String[] args) {    // 创建聊天室（中介者）    IMediator mediator = new ConcreteMediator();    // 创建用户信息    IUser userA = new UserA(mediator, "张三");    IUser userB = new UserB(mediator, "李四");    IUser userC = new UserC(mediator, "王五");    System.out        .println("============================================================");    userA.sendMessage("大家好，我叫张三！初来乍到，请多多关照！");    System.out        .println("============================================================/n");    System.out        .println("============================================================");    userB.sendMessage("你好，我叫李四，欢迎加入！");    System.out        .println("============================================================/n");    System.out        .println("============================================================");    userC.sendMessage("我是王五，欢迎欢迎！");    System.out        .println("============================================================/n");  }}

4 运行结果

============================================================
张三说:大家好，我叫张三！初来乍到，请多多关照！
User B Received Message : 大家好，我叫张三！初来乍到，请多多关照！
User C Received Message : 大家好，我叫张三！初来乍到，请多多关照！
============================================================
============================================================
李四说:你好，我叫李四，欢迎加入！
User A Received Message : 你好，我叫李四，欢迎加入！
User C Received Message : 你好，我叫李四，欢迎加入！
============================================================
============================================================
王五说:我是王五，欢迎欢迎！
User A Received Message : 我是王五，欢迎欢迎！
User B Received Message : 我是王五，欢迎欢迎！
============================================================

三该模式设计原则

1 一对多的对象依赖转化为一对一依赖
2 集中控制提高类的复用性

四使用场合

(1)一组对象以定义良好但复杂的方式进行通信，产生相互依赖关系结构混乱且难以理解。注意多个对象之间的相互依赖。
(2)想定制一个分布在多个类的行为，而不想生成太多的子类场合。
(3)产品架构的研发，更需要易于扩展的场合。

五中介模式静态类图