下面的章节里我们模仿其中的一个例子EchoServer来构建一个服务器。EchoServer是一个简单的TCP服务器,主要功能是将用户发送的字符串加上前缀"Echo :"后返回。虽然这个例子可用性不强,但它是一个对QuickServer所有特点的一个很好的示范。我们从构建一个最基本的服务器开始,以后慢慢给它添加新的功能。
1. 代码
首先实现EchoServer最基本的功能:将用户发送的字符串加上前缀"Echo :"后返回。
在本地创建一个文件夹存放需要的代码,如在c:/projects/中建立echoserver文件夹,然后创建一个类EchoServer.java:
01packageechoserver; 02 03importorg.quickserver.net.*; 04importorg.quickserver.net.server.*; 05 06importjava.io.*; 07 08public classEchoServer { 09public static voidmain(String s[]) { 10QuickServer myServer = 11newQuickServer("echoserver.EchoCommandHandler"); 12myServer.setPort(4123); 13myServer.setName("EchoServer v 1.0"); 14try{ 15myServer.startServer(); 16}catch(AppException e){ 17System.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 02packageechoserver; 03 04importjava.net.*; 05importjava.io.*; 06importorg.quickserver.net.server.ClientCommandHandler; 07importorg.quickserver.net.server.ClientHandler; 08 09public classEchoCommandHandlerimplementsClientCommandHandler { 10 11public voidgotConnected(ClientHandler handler) 12throwsSocketTimeoutException, IOException { 13handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 14handler.sendClientMsg("| Welcome to EchoServer v 1.3 |"); 15handler.sendClientMsg("| Send 'Quit' to exit |"); 16handler.sendClientMsg("+++++++++++++++++++++++++++++++"); 17} 18public voidlostConnection(ClientHandler handler) 19throwsIOException { 20handler.sendSystemMsg("Connection lost : "+ 21handler.getSocket().getInetAddress()); 22} 23public voidclosingConnection(ClientHandler handler) 24throwsIOException { 25handler.sendSystemMsg("Closing connection : "+ 26handler.getSocket().getInetAddress()); 27} 28 29public voidhandleCommand(ClientHandler handler, String command) 30throwsSocketTimeoutException, IOException { 31if(command.equals("Quit")) { 32handler.sendClientMsg("Bye ;-)"); 33handler.closeConnection(); 34}else{ 35handler.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",服务器断开连接。