Java网络编程之服务器套接字.pdf

《Java网络编程之服务器套接字.pdf》由会员分享，可在线阅读，更多相关《Java网络编程之服务器套接字.pdf（38页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、369第十一章服务器套接字本章内容：ServerSocket 类一些有用的服务器前一章我们从客户机的角度讨论了套接字：打开到正在监听的服务器的套接字。但是，仅有客户机套接字是不够的，如果客户机没有和服务器对话，那么它是没用的。考虑到这一点，我们前一章所讨论的内容用于写服务器程序是远远不够的。为创建Socket，程序员需要知道想要建立连接的Internet主机。在编写服务器程序时不需要提前知道谁会与程序员联系，即使知道是谁，也无法知道他何时想与之建立联系。换句话说，服务器类似于坐在电话机旁边等待呼叫到来的接收者。它们不知道是谁、会在什么时候会打电话来，只有在电话铃声响起的时候才知道有呼叫进来，然

2、后它们拿起电话与不知在何处的人（对方响应之前）进行通话。我们无法编写单独实现Socket类的程序。当然没有任何理由用Java编写的客户程序一定是与Java服务器对话 事实上，客户程序不关心服务器程序是用什么语言编写的，也不关心它具体在哪一种操作平台上运行。但是，如果Java不支持服务器程序的编写，那将是它在功能上令人吃惊的漏洞。幸运的是，Java中不存在这样的漏洞。它提供了一个ServerSocket 类，程序员可以很方便地用它编写服务器程序。服务器套接字的基本功能类似于坐在电话机旁边等待呼叫到来。从技术上讲，ServerSocket 运行在服务器上并监听到来的 TCP 连接。每个Server

3、Socket都在服务器上的指定端口监听。当远程主机上的客户Socket试图与指定端口建立连接时，服务器被激活，判定客户程序与服务器的连接，并打开两个主机之间固有的 Socket。一旦与服务器套接字建立了连接，则服务器就可以使用固有的 Socket 对象向客户机发送数据。数据总是通过固有的套接字传递。第十一章370ServerSocket 类ServerSocket 类包含了用 Java 编写服务器程序的所有内容。它包括创建新ServerSocket对象的构造器、在指定端口监听连接的方法，以及连接建立后可以发送和接收数据时返回Socket对象的方法。此外，它还有设置不同选项以及各种各样常用的方法

4、，例如 toString()方法。服务器的基本生命期是：1.利用 ServerSocket()构造器在指定端口创建一个新的 ServerSocket；2.ServerSocket利用它的accept()方法在指定端口监听到来的连接。accept()方法一直处于阻塞状态，直到有客户机试图建立连接。这时accept()方法返回连接客户机何服务器的 Socket；3.调用getInputStream()方法、getOutputStream()方法或者两者都调用来得到与客户机通信的输入流和输出流，具体调用哪一个方法还是两者都调用与具体服务器的类型有关；4.服务器和客户机根据双方都承认的协议进行交互，直

5、到关闭连接时为止；5.服务器、客户机或两者均关闭连接；6.服务器返回步骤 2，等待下一个连接到来。如果在第4 步花费的时间很长或时间无限期，则wu-ftpd这样的传统Unix 服务器会创建一个新的进程来处理每个连接，从而使服务器在同一时刻可以为多个客户机提供服务。Java程序产生一个线程来与客户机发生作用，从而使服务器能很快准备好处理下一个连接。服务器上的线程远比子进程小。事实上，服务器所要处理的进程实在太多，这也就是为什么在没有缓存进行缓冲的条件下，典型的 Unix FTP 服务器不能处理多于 400 个连接的原因。另一方面，如果所使用的协议比较简单快速，而且允许服务器在它通过时关闭连接，则

6、对于服务器处理客户机请求来说会更加有效，客户机的请求可以很快得到处理，而不需要再产生线程。操作系统将到来的连接请求放在一个先入先出（first in first out）的队列中，每个请求都寻址到指定端口。队列的默认长度通常为50，但这根据操作系统的不同可以有所变化。有些操作系统（Solaris不是）有一个队列长度最大值限制，典型的值为5。在这些系统上，队列的最大可能长度应该是小于等于 50。在未处理的连接的数服务器套接字371目达到队列的最大长度数以后，主机就拒绝在此端口再增加连接，直到队列出现空隙为止。对于许多（尽管不是全部）客户程序来说，如果它们开始的连接请求被拒绝，它们一般都会试着继续

