无论何时如果您创建了一个无法绑定到指定端口（可能是因为别的什么控制了该端口）的ServerSocket，Java代码都将抛出一个错误。所以这里我们必须捕捉可能的BindException。就跟在客户机端上时一样，我们必须捕捉IOException，当我们试图在ServerSocket上接受连接时，它就会被抛出。请注意，您可以通过用毫秒数调用setSoTimeout()来为accept()调用设置超时，以避免实际长时间的等待。调用setSoTimeout()将使accept()经过指定占用时间后抛出IOException。
处理连接
这里我们实现handleConnection()方法，它将用连接的流来接收输入和写输出：
publicvoidhandleConnection(SocketincomingConnection){try{OutputStreamoutputToSocket=incomingConnection.getOutputStream();
InputStreaminputFromSocket=incomingConnection.getInputStream();
BufferedReaderstreamReader=newBufferedReader(newInputStreamReader(inputFromSocket));
FileReaderfileReader=newFileReader(newFile(streamReader.readLine()));
BufferedReaderbufferedFileReader=newBufferedReader(fileReader);
PrintWriterstreamWriter=newPrintWriter(incomingConnection.getOutputStream());
Stringline=null;
while((line=bufferedFileReader.readLine())!=null){streamWriter.println(line);}fileReader.close();
streamWriter.close();streamReader.close();}
catch(Exceptione){System.out.println("Errorhandlingaclient:"+e);
e.printStackTrace();}}
跟在客户机中一样，我们用getOutputStream()和getInputStream()来获取与我们刚创建的Socket相关联的流。跟在客户机端一样，我们把InputStream包装进BufferedReader，把OutputStream包装进PrintWriter。在服务器端上，我们需要添加一些代码，用来读取目标文件和把内容逐行发送到客户机。这里是重要的代码：
FileReaderfileReader=newFileReader(newFile(streamReader.readLine()));
BufferedReaderbufferedFileReader=newBufferedReader(fileReader);
Stringline=null;
while((line=bufferedFileReader.readLine())!=null){streamWriter.println(line);}
这些代码值得详细解释。让我们一点一点来看：
FileReaderfileReader=newFileReader(newFile(streamReader.readLine()));
首先，我们使用Socket的InputStream的BufferedReader。我们应该获取一条有效的文件路径，所以我们用该路径名构造一个新File。我们创建一个新FileReader来处理读文件的操作。
BufferedReaderbufferedFileReader=newBufferedReader(fileReader);
这里我们把FileReader包装进BufferedReader以使我们能够逐行地读该文件。
接着，我们调用BufferedReader的readLine()。这个调用将造成阻塞直到有字节到来。我们获取一些字节之后就把它们放到本地的line变量中，然后再写出到客户机上。完成读写操作之后，我们就关闭打开的流。
请注意我们在完成从Socket的读操作之后关闭streamWriter和streamReader。您或许会问我们为什么不在读取文件名之后立刻关闭streamReader。原因是当您这样做时，您的客户机将不会获取任何数据。如果您在关闭streamWriter之前关闭streamReader，则您可以往Socket写任何东西，但却没有任何数据能通过通道（通道被关闭了）。
总结一下服务器
在我们接着讨论另一个更实际的示例之前，让我们回顾一下创建和使用ServerSocket的步骤：
1.用一个您想让它侦听传入客户机连接的端口来实例化一个ServerSocket（如有问题则抛出Exception）。
2.调用ServerSocket的accept()以在等待连接期间造成阻塞。
3.获取位于该底层Socket的流以进行读写操作。
4.按使事情简单化的原则包装流。
5.对Socket进行读写。
6.关闭打开的流（并请记住，永远不要在关闭Writer之前关闭Reader）。
6创建多线程Socket服务器
前面的示例教给您基础知识，但并不能令您更深入。如果您到此就停止了，那么您一次只能处理一台客户机。原因是handleConnection()是一个阻塞方法。只有当它完成了对当前连接的处理时，服务器才能接受另一个客户机。在多数时候，您将需要（也有必要）一个多线程服务器。
创建MultithreadedRemoteFileServer类
importjava.io.*;
importjava.net.*;
publicclassMultithreadedRemoteFileServer{intlistenPort;
publicMultithreadedRemoteFileServer(intlistenPort){this.listenPort=listenPort;}
//允许客户机连接到服务器,等待客户机请求
publicvoidacceptConnections(){try{ServerSocketserver=newServerSocket(listenPort,5);
SocketincomingConnection=null;
while(true){incomingConnection=server.accept();
handleConnection(incomingConnection);}}
catch(BindExceptione){System.out.println("Unabletobindtoport"+listenPort);}
catch(IOExceptione){System.out.println("UnabletoinstantiateaServerSocketonport:"+listenPort);}}
//与客户机Socket交互以将客户机所请求的文件的内容发送到客户机
publicvoidhandleConnection(SocketconnectionToHandle){newThread(newConnectionHandler(connectionToHandle)).start();}
publicstaticvoidmain(Stringargs[]){MultithreadedRemoteFileServerserver=newMultithreadedRemoteFileServer(1001);
server.acceptConnections();}}
这里我们实现改动过acceptConnections()方法，它将创建一个能够处理待发请求的ServerSocket，并告诉ServerSocket接受连接。
新的server仍然需要acceptConnections()，所以这些代码实际上是一样的。突出显示的行表示一个重大的不同。对这个多线程版，我们现在可以指定客户机请求的最大数目，这些请求都能在实例化ServerSocket期间处于待发状态。如果我们没有指定客户机请求的最大数目，则我们假设使用缺省值50。
这里是它的工作机制。假设我们指定待发数（backlog值）是5并且有五台客户机请求连接到我们的服务器。我们的服务器将着手处理第一个连接，但处理该连接需要很长时间。由于我们的待发值是5，所以我们一次可以放五个请求到队列中。我们正在处理一个，所以这意味着还有其它五个正在等待。等待的和正在处理的一共有六个。当我们的服务器仍忙于接受一号连接（记住队列中还有2?6号）时，如果有第七个客户机提出连接申请，那么，该第七个客户机将遭到拒绝。我们将在带有连接池服务器示例中说明如何限定能同时连接的客户机数目。
处理连接：
publicvoidhandleConnection(SocketconnectionToHandle){newThread(newConnectionHandler(connectionToHandle)).start();}
我们对RemoteFileServer所做的大改动就体现在这个方法上。我们仍然在服务器接受一个连接之后调用handleConnection()，但现在我们把该Socket传递给ConnectionHandler的一个实例，它是Runnable的。我们用ConnectionHandler创建一个新Thread并启动它。ConnectionHandler的run()方法包Socket读／写和读File的代码，这些代码原来在RemoteFileServer的handleConnection()中。
创建ConnectionHandler类
importjava.io.*;
importjava.net.*;
publicclassConnectionHandlerimplementsRunnable{protectedSocketsocketToHandle;
publicConnectionHandler(SocketsocketToHandle){this.socketToHandle=socketToHandle;}
publicvoidrun(){try{PrintWriterstreamWriter=newPrintWriter(socketToHandle.getOutputStream());
BufferedReaderstreamReader=newBufferedReader(newInputStreamReader(socketToHandle.getInputStream()));
StringfileToRead=streamReader.readLine();
BufferedReaderfileReader=newBufferedReader(newFileReader(fileToRead));
Stringline=null;
while((line=fileReader.readLine())!=null){streamWriter.println(line);}fileReader.close();
streamWriter.close();streamReader.close();}
catch(Exceptione){System.out.println("Errorhandlingaclient:"+e);
e.printStackTrace();}}}
这个助手类相当简单。跟我们到目前为止的其它类一样，我们导入java.net和java.io。该类只有一个实例变量socketToHandle，它保存由该实例处理的Socket。
类的构造器用一个Socket实例作参数并将它赋给socketToHandle。
请注意该类实现了Runnable接口。实现这个接口的类都必须实现run()方法。这里我们实现run()方法，它将攫取我们的连接的流，用它来读写该连接，并在任务完成之后关闭它。ConnectionHandler的run()方法所做的事情就是RemoteFileServer上的handleConnection()所做的事情。首先，我们把InputStream和OutputStream分别包装（用Socket的getOutputStream()和getInputStream()）进BufferedReader和PrintWriter。然后我们用这些代码逐行地读目标文件：
PrintWriterstreamWriter=newPrintWriter(socketToHandle.getOutputStream());
BufferedReaderstreamReader=newBufferedReader(newInputStreamReader(socketToHandle.getInputStream()));
StringfileToRead=streamReader.readLine();BufferedReaderfileReader=newBufferedReader(newFileReader(fileToRead));
Stringline=null;
while((line=fileReader.readLine())!=null){streamWriter.println(line);}
请记住我们应该从客户机获取一条有效的文件路径，这样用该路径名构造一个新File，把它包装进FileReader以处理读文件的操作，然后把它包装进BufferedReader以让我们逐行地读该文件。我们while循环中调用BufferedReader上的readLine()直到不再有要读的行。请记注，对readLine()的调用将造成阻塞，直到有字节来到为止。我们获取一些字节之后就把它们放到本地的line变量中，然后写出到客户机上。完成读写操作之后，我们关闭打开的流。
总结一下多线程服务器
让我们回顾一下创建和使用“多线程版”的服务器的步骤：
1.修改acceptConnections()以用缺省为50（或任何您想要的大于1的指定数字）实例化ServerSocket。
2.修改ServerSocket的handleConnection()以用ConnectionHandler的一个实例生成一个新的Thread。
3.借用RemoteFileServer的handleConnection()方法的代码实现ConnectionHandler类。
7创建带有连接池的Socket服务器
我们现在已经拥有的MultithreadedServer每当有客户机申请一个连接时都在一个新Thread中创建一个新ConnectionHandler。这意味着可能有一捆Thread“躺”在我们周围。而且创建Thread的系统开销并不是微不足道的。如果性能成为了问题（也请不要事到临头才意识到它），更高效地处理我们的服务器是件好事。那么，我们如何更高效地管理服务器端呢？我们可以维护一个进入的连接池，一定数量的ConnectionHandler将为它提供服务。这种设计能带来以下好处：
•它限定了允许同时连接的数目。
•我们只需启动ConnectionHandlerThread一次。
幸运的是，跟在我们的多线程示例中一样，往代码中添加“池”不需要来一个大改动。事实上，应用程序的客户机端根本就不受影响。在服务器端，我们在服务器启动时创建一定数量的ConnectionHandler，我们把进入的连接放入“池”中并让ConnectionHandler打理剩下的事情。这种设计中有很多我们不打算讨论的可能存在的技巧。例如，我们可以通过限定允许在“池”中建立的连接的数目来拒绝客户机。
请注意：我们将不会再次讨论acceptConnections()。这个方法跟前面示例中的完全一样。它无限循环地调用ServerSocket上的accept()并把连接传递到handleConnection()。
创建PooledRemoteFileServer类
importjava.io.*;
importjava.net.*;
importjava.util.*;
publicclassPooledRemoteFileServer{protectedintmaxConnections;
protectedintlistenPort;protectedServerSocketserverSocket;
publicPooledRemoteFileServer(intaListenPort,intmaxConnections){listenPort=aListenPort;
this.maxConnections=maxConnections;}
publicvoidacceptConnections(){try{ServerSocketserver=newServerSocket(listenPort,5);
SocketincomingConnection=null;
while(true){incomingConnection=server.accept();
handleConnection(incomingConnection);}}catch(BindExceptione){System.out.println("");}
catch(IOExceptione){System.out.println(""+listenPort);}}protectedvoidhandleConnection(SocketconnectionToHandle){PooledConnectionHandler.processRequest(connectionToHandle);}
publicvoidsetUpHandlers(){for(inti=0;i
server.setUpHandlers();
server.acceptConnections();}}
请注意一下您现在应该熟悉了的import语句。我们给类以下实例变量以保存：
•我们的服务器能同时处理的活动客户机连接的最大数目
•进入的连接的侦听端口（我们没有指定缺省值，但如果您想这样做，并不会受到限制）
•将接受客户机连接请求的ServerSocket
类的构造器用的参数是侦听端口和连接的最大数目
我们的类有一个main()方法和三个其它方法。稍后我们将探究这些方法的细节。现在只须知道setUpHandlers()创建数目为maxConnections的大量PooledConnectionHandler，而其它两个方法则与我们前面已经看到的相似：acceptConnections()在ServerSocket上侦听传入的客户机连接，而handleConnection则在客户机连接一旦被建立后就实际处理它。
实现main()
这里我们实现需作改动的main()方法，该方法将创建能够处理给定数目的客户机连接的PooledRemoteFileServer，并告诉它接受连接：
publicstaticvoidmain(Stringargs[]){PooledRemoteFileServerserver=newPooledRemoteFileServer(1001,3);
server.setUpHandlers();server.acceptConnections();}
我们的main()方法很简单。我们实例化一个新的PooledRemoteFileServer，它将通过调用setUpHandlers()来建立三个PooledConnectionHandler。一旦服务器就绪，我们就告诉它acceptConnections()。
建立连接处理程序
publicvoidsetUpHandlers(){for(inti=0;i＜maxConnections;i++){PooledConnectionHandlercurrentHandler=newPooledConnectionHandler();
newThread(currentHandler,"Handler"+i).start();}}
setUpHandlers()方法创建maxConnections（例如3）个PooledConnectionHandler并在新Thread中激活它们。用实现了Runnable的对象来创建Thread使我们可以在Thread调用start()并且可以期望在Runnable上调用了run()。换句话说，我们的PooledConnectionHandler将等着处理进入的连接，每个都在它自己的Thread中进行。我们在示例中只创建三个Thread，而且一旦服务器运行，这就不能被改变。
处理连接
这里我们实现需作改动的handleConnections()方法，它将委派PooledConnectionHandler处理连接：
protectedvoidhandleConnection(SocketconnectionToHandle){PooledConnectionHandler.processRequest(connectionToHandle);}
我们现在叫PooledConnectionHandler处理所有进入的连接（processRequest()是一个静态方法）。
创建PooledRemoteFileServer类
importjava.io.*;
importjava.net.*;
importjava.util.*;
publicclassPooledConnectionHandlerimplementsRunnable{protectedSocketconnection;
protectedstaticListpool=newLinkedList();
publicPooledConnectionHandler(){}publicvoidhandleConnection(){try{PrintWriterstreamWriter=newPrintWriter(connection.getOutputStream());
BufferedReaderstreamReader=newBufferedReader(newInputStreamReader(connection.getInputStream()));
StringfileToRead=streamReader.readLine();
BufferedReaderfileReader=newBufferedReader(newFileReader(fileToRead));
Stringline=null;
while((line=fileReader.readLine())!=null)streamWriter.println(line);
fileReader.close();
streamWriter.close();
streamReader.close();}
catch(FileNotFoundExceptione){System.out.println("");}catch(IOExceptione){System.out.println(""+e);}}
publicstaticvoidprocessRequest(SocketrequestToHandle){synchronized(pool){pool.add(pool.size(),requestToHandle);pool.notifyAll();}}
publicvoidrun(){while(true){synchronized(pool){while(pool.isEmpty()){try{pool.wait();}
catch(InterruptedExceptione){e.printStackTrace();}}connection=(Socket)pool.remove(0);}
handleConnection();}}}
这个助手类与ConnectionHandler非常相似，但它带有处理连接池的手段。该类有两个实例变量：
•connection是当前正在处理的Socket
•名为pool的静态LinkedList保存需被处理的连接
填充连接池
这里我们实现PooledConnectionHandler上的processRequest()方法，它将把传入请求添加到池中，并告诉其它正在等待的对象该池已经有一些内容：
publicstaticvoidprocessRequest(SocketrequestToHandle){synchronized(pool){pool.add(pool.size(),requestToHandle);
pool.notifyAll();}}
synchronized块是个稍微有些不同的东西。您可以同步任何对象上的一个块，而不只是在本身的某个方法中含有该块的对象。在我们的示例中，processRequest()方法包含有一个pool（请记住它是一个LinkedList，保存等待处理的连接池）的synchronized块。我们这样做的原因是确保没有别人能跟我们同时修改连接池。
既然我们已经保证了我们是唯一“涉水”池中的人，我们就可以把传入的Socket添加到LinkedList的尾端。一旦我们添加了新的连接，我们就用以下代码通知其它正在等待该池的Thread，池现在已经可用：
pool.notifyAll();
Object的所有子类都继承这个notifyAll()方法。这个方法，连同我们下一屏将要讨论的wait()方法一起，就使一个Thread能够让另一个Thread知道一些条件已经具备。这意味着该第二个Thread一定正在等待那些条件的满足。
从池中获取连接
这里我们实现PooledConnectionHandler上需作改动的run()方法，它将在连接池上等待，并且池中一有连接就处理它：
publicvoidrun(){while(true){synchronized(pool){while(pool.isEmpty()){try{pool.wait();}
catch(InterruptedExceptione){e.printStackTrace();}}
connection=(Socket)pool.remove(0);}
handleConnection();}}
回想一下在前面讲过的：一个Thread正在等待有人通知它连接池方面的条件已经满足了。在我们的示例中，请记住我们有三个PooledConnectionHandler在等待使用池中的连接。每个PooledConnectionHandler都在它自已的Thread中运行，并通过调用pool.wait()产生阻塞。当我们的processRequest()在连接池上调用notifyAll()时，所有正在等待的PooledConnectionHandler都将得到“池已经可用”的通知。然后各自继续前行调用pool.wait()，并重新检查while(pool.isEmpty())循环条件。除了一个处理程序，其它池对所有处理程序都将是空的，因此，在调用pool.wait()时，除了一个处理程序，其它所有处理程序都将再次产生阻塞。恰巧碰上非空池的处理程序将跳出while(pool.isEmpty())循环并攫取池中的第一个连接：
connection=(Socket)pool.remove(0);
处理程序一旦有一个连接可以使用，就调用handleConnection()处理它。
在我们的示例中，池中可能永远不会有多个连接，只是因为事情很快就被处理掉了。如果池中有一个以上连接，那么其它处理程序将不必等待新的连接被添加到池。当它们检查pool.isEmpty()条件时，将发现其值为假，然后就从池中攫取一个连接并处理它。
还有另一件事需注意。当run()拥有池的互斥锁时，processRequest()如何能够把连接放到池中呢？答案是对池上的wait()的调用释放锁，而wait()接着就在自己返回之前再次攫取该锁。这就使得池对象的其它同步代码可以获取该锁。
处理连接：再一次
这里我们实现需做改动的handleConnection()方法，该方法将攫取连接的流，使用它们，并在任务完成之后清除它们：
publicvoidhandleConnection()
{try{PrintWriterstreamWriter=newPrintWriter(connection.getOutputStream());
BufferedReaderstreamReader=newBufferedReader(newInputStreamReader(connection.getInputStream()));
StringfileToRead=streamReader.readLine();
BufferedReaderfileReader=newBufferedReader(newFileReader(fileToRead));
Stringline=null;while((line=fileReader.readLine())!=null)streamWriter.println(line);
fileReader.close();
streamWriter.close();
streamReader.close();}
catch(FileNotFoundExceptione){System.out.println("");}
catch(IOExceptione){System.out.println(""+e);}}
跟在多线程服务器中不同，我们的PooledConnectionHandler有一个handleConnection()方法。这个方法的代码跟非池式的ConnectionHandler上的run()方法的代码完全一样。首先，我们把OutputStream和InputStream分别包装进（用Socket上的getOutputStream()和getInputStream()）BufferedReader和PrintWriter。然后我们逐行读目标文件，就象我们在多线程示例中做的那样。再一次，我们获取一些字节之后就把它们放到本地的line变量中，然后写出到客户机。完成读写操作之后，我们关闭FileReader和打开的流。
总结一下带有连接池的服务器
让我们回顾一下创建和使用“池版”服务器的步骤：
1.创建一个新种类的连接处理程序（我们称之为PooledConnectionHandler）来处理池中的连接。
2.修改服务器以创建和使用一组PooledConnectionHandler。
Java语言简化了套接字在应用程序中的使用。它的基础实际上是java.net包中的Socket和ServerSocket类。一旦您理解了表象背后发生的情况，就能容易地使用这些类。在现实生活中使用套接字只是这样一件事，即通过贯彻优秀的OO设计原则来保护应用程序中各层间的封装。我们为您展示了一些有帮助的类。这些类的结构对我们的应用程序隐藏了Socket交互作用的低级细节?使应用程序能只使用可插入的ClientSocketFacade和ServerSocketFacade。在有些地方（在Facade内），您仍然必须管理稍显杂乱的字节细节，但您只须做一次就可以了。更好的是，您可以在将来的项目中重用这些低级别的助手类。
[1] [2]