Java多線程服務器一直是我們不斷的研究和創新的技術，下面我們就來看看如何才能更好的使用相關服務。們的Java多線程服務器研究完了。在我們接著討論帶有連接池示例之前，讓我們回顧一下創建和使用“多線程版”的服務器的步驟：

修改 acceptConnections() 以用缺省為 50（或任何您想要的大于 1 的指定數字）實例化 ServerSocket 。

修改 ServerSocket 的 handleConnection() 以用 ConnectionHandler 的一個實例生成一個新的 Thread 。

借用 RemoteFileServer 的 handleConnection() 方法的代碼實現 ConnectionHandler 類。
附： MultithreadedRemoteFileServer 的完整代碼清單

Java代碼

import java.io.*;   
import java.net.*;   
public class MultithreadedRemoteFileServer {   
protected int listenPort;   
public MultithreadedRemoteFileServer(int aListenPort) {   
listenPort = aListenPort;   
}   
public void acceptConnections() {   
try {   
ServerSocket server = new ServerSocket(listenPort, 5);   
Socket incomingConnection = null;   
while (true) {   
incomingConnection = server.accept();   
handleConnection(incomingConnection);   
}   
}catch (BindException e) {   
System.out.println("Unable to bind to port " + listenPort);   
} catch (IOException e) {   
System.out.println("Unable to instantiate a ServerSocket on port: " + listenPort);   
}   
}   
public void handleConnection(Socket connectionToHandle) {   
new Thread(new ConnectionHandler(connectionToHandle)).start();   
}   
public static void main(String[] args) {   
MultithreadedRemoteFileServer server = new MultithreadedRemoteFileServer(3000);   
server.acceptConnections();   
}   
}   
import java.io.*;  
import java.net.*;  
public class MultithreadedRemoteFileServer {  
protected int listenPort;  
public MultithreadedRemoteFileServer(int aListenPort) {  
listenPort = aListenPort;  
}  
public void acceptConnections() {  
try {  
ServerSocket server = new ServerSocket(listenPort, 5);  
Socket incomingConnection = null;  
while (true) {  
incomingConnection = server.accept();  
handleConnection(incomingConnection);  
}  
} catch (BindException e) {  
System.out.println("Unable to bind to port " + listenPort);  
} catch (IOException e) {  
System.out.println("Unable to instantiate a ServerSocket on port: " + listenPort);  
}  
}  
public void handleConnection(Socket connectionToHandle) {  
new Thread(new ConnectionHandler(connectionToHandle)).start();  
}  
public static void main(String[] args) {  
MultithreadedRemoteFileServer server = new MultithreadedRemoteFileServer(3000);  
server.acceptConnections();  
}  
}  

ConnectionHandler 的完整代碼清單

Java代碼

import java.io.*;   
import java.net.*;   
public class ConnectionHandler implements Runnable {   
protected Socket socketToHandle;   
public ConnectionHandler(Socket aSocketToHandle) {   
socketToHandle = aSocketToHandle;   
}   
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);   
}   
}   
}  

以上就是對Java多線程服務器相關使用的介紹。希望大家有所收獲。

【編輯推薦】

1. Java多線程程序如何掌握基本語法
2. Java多線程同步具體實例講解
3. Java多線程語句具體分類的詳細介紹
4. Java多線程優化之偏向鎖原理分析
5. Java多線程初學者指南系列教程