Java while循環語句會有很多重要的環節都使用到。下面我們就來看看相關的問題解決方案和相關的代碼。希望大家在之后的學習和生活中能更好的使用Java while循環語句。

這里我們將討論 handleConnection() 方法的結構，這個方法生成一個新的 Thread 來處理每個連接。我們將分兩部分討論這個問題。這一屏我們將著重該方法本身，然后在下一屏研究該方法所使用的 ConnectionHandler 助手類的結構。

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 變量中，然后寫出到客戶機上。完成讀寫操作之后，我們關閉打開的流。

【編輯推薦】

1. 用Java多線程實現無阻塞讀取遠程文件
2. 使用Java多線程實現任務分發
3. Java多線程初學者指南系列教程
4. Java多線程優化之偏向鎖原理分析
5. Java多線程程序如何掌握基本語法