您的位置:首页 > 产品设计 > UI/UE

QuickServer开发指南(5)- 客户数据

2007-05-15 09:57 387 查看
既然不能在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

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: