摘要：在Java出現之前，編寫多線程程序是一件煩瑣且伴隨許多不安全因素的事情。利用Java，編寫安全高效的多線程程序變得簡單，而且利用多線程和Java的網絡包我們可以方便的實現多線程服務器程序。

　　Java是伴隨Internet的大潮產生的，對網絡及多線程具有內在的支持，具有網絡時代編程語言的一切特點。從Java的當前應用看，Java主要用于在Internet或局域網上的網絡編程，而且將Java作為主流的網絡編程語言的趨勢愈來愈明顯。實際工作中，我們除了使用商品化的服務器軟件外，時常需要按照實際環境編寫自己的服務器軟件，以完成特定任務或與特定客戶端軟件實現交互。在實現服務器程序時，為提高程序運行效率，降低用戶等待時間，我們應用了在Java Applet中常見的多線程技術。

　　一、Java中的服務器程序與多線程

　　在Java之前，沒有一種主流編程語言能夠提供對網絡編程的固有支持。在其他語言環境中，實現網絡程序往往需要深入依賴于操作平臺的網絡API的技術中去，而Java提供了對網絡支持的無平臺相關性的完整軟件包，使程序員沒有必要為系統網絡支持的細節而煩惱。
　　Java軟件包內在支持的網絡協議為TCP/IP，也是當今的廣域網/局域網協議。Java有關網絡的類及接口定義在java.net包中。客戶端軟件通常使用java.net包中的核心類Socket與服務器的某個端口建立連接，而服務器程序不同于客戶機，它需要初始化一個端口進行監聽，遇到連接呼叫，才與相應的客戶機建立連接。Java.net包的ServerSocket類包含了編寫服務器系統所需的一切。下面給出ServerSocket類的部分定義。

public class ServerSocket
{ public ServerSocket(int port)
throws IOException ；
public Socket accept() throws IOException ；
public InetAddress getInetAddress() ；
public int getLocalPort() ；
public void close() throws IOException ；
public synchronized void setSoTimeout (int timeout) throws SocketException ；
public synchronized int getSoTimeout() throws IOException ； }

　　ServerSocket構造器是服務器程序運行的基礎，它將參數port指定的端口初始化作為該服務器的端口，監聽客戶機連接請求。Port的范圍是0到65536，但0到1023是標準Internet協議保留端口，而且在Unix主機上，這些端口只有root用戶可以使用。一般自定義的端口號在8000到16000之間。僅初始化了ServerSocket還是遠遠不夠的，它沒有同客戶機交互的套接字（Socket），因此需要調用該類的accept方法接受客戶呼叫。Accept()方法直到有連接請求才返回通信套接字(Socket)的實例。通過這個實例的輸入、輸出流，服務器可以接收用戶指令，并將相應結果回應客戶機。

　　ServerSocket類的getInetAddress和getLocalPort方法可得到該服務器的IP地址和端口。setSoTimeout和getSoTimeout方法分別是設置和得到服務器超時設置，如果服務器在timout設定時間內還未得到accept方法返回的套接字實例，則拋出IOException的異常。

　　Java的多線程可謂是Java編程的精華之一，運用得當可以極大地改善程序的響應時間，提高程序的并行性。在服務器程序中，由于往往要接收不同客戶機的同時請求或命令，因此可以對每個客戶機的請求生成一個命令處理線程，同時對各用戶的指令作出反應。在一些較復雜的系統中，我們還可以為每個數據庫查詢指令生成單獨的線程，并行對數據庫進行操作。實踐證明，采用多線程設計可以很好的改善系統的響應，并保證用戶指令執行的獨立性。由于Java本身是"線程安全"的，因此有一條編程原則是能夠獨立在一個線程中完成的操作就應該開辟一個新的線程。