7、建立连接，并进行很多次。对到来的连接和队列的管理由操作系统提供的服务器程序负责，用户程序不需要考虑这些。如果用户认为等待队列的长度不足够大，有几个Socket构造器允许改变队列的长度限制。但是不能在操作系统所支持的最大队列数之外增加新的队列。构造器一共有 3 个公共的 ServerSocket 构造器：public ServerSocket(int port)throws IOException,BindExceptionpublic ServerSocket(int port,int queueLength)throws IOException,BindExceptionpublic Ser

8、verSocket(int port,int queueLength,InetAddress bindaddress)throws IOException这些构造器允许用户指定端口、用于保存到来的连接请求队列的长度以及绑定本地网络的接口。它们的基本功能完全相同，但其中有一些使用默认的队列长度值和默认的绑定地址。下面我们按顺序逐个进行研究。public ServerSocket(int port)throws IOException,BindException这个构造器在变量 port 给定的端口上创建服务器套接字。如果采用 0 作为端口号，则由系统选择可用端口。由系统选择的端口有时候也称做匿名

9、端口（anonymousport），因为我们不知道它的标号。对于服务器来说，匿名端口不是很有用，因为客户机需要提前知道它与哪个端口相连。但是，也有一些情况下（我们将在后面予以讨论）匿名端口是有用的。例如，为创建一个在HTTP服务器的80端口使用的服务器套接字，可以编写如下代码：try ServerSocket httpd=new ServerSocket(80);catch(IOException e)System.err.println(e);第十一章372如果不能在所要求的端口创建服务器套接字，则此构造器触发一个 IOException（特别地情况下，是BindException）。创建S

10、erverSocket时触发IOException通常总是意味着下面两件事情中的一件：或者是因为可能有从另外一个完全不同的程序来的服务器套接字已经占用了所要求的端口；或者是因为在没有 root（超级用户）权限的情况下试图与 Unix 上范围在 1 到 1023 之间的端口建立连接。可以利用这个构造器对前一章所讲的PortScanner程序进行改变。例11-1通过试图在本地计算机上的端口创建ServerSocket对象来检查这些端口并察看哪个端口不可用。如果使用的是Unix而又不是超级用户，则此程序仅在端口号不小于1024的端口工作。例 11-1：查找本地端口import .*;import j

