既然不能在ClientCommandHandler和ServerAuthenticator类中保存客户数据,我们使用ClientData类的handleCommand()或askAuthorisation()方法来存储所有的客户端信息。 示范一下这个特点有什么用。还是以EchoServer为例,当用户发送"Hello"时,我们给他一个问候。如果用户再发送"Hello",我们提醒他已经发了n次"Hello"。接下来定义ClientData类来存储用户名以及他向服务器发送"Hello"的次数。
1. 代码 1. 在EchoServer中创建一个EchoServerData类
[align=left]01 //---- EchoServerData.java ----[/align] [align=left]02 package echoserver;[/align] [align=left]03[/align] [align=left]04 import org.quickserver.net.server.*;[/align] [align=left]05 import java.io.*;[/align] [align=left]06 [/align] [align=left]07 public class EchoServerData implements ClientData {[/align] [align=left]08 private int helloCount;[/align] [align=left]09 private String username;[/align] [align=left]10[/align] [align=left]11 public void setHelloCount(int count) {[/align] [align=left]12 helloCount = count;[/align] [align=left]13 }[/align] [align=left]14 public int getHelloCount() {[/align] [align=left]15 return helloCount;[/align] [align=left]16 }[/align] [align=left]17[/align] [align=left]18 public void setUsername(String username) {[/align] [align=left]19 this.username = username;[/align] [align=left]20 }[/align] [align=left]21 public String getUsername() {[/align] [align=left]22 return username;[/align] [align=left]23 }[/align] [align=left]24 }[/align] [align=left]25 //--- end of code ---[/align]
| 2. 告诉QuickServer用这个EchoServerData来做为它的ClientData类。 修改前面创建的EchoServer.java,代码如下:
[align=left]01 package echoserver;[/align] [align=left]02[/align] [align=left]03 import org.quickserver.net.*;[/align] [align=left]04 import org.quickserver.net.server.*;[/align] [align=left]05[/align] [align=left]06 import java.io.*;[/align] [align=left]07[/align] [align=left]08 public class EchoServer {[/align] [align=left]09 public static void main(String s[]) {[/align] [align=left]10[/align] [align=left]11 String cmd = "echoserver.EchoCommandHandler";[/align] [align=left]12 String auth = "echoserver.EchoServerQuickAuthenticator";[/align] [align=left]13 String data = "echoserver.EchoServerData";[/align] [align=left]14[/align] [align=left]15 QuickServer myServer = new QuickServer(cmd);[/align] [align=left]16 myServer.setAuthenticator(auth);[/align] [align=left]17 myServer.setClientData(data);[/align] [align=left]18[/align] [align=left]19 myServer.setPort(4123);[/align] [align=left]20 myServer.setName("Echo Server v 1.0");[/align] [align=left]21 try {[/align] [align=left]22 myServer.startServer();[/align] [align=left]23 } catch(AppException e){ [/align] [align=left]24 System.out.println("Error in server : "+e);[/align] [align=left]25 }[/align] [align=left]26 }[/align] [align=left]27 }[/align]
| 上面的代码中,我们将配置信息写入String对象来设置QuickServer。
3. 修改Authenticator类,也就是EchoServerAuthenticator类,让它在ClientData对象中存储用户名。下面是修改后的代码:
[align=left]01 package echoserver;[/align] [align=left]02[/align] [align=left]03 import org.quickserver.net.server.*;[/align] [align=left]04 import java.io.*;[/align] [align=left]05[/align] [align=left]06 public class EchoServerQuickAuthenticator extends QuickAuthenticator {[/align] [align=left]07[/align] [align=left]08 public boolean askAuthorisation(ClientHandler clientHandler)[/align] [align=left]09 throws IOException {[/align] [align=left]10 String username = askStringInput(clientHandler, "User Name :");[/align] [align=left]11 if(username!=null && username.equalsIgnoreCase("QUIT")) {[/align] [align=left]12 sendString(clientHandler, "Logged out.");[/align] [align=left]13 //close the connection[/align] [align=left]14 clientHandler.closeConnection();[/align] [align=left]15 return false;[/align] [align=left]16 }[/align] [align=left]17[/align] [align=left]18 String password = askStringInput(clientHandler, "Password :");[/align] [align=left]19[/align] [align=left]20 if(username==null || password ==null)[/align] [align=left]21 return false;[/align] [align=left]22[/align] [align=left]23 if(username.equals(password)) {[/align] [align=left]24 sendString(clientHandler, "Auth OK");[/align] [align=left]25 //store the username in ClientData[/align] [align=left]26 EchoServerData data = (EchoServerData)clientHandler.getClientData();[/align] [align=left]27 data.setUsername(username);[/align] [align=left]28 return true;[/align] [align=left]29 } else {[/align] [align=left]30 sendString(clientHandler, "Auth Failed");[/align] [align=left]31 return false;[/align] [align=left]32 }[/align] [align=left]33 }[/align] 34 } | 4. 修改ClientCommandHandler实现类EchoCommandHandler。如果用户发送"Hello",给他一个问候。如果他发送多次"Hello",告诉他已经发送了n次"Hello"。下面是修改后的代码:
[align=left]01 // EchoCommandHandler.java[/align] [align=left]02 package echoserver;[/align] [align=left]03[/align] [align=left]04 import java.net.*;[/align] [align=left]05 import java.io.*;[/align] [align=left]06 import org.quickserver.net.server.ClientCommandHandler;[/align] [align=left]07 import org.quickserver.net.server.ClientHandler;[/align] [align=left]08[/align] [align=left]09 public class EchoCommandHandler implements ClientCommandHandler {[/align] [align=left]10[/align] [align=left]11 public void gotConnected(ClientHandler handler)[/align] [align=left]12 throws SocketTimeoutException, IOException {[/align] [align=left]13 handler.sendClientMsg("+++++++++++++++++++++++++++++++");[/align] [align=left]14 handler.sendClientMsg("| Welcome to EchoServer v 1.0 |");[/align] [align=left]15 handler.sendClientMsg("| Note: Password = Username |");[/align] [align=left]16 handler.sendClientMsg("| Send 'Quit' to exit |");[/align] [align=left]17 handler.sendClientMsg("+++++++++++++++++++++++++++++++");[/align] [align=left]18 }[/align] [align=left]19 public void lostConnection(ClientHandler handler)[/align] [align=left]20 throws IOException {[/align] [align=left]21 handler.sendSystemMsg("Connection lost : " +[/align] [align=left]22 handler.getSocket().getInetAddress());[/align] [align=left]23 }[/align] [align=left]24 public void closingConnection(ClientHandler handler)[/align] [align=left]25 throws IOException {[/align] [align=left]26 handler.sendSystemMsg("Closing connection : " +[/align] [align=left]27 handler.getSocket().getInetAddress());[/align] [align=left]28 }[/align] [align=left]29[/align] [align=left]30 public void handleCommand(ClientHandler handler, String command)[/align] [align=left]31 throws SocketTimeoutException, IOException {[/align] [align=left]32 if(command.equals("Quit")) {[/align] [align=left]33 handler.sendClientMsg("Bye ;-)");[/align] [align=left]34 handler.closeConnection();[/align] [align=left]35 } if(command.equalsIgnoreCase("hello")) {[/align] [align=left]36 EchoServerData data = (EchoServerData) handler.getClientData();[/align] [align=left]37 data.setHelloCount(data.getHelloCount()+1);[/align] [align=left]38 if(data.getHelloCount()==1) {[/align] [align=left]39 handler.sendClientMsg("Hello "+data.getUsername());[/align] [align=left]40 } else {[/align] [align=left]41 handler.sendClientMsg("You told Hello "+data.getHelloCount()+ [/align] [align=left]42 " times. ");[/align] [align=left]43 }[/align] [align=left]44 } else {[/align] [align=left]45 handler.sendClientMsg("Echo : "+command);[/align] [align=left]46 }[/align] [align=left]47 }[/align] [align=left]48 }[/align]
| 5. 编译改好的程序,运行,使用SocketTest测试。登录后,发送"Hello",系统会给一个问候,再次发送"Hello",它将告诉你发送了多少次"Hello"。
4.2 创建ClientData池
现在我们知道ClientData可以正常工作了。但是对每一个连接QuickServer的客户端都要创建一个新的ClientData对象,可能会造成性能上的瓶颈,尤其对性能要求较高的服务器来说。 我们可以创建一个ClientData池对象,无论客户端什么时候进行连接,都使用同一个对象。首先实现下面的接口: org.quickserver.util.pool.PoolableObject 查找QuickServer API文档可以发现PoolableObject只有两个必须实现的方法: org.apache.commons.pool.PoolableObjectFactory属于通常的工厂方法。 isPoolable()判断对象是否可以成为池对象。
PoolableObjectFactory org.apache.commons.pool.PoolableObjectFactory接口包含了以下方法: o void activateObject(Object obj):重新初始化一个实例。 o void destroyObject(Object obj):销毁一个不再需要的实例。 o Object makeObject():创建一个实例。 o void passivateObject(Object obj):禁止初始化一个实例。 o boolean validateObject(Object obj):确定一个实例是否安全。
我们可以扩展一个基于无操作的实现来创建可"池"化的对象: org.apache.commons.pool.BasePoolableObjectFactory 这个类只有一个抽象方法makeObject()和一个validateObject()方法,它只返回true。 我们来创建一个EchoServerPoolableData类。
[align=left]01 //---- EchoServerPoolableData.java ----[/align] [align=left]02 package echoserver;[/align] [align=left]03[/align] [align=left]04 import org.quickserver.net.server.*;[/align] [align=left]05 import java.io.*;[/align] [align=left]06[/align] [align=left]07 public class EchoServerPoolableData[/align] [align=left]08 extends EchoServerData[/align] [align=left]09 implements org.apache.commons.pool.PoolableObjectFactory {[/align] [align=left]10[/align] [align=left]11 public void activateObject(Object obj) {[/align] [align=left]12 }[/align] [align=left]13 public void destroyObject(Object obj) {[/align] [align=left]14 if(obj==null) return;[/align] [align=left]15 passivateObject(obj);[/align] [align=left]16 obj = null;[/align] [align=left]17 }[/align] [align=left]18 public Object makeObject() {[/align] [align=left]19 return new EchoServerPoolableData();[/align] [align=left]20 }[/align] [align=left]21 public void passivateObject(Object obj) {[/align] [align=left]22 EchoServerPoolableData pd = (EchoServerPoolableData)obj;[/align] [align=left]23 pd.setHelloCount(0);[/align] [align=left]24 pd.setUsername(null);[/align] [align=left]25 }[/align] [align=left]26 public boolean validateObject(Object obj) {[/align] [align=left]27 if(obj==null)[/align] [align=left]28 return false;[/align] [align=left]29 else[/align] [align=left]30 return true [/align]
| 原文地址 http://tb.blog.csdn.net/TrackBack.aspx?PostId=301736 | |
|
|
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理