原贴地址
http://blog.csdn.net/clearwater21cn/category/99145.aspxQuickServer开发指南(1)- 介绍 QuickServer是一个免费的开源Java库,用于快速创建健壮的多线程、多客户端TCP服务器应用程序。使用QuickServer,用户可以只集中处理应用程序的逻辑/协议,从而方便的建立功能强大的服务器应用。该程序由Akshathkumar Shetty设计和实现。
QuickServer安装目录下的example中有演示其功能的例子,最新的例子和文档可以通过网站
http://www.quickserver.org或
http://quickserver.sourceforge.net获得。
该指南适用于所有想要学习和使用QuickServer的人,阅读该指南应具备基本的Java编程知识,基本的网络和sockets方面的知识也会有所帮助
1. 为什么需要QuickServer? 无论何种编程语言,socket编程对程序员来说都不是一件容易的事,创建多线程、多客户端的服务器socket更像一场恶梦了。在每个新的软件中处理多socket连接,我们都要浪费大把时间编写大量重复的代码。QuickServer因而诞生——使用Java创建多线程、多客户端服务器应用。
2. 基本构造
QuickServer在应用逻辑上为开发者提供了四个类
o ClientCommandHandler
处理与客户端的交互——使用字符串命令
o ClientObjectHandler [可选类]
处理与客户端的交互——使用对象命令
o Authenticator [可选类]
客户端验证
o ClientData [可选类]
客户端数据载体(支持类)
下面的图表显示了QuickServer库的基本构造。QuickServer模块上七个辐条表示七个方法:
o java.lang.String info()
o int getServiceState()
o boolean initService(java.lang.Object[] config)
o boolean startService()
o boolean resumeService()
o boolean suspendService()
o boolean stopService()
与QuickServer模块相连接的四个组件中只有ClientCommandHandler是必须的。
QuickServerConfig对象由initService()方法构建。它实现了QuickServer,在读取XML配置后,QuickServerConfig用于QuickServer配置。
ClientHandler线程对象用于客户端缓冲池。可选的ClientData类与ClientHandler类关联,ClientHandler对象容器参考ClientCommandHandler,ClientObjectHandler(可选),Authenticator(可选)对象包含在QuickServer主函数中。
注意:上图中并未显示QSAdminServer,它是图中QuickServer的组成部分。
3. 主要特点
o 创建多线程、多客户端TCP服务器应用程序
o 支持安全服务的创建:SSL, TLS
o 清楚的分离服务、协议、验证逻辑
o GUI图形界面远程管理支持
o Command Shell对服务器的本地管理
o 无须断开客户端连接的重启或延迟服务
o 为线程的再利用和大多数的使用对象建立缓冲池
o 完全的日志支持(Java构建)
o 支持发送和接收字符串、字节、二进制、序列化Java对象
o 在同样的xml中支持能够存贮指定应用数据的XML配置
o 支持通过IP地址限制服务
o 支持基于XML的JDBC映射
o 支持服务配置模式
o 支持从xml加载/重新加载用于jar包
o 在QuickServer中添加处理hooks
o 指定允许的最大客户端连接数
o 在通常的TCP连接上支持谈判安全连接
o 支持鉴别和查询客户端
o 附带典型例子——FTPServer, CmdServer,EchoWebServer, ChatServer
4. 1.4版的新功能
o 为QuickServer添加安全模式:SSL, TLS
o 添加SecureManagerLoader管理安全模式
o 在通常的TCP连接上添加谈判安全连接
o 添加初始化服务hooks
o 为通信添加二进制模式
o 为QsAdminServer通信添加QSAdminAPI
o 为QuickServer 添加findAllClientByKey
o 添加ConnectionLostException类
o 改进ClientHandler、安全配置
o 新例子——XmlAdder:一个简单的xml服务,可添加两个整数
o 新例子——PipeServer:一个简单的重定向服务
QuickServer开发指南(2)- 安装
1. 运行环境
QuickServer 1.2以上的版本需要(其实在偶看来一个1.4版以上JDK足矣):
推荐1.4版以上Java虚拟机,最低1.3版(未经测试).
Java Logging API(下列之一)
o java.util.logging包 [JDK 1.4版自带]
o Lumberjack库 [http://javalogging.sourceforge.net/]
XML 解析器 (下列之一)
o SAX (面向XML 2.0的API) [JDK 1.4版自带]
o JAXP (面向XML解析的Java API) 1.1 [JDK 1.4版自带]
o Xerces [http://xml.apache.org/xerces2-j]
o Crimson [http://xml.apache.org/crimson]
Jakarta公共组件{Digester, Pool}
o 这些产品包含在Apache开发的软件中(http://www.apache.org/)。Jar包都在以下的库中:BeanUtils, Collections, Logging. [http://jakarta.apache.org/commons/components.html]. Apache软件许可证在文件“apache_license.txt”中。
2. 安装
目前最新的1.4.1版QuickServer可在http://www.quickserver.org/download.html下载。安装QuickServer,假设安装路径为$INSTALL_PATH。
在CLASSPATH中添加"$INSTALL_PATH\dist\QuickServer.jar",在PATH中添加"$INSTALL_PATH\bin"。
另外测试socket的通讯软件推荐SockTest,在http://www.ddost.com/soft/sockettest 可下载到最新版本。Windows自带的telnet也可以进行测试。
QuickServer开发指南(3)- 构建EchoServer
学习怎样使用QuickServer库的一个好的方法是学习它提供的例子。在QuickServer安装路径下的examples文件夹里有许多典型的例子。
下面的章节里我们模仿其中的一个例子EchoServer来构建一个服务器。EchoServer是一个简单的TCP服务器,主要功能是将用户发送的字符串加上前缀"Echo :"后返回。虽然这个例子可用性不强,但它是一个对QuickServer所有特点的一个很好的示范。我们从构建一个最基本的服务器开始,以后慢慢给它添加新的功能。
1. 代码
首先实现EchoServer最基本的功能:将用户发送的字符串加上前缀"Echo :"后返回。
在本地创建一个文件夹存放需要的代码,如在c:\projects\中建立echoserver文件夹,然后创建一个类EchoServer.java:
01 package echoserver; 02 03 import org.quickserver.net.*; 04 import org.quickserver.net.server.*; 05 06 import java.io.*;
07 08 public class EchoServer { 09 public static void main(String s[]) { 10 QuickServer myServer = 11 new QuickServer("echoserver.EchoCommandHandler"); 12 myServer.setPort(4123); 13 myServer.setName("EchoServer v 1.0"); 14 try { 15 myServer.startServer(); 16 } catch(AppException e){ 17 System.err.println("Error in server : "+e); 18 } 19 } 20 } |
在第10行和第11行定义了一个QuickServer对象myServer,通过一个String对象"echoserver.EchoCommandHandler"声明了要加载的类,这个类面向所有客户端做命令处理器,实现了org.quickserver.net.server.ClientCommandHandler接口,我们即将创建。
第12行设置了一个服务器端口用来做监听,然后设置整个应用的名字(第13行)。最后启动服务(第15行)。
接下来为EchoServer创建一个实现org.quickserver.net.server.ClientCommandHandler接口的类EchoCommandHandler.java,用来处理服务器发送的命令。
01 // EchoCommandHandler.java 02 package echoserver; 03 04 import java.net.*; 05 import java.io.*; 06 import org.quickserver.net.server.ClientCommandHandler; 07 import org.quickserver.net.server.ClientHandler; 08 09 public class EchoCommandHandler implements ClientCommandHandler { 10 11 public void gotConnected(ClientHandler handler) 12 throws SocketTimeoutException, IOException { 13 handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 14 handler.sendClientMsg("| Welcome to EchoServer v 1.3 |"); 15 handler.sendClientMsg("| Send 'Quit' to exit |"); 16 handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 17 } 18 public void lostConnection(ClientHandler handler) 19 throws IOException { 20 handler.sendSystemMsg("Connection lost : " + 21 handler.getSocket().getInetAddress()); 22 } 23 public void closingConnection(ClientHandler handler)
24 throws IOException { 25 handler.sendSystemMsg("Closing connection : " + 26 handler.getSocket().getInetAddress()); 27 } 28 29 public void handleCommand(ClientHandler handler, String command) 30 throws SocketTimeoutException, IOException { 31 if(command.equals("Quit")) { 32 handler.sendClientMsg("Bye ;-)"); 33 handler.closeConnection(); 34 } else { 35 handler.sendClientMsg("Echo : "+command); 36 } 37 } 38 } |
根据QuickServer的要求,这个类必须实现ClientCommandHandler接口。
当客户端建立一个连接(11行),gotConnected()方法被调用。在这个方法里面,我们给客户端发送欢迎文本(13-16行),这些文本使用通过ClientHandler的sendClientMsg()方法发送给客户端。我们也会使用ClientHandler的sendSystemMessage()方法显示客户端连接的InetAddress(20-21,25-26行)。
handlerCommand()方法是ClientCommandHandler接口的核心方法,因为服务器接收客户端发送的任何命令时都要调用该方法。在我们对这个方法的实现中,我们会检查命令是否为"Quit"(31行),如果是,我们将发送一些提示文本表示服务器即将关闭连接,然后关闭连接(33行)。否则,将命令加上前缀"Echo :"返回给用户。
2. 运行和测试
o 运行命令提示符程序(cmd.exe)
o 进入代码所在文件夹根目录,如c:\projects
o 编译代码 javac echoserver\*.java
o 若无编译错误,运行服务器:
set classpath=%classpath%;d:\QuickServer\dist\QuickServer.jar;.\(类所在文件夹)
java echoserver.EchoServer
o 您将会看到如下信息:
o 测试我们的服务器是否可以正常工作。再运行一个cmd程序,进入SocketTest.jar所在目录,键入java -jar sockettest.jar命令,弹出一个窗口。在IP Address中输入"127.0.0.1",在Port里输入"4123",点击"Connect"按钮,将看到窗口中显示如下图的信息。
若使用telnet,可键入命令:open localhost 4123
在Message中输入一些字符串,点击"Send"按钮,浏览器将会返回一个加了前缀"Echo :"的字符串。发送"Quit",服务器断开连接。
QuickServer开发指南(4)- 添加认证
现在我们给刚刚创建的服务器添加认证功能。
查看org.quickserver.net.server.QuickServer的文档(docs文件夹下)你可以注意到里面有一个方法
public void setAuthenticator(java.lang.String authenticator)
阅读文档可知此方法中的authenticator字符串是实现org.quickserver.net.server.Authenticator接口的方法的全名。
Authenticator接口有两个实现:
org.quickserver.net.server.QuickAuthenticator:这个类用来验证连接QuickServer的客户端。它只用一个实例处理所有的QuickServer验证。(推荐)
org.quickserver.net.server.ServerAuthenticator:这个类同样用来验证连接QuickServer的客户端,但对每一个验证的处理都会创建一个实例。
接下来给EchoServer加验证功能。简单点,客户端输入的用户名和密码一致就算验证通过。
首先,在同样的文件夹里创建一个验证类:EchoServerQuickAuthenticator
01 package echoserver;
02 03 import org.quickserver.net.server.*; 04 import java.io.*; 05 06 public class EchoServerQuickAuthenticator extends QuickAuthenticator { 07 08 public boolean askAuthorisation(ClientHandler clientHandler) 09 throws IOException { 10 String username = askStringInput(clientHandler, "User Name :"); 11 String password = askStringInput(clientHandler, "Password :"); 12 13 if(username==null || password ==null) 14 return false; 15 16 if(username.equals(password)) { 17 sendString(clientHandler, "Auth OK"); 18 return true; 19 } else { 20 sendString(clientHandler, "Auth Failed"); 21 return false; 22 } 23 } 24 } |
这个类扩展了org.quickserver.net.server.QuickAuthenticator(第6行),在askAuthorisation()方法中(8行),通过askStringInput()方法要求客户端输入用户名和密码,并读入客户端输入的信息(10-11行)。这个方法继承自QuickAuthenticator。如果用户名与密码相等,发送正确信息并返回"true"(16-18行),否则发送错误信息并返回"false"(20-21行)。
接下来我们要告诉QuickServer使用我们新创建的验证类来做验证器。修改前一章创建的EchoServer.java文件,代码如下(粗体为修改的代码):
01 package echoserver; 02 03 import com.ddost.net.*; 04 import com.ddost.net.server.*; 05 06 import java.io.*; 07 08 public class EchoServer { 09 10 public static void main(String s[]) { 11 12 QuickServer myServer = 13 new QuickServer("echoserver.EchoCommandHandler"); 14myServer.setAuthenticator(
15"echoserver.EchoServerQuickAuthenticator"); 16 myServer.setPort(4123); 17 myServer.setName("EchoServer v 1.0"); 18try { 19 myServer.startServer(); 20 } catch(AppException e){ 21 System.err.println("Error in server : "+e); 22 } 23 } 24 } |
OK,将修改好的文件编译,按照前一章讲述的方法运行程序。这次当我们点击"Connect"时,浏览器会要求我们输入用户名和密码。如果输入的用户名和密码一致就可以登录。如果输入错误五次以上,浏览器会提示"-ERR Max Auth Try Reached"并自动断开连接。这个次数和提示信息可以通过QuickServer类的setMaxAuthTry() 和 setMaxAuthTryMsg()修改。
有时在验证过程中我们可能需要中途退出而不是等待验证结束,这时输入"Quit"是不起作用的。我们可以这样修改代码,有两个方法:
一是从EchoServerQuickAuthenticator类中的askAuthorisation()方法抛出一个org.quickserver.net.AppException异常,代码如下:
String username = askStringInput(clientHandler, "User Name :");
if (username != null &&
username.equalsIgnoreCase("QUIT")) {
sendString(clientHandler, "Logged out.");
throw new AppException("Quit");
}
或者参考ClientHandler,关闭连接,代码如下:
String username = askStringInput(clientHandler, "User Name :");
if (username != null &&
username.equalsIgnoreCase("QUIT")) {
sendString(clientHandler, "Logged out.");
clientHandler.closeConnection();
return false;
}
ClientHandler对象能够提供很多客户端连接的有用信息,如IP地址。更多信息请参考API文档。
注意:
o 不要在验证器类中存贮任何客户端相关信息,如果需要,必须存放在ClientData类中--下一章将讲解该部分内容。
o 必须确认askAuthorisation()方法是线程安全的。
QuickServer开发指南(5)- 客户数据
既然不能在ClientCommandHandler和ServerAuthenticator类中保存客户数据,我们使用ClientData类的handleCommand()或askAuthorisation()方法来存储所有的客户端信息。
示范一下这个特点有什么用。还是以EchoServer为例,当用户发送"Hello"时,我们给他一个问候。如果用户再发送"Hello",我们提醒他已经发了n次"Hello"。接下来定义ClientData类来存储用户名以及他向服务器发送"Hello"的次数。
1. 代码
1. 在EchoServer中创建一个EchoServerData类
01 //---- EchoServerData.java ---- 02 package echoserver; 03 04 import org.quickserver.net.server.*; 05 import java.io.*; 06
07 public class EchoServerData implements ClientData { 08 private int helloCount; 09 private String username; 10 11 public void setHelloCount(int count) { 12 helloCount = count; 13 } 14 public int getHelloCount() { 15 return helloCount; 16 } 17 18 public void setUsername(String username) { 19 this.username = username; 20 } 21 public String getUsername() { 22 return username; 23 } 24 } 25 //--- end of code --- |
2. 告诉QuickServer用这个EchoServerData来做为它的ClientData类。
修改前面创建的EchoServer.java,代码如下:
01 package echoserver; 02 03 import org.quickserver.net.*; 04 import org.quickserver.net.server.*; 05 06 import java.io.*; 07 08 public class EchoServer { 09 public static void main(String s[]) { 10 11 String cmd = "echoserver.EchoCommandHandler"; 12 String auth = "echoserver.EchoServerQuickAuthenticator"; 13 String data = "echoserver.EchoServerData"; 14 15 QuickServer myServer = new QuickServer(cmd); 16 myServer.setAuthenticator(auth); 17 myServer.setClientData(data); 18 19 myServer.setPort(4123); 20 myServer.setName("Echo Server v 1.0"); 21 try { 22 myServer.startServer(); 23 } catch(AppException e){
24 System.out.println("Error in server : "+e); 25 } 26 } 27 } |
上面的代码中,我们将配置信息写入String对象来设置QuickServer。
3. 修改Authenticator类,也就是EchoServerAuthenticator类,让它在ClientData对象中存储用户名。下面是修改后的代码:
01 package echoserver; 02 03 import org.quickserver.net.server.*; 04 import java.io.*; 05 06 public class EchoServerQuickAuthenticator extends QuickAuthenticator { 07 08 public boolean askAuthorisation(ClientHandler clientHandler) 09 throws IOException { 10 String username = askStringInput(clientHandler, "User Name :"); 11 if(username!=null && username.equalsIgnoreCase("QUIT")) { 12 sendString(clientHandler, "Logged out."); 13 //close the connection 14 clientHandler.closeConnection(); 15 return false; 16 } 17 18 String password = askStringInput(clientHandler, "Password :"); 19 20 if(username==null || password ==null) 21 return false; 22 23 if(username.equals(password)) { 24 sendString(clientHandler, "Auth OK"); 25 //store the username in ClientData 26 EchoServerData data = (EchoServerData)clientHandler.getClientData(); 27 data.setUsername(username); 28 return true; 29 } else { 30 sendString(clientHandler, "Auth Failed"); 31 return false; 32 } 33 } 34 } |
4. 修改ClientCommandHandler实现类EchoCommandHandler。如果用户发送"Hello",给他一个问候。如果他发送多次"Hello",告诉他已经发送了n次"Hello"。下面是修改后的代码:
01 // EchoCommandHandler.java 02 package echoserver; 03 04 import java.net.*; 05 import java.io.*; 06 import org.quickserver.net.server.ClientCommandHandler; 07 import org.quickserver.net.server.ClientHandler; 08 09 public class EchoCommandHandler implements ClientCommandHandler { 10 11 public void gotConnected(ClientHandler handler) 12 throws SocketTimeoutException, IOException { 13 handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 14 handler.sendClientMsg("| Welcome to EchoServer v 1.0 |"); 15 handler.sendClientMsg("| Note: Password = Username |"); 16 handler.sendClientMsg("| Send 'Quit' to exit |"); 17 handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 18 } 19 public void lostConnection(ClientHandler handler) 20 throws IOException { 21 handler.sendSystemMsg("Connection lost : " + 22 handler.getSocket().getInetAddress()); 23 } 24 public void closingConnection(ClientHandler handler) 25 throws IOException { 26 handler.sendSystemMsg("Closing connection : " + 27 handler.getSocket().getInetAddress()); 28 } 29 30 public void handleCommand(ClientHandler handler, String command) 31 throws SocketTimeoutException, IOException { 32 if(command.equals("Quit")) { 33 handler.sendClientMsg("Bye ;-)"); 34 handler.closeConnection(); 35 } if(command.equalsIgnoreCase("hello")) { 36 EchoServerData data = (EchoServerData) handler.getClientData(); 37 data.setHelloCount(data.getHelloCount()+1); 38 if(data.getHelloCount()==1) { 39 handler.sendClientMsg("Hello "+data.getUsername()); 40 } else { 41 handler.sendClientMsg("You told Hello "+data.getHelloCount()+
42 " times. "); 43 } 44 } else { 45 handler.sendClientMsg("Echo : "+command); 46 } 47 } 48 } |
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类。
01 //---- EchoServerPoolableData.java ---- 02 package echoserver; 03 04 import org.quickserver.net.server.*; 05 import java.io.*; 06 07 public class EchoServerPoolableData 08 extends EchoServerData 09 implements org.apache.commons.pool.PoolableObjectFactory { 10 11 public void activateObject(Object obj) { 12 } 13 public void destroyObject(Object obj) { 14 if(obj==null) return; 15 passivateObject(obj); 16 obj = null; 17 } 18 public Object makeObject() { 19 return new EchoServerPoolableData(); 20 } 21 public void passivateObject(Object obj) { 22 EchoServerPoolableData pd = (EchoServerPoolableData)obj; 23 pd.setHelloCount(0); 24 pd.setUsername(null); 25 } 26 public boolean validateObject(Object obj) { 27 if(obj==null) 28 return false; 29 else 30 return true; 31 } 32 } 33 //--- end of code --- |
这个类扩展了我们的EchoServerData,然后我们实现了org.apache.commons.pool.BasePoolableObjectFactory,这个实现是简单的不需要解释了。
现在我们需要告诉QuickServer使用这个类来代替原来的ClientData类。
myServer.setClientData("echoserver.EchoServerPoolableData");
编译修改的程序,可能会报如下错误:
package org.apache.commons.pool does not exist。
这是因为编译器不知道这个类。可以在环境变量中添加D:\QuickServer\dist\commons-pool.jar包,并在运行时
set classpath=%classpath%;d:\QuickServer\dist\QuickServer.jar; d:\QuickServer\dist\commons-pool.jar;.\(类所在文件夹)即可。
posted on 2006-12-04 19:45
OMG 阅读(1116)
评论(0) 编辑 收藏 所属分类:
Soket