Java代码

public void handleConnection(Socket connectionToHandle) {   
new Thread(new ConnectionHandler(connectionToHandle)).
start();   
}   
public void handleConnection(Socket connectionToHandle) {  
new Thread(new ConnectionHandler(connectionToHandle)).
start();  
} 

我们对 RemoteFileServer 所做的大改动就体现在这个方法上。我们仍然在服务器接受一个连接之后调用 handleConnection() ，但现在我们把该 Socket 传递给 ConnectionHandler 的一个实例，它是 Runnable 的。我们用 ConnectionHandler 创建一个新 Thread 并启动它。ConnectionHandler 的 run() 方法包含Socket 读／写和读 File 的代码，这些代码原来在 RemoteFileServer 的 handleConnection() 中。

4. 处理连接：第 2 部分

这里是 ConnectionHandler 类的结构：

Java代码

import java.io.*;   import java.net.*;   public class ConnectionHandler implements Runnable{   Socket socketToHandle;   public ConnectionHandler(Socket aSocketToHandle) {   socketToHandle = aSocketToHandle;   }   public void run() {   }   }   import java.io.*;  import java.net.*;  public class ConnectionHandler implements Runnable{  Socket socketToHandle;  public ConnectionHandler(Socket aSocketToHandle) {  socketToHandle = aSocketToHandle;  }  public void run() {  }

这个助手类相当简单。跟我们到目前为止的其它类一样，我们导入 java.net 和 java.io 。该类只有一个实例变量 socketToHandle ，它保存由该实例处理的 Socket 。类的构造器用一个 Socket 实例作参数并将它赋给 socketToHandle 。

请注意该类实现了 Runnable 接口。实现这个接口的类都必须实现 run() 方法，我们的类就是这样做的。稍后我们将探究 run() 的细节。现在只需知道它将实际处理连接，所用的代码跟我们先前在 RemoteFileServer 类中看到的是一样的。

实现 run()

这里我们实现 run() 方法，它将攫取我们的连接的流，用它来读写该连接，并在任务完成之后关闭它：

Java代码

public void run() {   try {   PrintWriter streamWriter = new PrintWriter(socketToHandle.getOutputStream());   BufferedReader streamReader =   new BufferedReader(new InputStreamReader(socketToHandle.getInputStream()));   String fileToRead = streamReader.readLine();   BufferedReader fileReader = new BufferedReader(new FileReader(fileToRead));   String line = null;   while ((line = fileReader.readLine()) != null)   streamWriter.println(line);   fileReader.close();   streamWriter.close();   streamReader.close();   } catch (Exception e) {   System.out.println("Error handling a client: " + e);   }   }   public void run() {  try {  PrintWriter streamWriter = new PrintWriter(socketToHandle.getOutputStream());  BufferedReader streamReader =  new BufferedReader(new InputStreamReader(socketToHandle.getInputStream()));  String fileToRead = streamReader.readLine();  BufferedReader fileReader = new BufferedReader(new FileReader(fileToRead));  String line = null;  while ((line = fileReader.readLine()) != null)  streamWriter.println(line);  fileReader.close();  streamWriter.close();  streamReader.close();  } catch (Exception e) {  System.out.println("Error handling a client: " + e);  }  }

ConnectionHandler的 run() 方法所做的事情就是 RemoteFileServer 上的 handleConnection() 所做的事情。首先，我们把 InputStream 和 OutputStream 分别包装（用 Socket 的 getOutputStream() 和 getInputStream() ）进 BufferedReader 和 PrintWriter 。然后我们用这些代码逐行地读目标文件：

Java代码

FileReader fileReader = new FileReader(new File(streamReader.readLine()));   BufferedReader bufferedFileReader = new BufferedReader(fileReader);   String line = null;   while ((line = bufferedFileReader.readLine()) != null) {   streamWriter.println(line);   }   FileReader fileReader = new FileReader(new File(streamReader.readLine()));  BufferedReader bufferedFileReader = new BufferedReader(fileReader);  String line = null;  while ((line = bufferedFileReader.readLine()) != null) {  streamWriter.println(line);  }

请记住我们应该从客户机获取一条有效的文件路径，这样用该路径名构造一个新 File ，把它包装进 FileReader 以处理读文件的操作，然后把它包装进 BufferedReader 以让我们逐行地读该文件。我们在 Java while循环语句中调用 BufferedReader 上的 readLine() 直到不再有要读的行。请记注，对 readLine() 的调用将造成阻塞，直到有字节来到为止。我们获取一些字节之后就把它们放到本地的 line 变量中，然后写出到客户机上。