　　Java中實現線程的方式有兩種，一是生成Thread類的子類，并定義該子類自己的run方法，線程的操作在方法run中實現。但我們定義的類一般是其他類的子類，而Java又不允許多重繼承，因此第二種實現線程的方法是實現Runnable接口。通過覆蓋Runnable接口中的run方法實現該線程的功能。本文例子采用種方法實現線程。

　　二、多線程服務器程序舉例

　　以下是我們在項目中采用的多線程服務器程序的架構，可以在此基礎上對命令進行擴充。本例未涉及數據庫。如果在線程運行中需要根據用戶指令對數據庫進行更新操作，則應注意線程間的同步問題，使同一更新方法一次只能由一個線程調用。這里我們有兩個類，receiveServer包含啟動代碼（main()），并初始化ServerSocket的實例，在accept方法返回用戶請求后，將返回的套接字（Socket）交給生成的線程類serverThread的實例，直到該用戶結束連接。

//類receiveServer
import java.io.*;
import java.util.*;
import java.net.*;
public class receiveServer{
final int RECEIVE_PORT=9090; //該服務器的端口號
//receiveServer的構造器public receiveServer() {ServerSocket rServer=null;
//ServerSocket的實例
Socket request=null;
//用戶請求的套接字Thread receiveThread=null;
try{ rServer=new ServerSocket(RECEIVE_PORT);
//初始化ServerSocket System.out.println("Welcome to the server!");
System.out.println(new Date());
System.out.println("The server is ready!");
System.out.println("Port: "+RECEIVE_PORT);
while(true){ //等待用戶請求 request=rServer.accept(); //接收客戶機連接請求receiveThread=new serverThread(request);
//生成serverThread的實例
receiveThread.start();
//啟動serverThread線程
}
}
catch(IOException e){ System.out.println(e.getMessage()) ;
} } public static void main(String args[]){ new receiveServer();
} //end of main} //end of class//類serverThreadimport java.io.*;
import java.net.*;
class serverThread extends Thread {Socket clientRequest;
//用戶連接的通信套接字BufferedReader input;
//輸入流PrintWriter output;
//輸出流 public serverThread(Socket s) { //serverThread的構造器 this.clientRequest=s;
//接收receiveServer傳來的套接字 InputStreamReader reader;
OutputStreamWriter writer;
try{ //初始化輸入、輸出流 reader=new InputStreamReader(clientRequest.getInputStream()); writer=new OutputStreamWriter(clientRequest.getOutputStream()); input=new BufferedReader(reader);
output=new PrintWriter(writer,true); }catch(IOException e){ System.out.println(e.getMessage());} output.println("Welcome to the server!");
//客戶機連接歡迎詞 output.println("Now is: "+new java.util.Date()+" "+ "Port:"+clientRequest.getLocalPort());
output.println("What can I do for you?");
} public void run(){ //線程的執行方法 String command=null;
//用戶指令 String str=null;
boolean done=false;
while(!done){ try{str=input.readLine();
//接收客戶機指令 }catch(IOException e){ System.out.println(e.getMessage());} command=str.trim().toUpperCase();
if(str==null || command.equals("QUIT")) //命令quit結束本次連接 done=true;
else if(command.equals("HELP")){ //命令help查詢本服務器可接受的命令 output.println("query");
output.println("quit");
output.println("help"); }
else if(command.startsWith("QUERY")){ //命令query output.println("OK to query something!");
}//else if ........ //在此可加入服務器的其他指令 else if(!command.startsWith("HELP") && !command.startsWith("QUIT") && !command.startsWith("QUERY")){output.println("Command not Found!
Please refer to the HELP!"); } }
//end of while
try
{ clientRequest.close();
//關閉套接字
}catch(IOException e){ System.out.println(e.getMessage());
}command=null;
}
//end of run

　　啟動該服務器程序后，可用telnet machine port命令連接，其中machine為本機名或地址，port為程序中指定的端口。也可以編寫特定的客戶機軟件通過TCP的Socket套接字建立連接。