OMG,到底在寻找什么..................
(构造一个完美的J2EE系统所需要的完整知识体系)
posts - 198,  comments - 37,  trackbacks - 0
原贴地址http://blog.csdn.net/clearwater21cn/category/99145.aspx

QuickServer开发指南(1)- 介绍 

QuickServer是一个免费的开源Java库,用于快速创建健壮的多线程、多客户端TCP服务器应用程序。使用QuickServer,用户可以只集中处理应用程序的逻辑/协议,从而方便的建立功能强大的服务器应用。该程序由Akshathkumar Shetty设计和实现。
    QuickServer安装目录下的example中有演示其功能的例子,最新的例子和文档可以通过网站 http://www.quickserver.orghttp://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 阅读(1113) 评论(0)  编辑  收藏 所属分类: Soket

只有注册用户登录后才能发表评论。


网站导航:
 

<2006年12月>
262728293012
3456789
10111213141516
17181920212223
24252627282930
31123456

常用链接

留言簿(1)

随笔分类

随笔档案

IT风云人物

文档

朋友

相册

经典网站

搜索

  •  

最新评论

阅读排行榜

评论排行榜