11、ava.io.*;public class LocalPortScanner public static void main(String args)for(int port=1;port java LocalPortScannerThere is a server on port 135.There is a server on port 1025.There is a server on port 1026.There is a server on port 1027.There is a server on port 1028.服务器套接字373public ServerSocket(i

12、nt port,int queueLength)throws IOException,BindException这个构造器在指定的端口上创建一个ServerSocket，同时根据变量queueLength指定队列长度。如果使用的计算机有多个网络接口或多个IP地址，则它在所有网络接口和IP地址上的这个端口监听。queueLength变量设置到来连接请求队列的长度 也就是说，在主机开始拒绝连接之前，到底有多少同一时刻到来的连接请求可以被存储起来。有些操作系统有一个最大队列长度，典型的值是 5。如果想要扩展队列的最大值，则可以用最大队列长度来代替。如果传递的端口号为 0，则由系统来选择可利用的端口。

13、例如，为在端口5776上创建一个服务器套接字，同时使队列中所能存储的到来的连接请求数达到 100，可以编写下面的代码：try ServerSocket httpd=new ServerSocket(5776,100);catch(IOException e)System.err.println(e);如果不能在所要求的端口创建服务器套接字，则此构造器触发一个 IOException（特别情况下是BindException）。创建ServerSocket时触发IOException通常总是意味着下面两件事情中的一件：或者是因为可能有从另外一个完全不同的程序而来的服务器套接字已经占用了所要求的端口

14、；或者是因为在没有root（超级用户）权限的情况下试图与 Unix 上范围在 1 到 1023 之间的端口建立连接。public ServerSocket(int port,int queueLength,InetAddressbindaddress)throws IOException这个构造器仅在 Java 1.1 及后续版本中可用，它用于在指定端口上创建 Server-Socket，同时指定等待队列的长度。这个ServerSocket仅绑定在指定的本地IP地址上。这个构造器对于运行在具有多个 IP 地址（比较常见的实际情况是用在大的Web服务器上）的操作系统上的服务器程序比较有用，因为它

15、允许选择所监听的地址。也就是说，这个 ServerSocket仅监听在指定地址上到来的连接，而不监听这个主机上其他地址上到来的连接。另外两个构造器默认地与所有的本地 IP 地址绑定。第十一章374例如，metalab.unc.edu 是北加州的一个指定 SPARC 工作站，它通过 IP 地址152.2.254.81 与 Internet 相连。同样的 SPARC 工作站也叫做 www.gigabit-ethernet.org，但IP地址不同（它用的是152.2.254.82）。如果要创建一个在metalab.unc.edu的5,776端口监听的服务器套接字而此套接字不在www.gigabit-

16、ethernet.org的 5776 端口监听，应该编写的代码如下：try ServerSocket httpd=new ServerSocket(5776,10,InetAddress getByName(metalab.unc.edu );catch(IOException e)System.err.println(e);如果不能在所要求的端口创建服务器套接字，则此构造器触发一个 IOException（特别情况下是BindException）。创建ServerSocket时触发BindException通常总是意味着下面两件事情中的一件：或者是因为可能有从另外一个完全不同的程序而来的服务

17、器套接字已经占用了所要求的端口；或者是因为在没有root（超级用户）权限的情况下试图与 Unix 上范围在 1 到 1023 之间的端口建立连接。接受和关闭连接ServerSocket通常以循环的形式进行操作，从而重复地接受连接请求。每通过一次循环，就调用一次 accept()方法。这个方法返回一个代表远程客户机和本地服务器之间连接的Socket对象。与客户机的交互就通过这个Socket来完成。传输过程完成时，服务器应该调用Socket对象的close()方法并准备好处理下一个到来的连接。但是，当服务器需要关闭并且不再处理任何后面到来的连接时，则应该调用ServerSocket的close()

18、方法。public Socket accept()throws IOException当服务器建立完成并准备好接受连接时，调用ServerSocket的accept()方法。这个方法是“阻塞”的：它停止执行流并且等待直到下一个客户机连接到来。当客户机连接到来时，accept()方法返回 Socket 对象。可以用这个 Socket 对象的getInputStream()方法和getOutputStream()方法返回的流来与客户机进行通信。例如：服务器套接字375ServerSocket server=new ServerSocket(5776);While(true)Socket conne

19、ction=server.accept();OutputStream out =new OutputStreamWriter(connection.getOutputStream();Out.write(Youve connected to this server.Bye-bye now.rn);Connection.close();如果不希望程序在等待连接时停止，则可以把对 accept()方法的调用放在单独的线程中。当增加异常处理部分时，代码会变得有些令人难以理解。要注意区分ServerSocket触发的异常和Socket触发的异常。ServerSocket触发的异常应该关闭服务器并登记错

20、误信息；而 Socket触发的异常应该是关闭活动的连接。accept()触发的异常是一种中间情况，既不属于ServerSocket触发的异常，也不属于Socket触发的异常。因此需要编制try 块。最后，大多数服务器都希望确保在通信结束后关闭它所接受的所有套接字。即使使用的协议指定了由客户机负责关闭连接，客户机也不总是很好地坚持协议规定。对close()方法的调用也必须打包到捕获IOException的try块中。但是，如果在关闭套接字时捕获 IOException，则不理睬它。这意味着在服务器能够关闭套接字之前客户机已经将它关闭了。下面是一个比较实际的例子：try ServerSocket

21、server=new ServerSocket(5776);while(true)Socket connection=server.accept();try OutputStreamWriter out =new OutputStreamWriter(connection.getOutputStream();out.write(Youve connected to this server.Bye-bye now.rn);connection.close();catch(IOException e)/这可能是连接的暂时错误 /比如客户端过早中断 /因此不终止循环，输出错误 /但你可以选择将此错误

22、记入日志 finally /大多数服务器在完成后要保证套接字关闭 try if(connection!=null)connection.close();catch(IOException e)第十一章376 catch(IOException e)System.err.println(e);例11-2实现了一个符合 RFC 867的简单daytime服务器。因为这个服务器仅发送一行文本作为对连接的响应，因此它几乎可以在每一个连接请求出现时予以立即处理。更加复杂的服务器会产生一个线程来处理每个请求。在这种情况下，产生线程所要花费的时间比处理请求所花费的时间要长得多。注意：如果是在Unix上运行此

23、程序，则需要在根下运行才能保证连接到端口13。如果不能在根下运行程序，则把端口号改成大于 1024 的数，例如 1313。例 11-2：Daytime服务器import .*;import java.io.*;import java.util.Date;public class DaytimeServer public final static int DEFAULT_PORT=13;public static void main(String args)int port=DEFAULT_PORT;if(args.length 0)try port=Integer.parseInt(args0

24、);if(port=65536)System.out.println(Port must between 0 and 65535);return;catch(NumberFormatException e)/使用默认端口 try ServerSocket server=new ServerSocket(port);Socket connection=null;while(true)服务器套接字377 try connection=server.accept();OutputStreamWriter out =new OutputStreamWriter(connection.getOutput

25、Stream();Date now=new Date();out.write(now.toString()+rn);out.flush();connection.close();catch(IOException e)finally try if(connection!=null)connection.close();catch(IOException e)/结束 while /结束 try catch(IOException e)System.err.println(e);/结束 catch /结束 main/结束 DaytimeServer例11-2是非常简单而又直接的。程序的前三行导入常

26、用的包：java.io、以及获取时间的 java.util.Date。在DEFAULT_PORT 类中有一个单一的 publicfinal static int字段（例如一个常数），它用于设置众所周知的 daytime服务器端口（端口 13）。这个类只有一个方法，这个方法是 main()，它完成所有的工作。如果是在命令行指定端口，则它从 args0读取。否则使用默认值。外部的try块用来捕捉IOException。在daytime端口上构造ServerSocket服务器时或服务器接受连接时可能会触发这个异常。内部的try块监视连接接受和处理过程中触发的异常。在无限循环中调用 accept()方

27、法来监测新的连接。与许多其他服务器一样，这个程序一直运行并持续监听，直到触发了异常或人为地停止它为止（注 1）。当客户机建立连接时，accept()方法返回 Socket，它存在本地变量 connection注 1：人为停止程序的命令与具体的系统有关；在 Unix、NT 和许多其他系统中，CTRL-C可以完成此工作。如果是在 Unix 系统上后台运行服务器程序，则可以通过找到服务器进程的 ID 并用删除命令（kill pid）来删除它。第十一章378中，并且程序持续运行。调用 getOutputStream()方法获得与 Socket相关的输出流并将输出流连接到一个新的 OutputStrea

28、mWriter out。为获得当前日期，要构造一个Date对象，并通过用writer()方法写它的字符串表示形式，将数据发送到客户机。最后，在数据发送出去之后或触发了异常时，可以在finally块内关闭connection。在完成时总时要选择一个套接字。在前面的一章里，我们说客户机不应该依赖于连接的另一方来关闭套接字。这同样也适合于服务器。客户机可以超时或崩溃，用户可以删除传递，网络在高负载时可以关闭。其中的一个问题或几个问题的出现，都使得不能依靠客户机来关闭套接字，即使协议要求客户机关闭套接字（很少有这样的情况）也不行。发送二元非文本数据也并不是十分困难。例 11-3 说明了一个 time

29、服务器。它服从RFC 868 协议的规定。当客户机连接时，服务器发送一个 4 字节、从小到大排列的无符号整数来指定从GMT1900年1月1 日12:00时到现在所过去的时间（以秒为单位）。通过创建一个新的 Date对象可以简单地实现对当前时间的检索。但是，因为Date类计算的是从1970 年1月1日12:00时到现在的毫秒数，而不是从GMT 1900年 1 月 1 日 12:00 时到现在的秒数，因此需要必要的转换。例 11-3：Time 服务器import .*;import java.io.*;import java.util.Date;public class TimeServer pu

30、blic final static int DEFAULT_PORT=37;public static void main(String args)int port=DEFAULT_PORT;if(args.length 0)try port=Integer.parseInt(args0);if(port=65536)System.out.println(Port must between 0 and 65535);return;catch(NumberFormatException e)服务器套接字379 /time协议设置纪元为 1900,/java Date 类为1970 /这是转换数

31、long differenceBetweenEpochs=2208988800L;try ServerSocket server=new ServerSocket(port);while(true)Socket connection=null;try connection=server.accept();OutputStream out=connection.getOutputStream();Date now=new Date();long msSince1970=now.getTime();long secondsSince1970=msSince1970/1000;long second

32、sSince1900=secondsSince1970 +differenceBetweenEpochs;byte time=new byte4;time0 =(byte)(secondsSince1900&0 x00000000FF000000L)24);time1 =(byte)(secondsSince1900&0 x0000000000FF0000L)16);time2 =(byte)(secondsSince1900&0 x000000000000FF00L)8);time3=(byte)(secondsSince1900&0 x00000000000000FFL);out.writ

33、e(time);out.flush();/结束try catch(IOException e)/结束catch finally if(connection!=null)connection.close();/结束while /结束try catch(IOException e)System.err.println(e);/结束catch /结束main/结束TimeServer与前一章所讲的 TimeClient 一样，大多数的工作是处理Java 默认情况下所不支持的数据格式（32 位无符号数）。public void close()throws IOException如果实现了服务器套接字，

34、则应该关闭它，尤其是有些时候用户程序仍然需要继续第十一章380运行时更应该关闭服务器套接字。这可以释放端口给其他希望使用此端口的程序。关闭ServerSocket不应该与关闭Socket混淆。关闭ServerSocket是释放本地主机的端口，从而允许其他服务器绑定到这个端口；而关闭Socket是断开本地主机和远程主机之间的连接。有 一 些 套 接 字 可 以 在 程 序 退 出 时 自 动 关 闭，因 此 在 程 序 结 束 后 不 再 需 要ServerSocket时关闭此套接字也不是必需的。但是，关闭它是没有任何坏处的。例如，把LocalPortScanner程序的主循环写成下面的形式就可

35、以不占用系统的大部分端口：for(int port=1;port java RandomPortThis server runs on port 1154D:JAVAJNP2examples11java RandomPortThis server runs on port 1155D:JAVAJNP2examples11java RandomPortThis server runs on port 1156虽然在这个虚拟机上端口不是真正随机的，但它们在运行之前用户是不知道的。第十一章382套接字选项服务器套接字所支持的唯一一个套接字选项是SO_TIMEOUT。SO_TIMEOUT是一个时间量，

36、单位为毫秒。accept()在触发 java.io.InterruptedIOException之前等待连接的到来。如果 SO_TIMEOUT为 0，则 accept()从来不会超时。默认值就是从不超时。很少使用SO_TIMEOUT选项。如果用户正在实现比较复杂而且安全的协议，这个协议又要求在客户机和服务器之间建立多个连接，而且响应必须在一定时间内发生时，可能会用到SO_TIMEOUT选项。大多数服务器都设计为运行时间没有周期限制，因此默认的超时值为 0（永远都不超时）。public void setSoTimeout(int timeout)throws SocketExceptionset

37、SoTimeout()方法为服务器套接字对象设置 SO_TIMEOUT 字段。从 accept()调用时开始记数。当等待时间达到设定值时，accept()方法触发 Interrupt-IOException。应该在调用 accept()之前设置这个选项，而且在accept()等待连接时不能改变此值。Timeout变量必须大于等于0，否则此方法触发一个Illegal-ArgumentException。例如：try ServerSocket server=new ServerSocket(2048);server.setSoTimeout(30000);/阻塞不超过30秒 try Socket

38、s=server.accept();/处理连接 /.catch(InterruptedIOException e)System.err.println(No connection within 30 seconds);finally server.close();catch(IOException e)System.err.println(Unexpected IOException:+e);public int getSoTimeout()throws IOExceptiongetSoTimeout()方法返回服务器套接字的当前 SO_TIMEOUT 值。例如：服务器套接字383public

39、 void printSoTimeout(ServerSocket server)int timeout=server.getSoTimeOut();if(timeout 0)System.out.println(server+will time out after +timeout+milliseconds.);else if(timeout=0)System.out.println(server+will never time out.);else System.out.println(Impossible condition occurred in +server);System.out

40、.println(Timeout cannot be less than zero.);对象方法jServerSocket只从java.lang.Object重载一个标准方法toString()。这样，散列表中严格的等同比较身份和服务器套接字可能会有一点儿问题，但这绝不是什么大问题。public String toString()ServerSocket 的toString()返回的 String 具有如下形式：ServerSocket addr=0.0.0.0,port=0,localport=5776 在目前的应用中，addr 总是 0.0.0.0，而且 prt 总是 0。据作者推测，这些

41、值在以后可能会引起人们的兴趣。Localport 是服务器监听连接的本地端口。实现ServerSocket类提供了两个方法来改变服务器套接字的默认实现。下面将简要地描述它们，主要是因为它们倾向于用在 Java 虚拟机的实现上而非应用程序中。public static synchronized void setSocketFactory(SocketImplFactory fac)throws IOException这个方法设置系统（system）的服务器 SocketImplFactory，这是用于创建第十一章384ServerSocket对象的类库。它与创建Socket对象的类库有所不同，尽

42、管语法是相似的。可以用一个库创建 Socket对象，用另一个库创建 ServerSocket对象。但是在程序也可以只设置这个类库一次。试图第二次设置SocketImplFactory时会触发一个 SocketException。protected final void implAccept(Socket s)throws IOExceptionServerSocket的子类使用这个方法实现 accept()。可以把未连接的 Socket对象传递到 implAccept()（这样做同样要求实现 Socket子类，因为标准的 .Socket类没有提供创建未连接套接字的工具）。当此方法返回时，Soc

43、ket变量s就连接到客户机上。一些有用的服务器本节给出几个可以通过服务器套接字构建的服务器程序。我们从能够用于测试客户机响应和请求的服务器开始，这很像用Telnet测试服务器的行为特性。然后我们给出三个不同的HTTP 服务器，每一个都有特定的功能，并且都比前面的一个服务器稍微复杂一些。客户机测试器在前面的章节里，我们已经学习了如何利用Telnet来检验服务器。但是没有类似的程序可以监测客户机，因此这里我们创建一个。例 11-5是一个叫做 ClientTester的程序，运行在由命令行指定的端口上，显示所有发送到客户机的数据，同时允许用户在命令行键入响应发送到客户机。例如，可以使用这个程序来查看

44、 NetscapeNavigator 发送到服务器的命令。注意：客户机很少能像服务器容忍意外的客户机响应一样容忍服务器的意外响应。如果条件允许，有可能要在 Unix 系统或其他一些支持防系统崩溃的操作平台上运行连接到此程序的客户程序。不要在 Mac 或 Windows 98 上运行它们，因为这些系统不够稳定。这个程序使用了两个线程：一个用于处理客户机端的输入，另外一个用于处理发送服务器的输出。使用这两个线程此程序可以同时处理输入和输出：它能够在接收一服务器套接字385个请求的同时发送一个响应 或者说得更精确一点儿，它能够在等待客户机响应的同时发送数据。这是非常方便的，因为这样不同的客户机和服务

45、器可以在无法预测的路径上进行通信。对于有些协议来说，服务器首先发出信息，而另外一些协议中是客户机先发出信息。有时候客户机和服务器同时发出信息。还有一些情况就是连接的一端在发出响应之前等待另一方信息发送的结束。程序必须有足够的灵活性，从而能够处理上述各种情况。例 11-5 给出了程序代码。例 11-5：客户机测试程序import .*;import java.io.*;import com.macfaq.io.SafeBufferedReader;/来自第四章public class ClientTester public static void main(String args)int por

46、t;try port=Integer.parseInt(args0);catch(Exception e)port=0;try ServerSocket server=new ServerSocket(port,1);System.out.println(Listening for connections on port +server.getLocalPort();while(true)Socket connection=server.accept();try System.out.println(Connection established with +connection);Thread

47、 input=new InputThread(connection.getInputStream();input.start();Thread output =new OutputThread(connection.getOutputStream();output.start();/等待输入输出结束 try input.join();output.join();catch(InterruptedException e)第十一章386 catch(IOException e)System.err.println(e);finally try if(connection!=null)connect

48、ion.close();catch(IOException e)catch(IOException e)e.printStackTrace();class InputThread extends Thread InputStream in;public InputThread(InputStream in)this.in=in;public void run()try while(true)int i=in.read();if(i=-1)break;System.out.write(i);catch(SocketException e)/输出线程关闭了套接字 catch(IOException

49、 e)System.err.println(e);try in.close();catch(IOException e)服务器套接字387class OutputThread extends Thread Writer out;public OutputThread(OutputStream out)this.out=new OutputStreamWriter(out);public void run()String line;BufferedReader in =new SafeBufferedReader(new InputStreamReader(System.in);try whil

50、e(true)line=in.readLine();if(line.equals(.)break;out.write(line+rn);out.flush();catch(IOException e)try out.close();catch(IOException e)客户机测试应用程序分成 3 个类：ClientTester 类、InputThread 类和OutputThread 类。ClientTester 类从命令行读端口，然后打开此端口的ServerSocket并监听到来的连接。在某一时刻只允许一个连接，这是因为此程序只是一个实验程序而且是由比较缓慢的人（与计算机相比较）来作出响应