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

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

本文实例讲述了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 list = new ArrayList();

/**

* 注册用户信息

*

* @param user

*/

public void regist(IUser user) {

if (user != null && !list.contains(user)) {

list.add(user);

}

}

/**

* 发送消息

*

* @param user

* 发送消息人

*/

public void notifyAllMessage(IUser user) {

Iterator 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);

}

/**

*GumQR 接收消息方法

*/

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 =http:// 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)产品架构的研发，更需要易于扩展的场合。

五 中介模式静态类图

更多java相关内容感兴趣的读者可查看本站专题：《Java面向对象程序设计入门与进阶教程》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。