12.3.2 模擬網絡數據發送
在實際的網絡程序開發中,由於網絡通訊一般都需要消耗時間,所以網絡通訊的內容一般都啟動專門的線程進行處理。
這樣,在一個最簡單的網絡程序程序中,至少就包含了兩個線程:處理界面繪制和接收用戶輸入的系統線程,以及至少一個網絡通訊線程。
下面以一個簡單的模擬程序,實現模擬網絡數據的發送功能,關於更詳細的網絡編程中線程的使用,可以參看後續的網絡編程章節。
在該示例代碼中,用戶在控制台輸入需要發送的內容,程序接收到用戶的輸入以後,啟動一個單獨的線程進行網絡通訊,然後用戶可以繼續在控制台進行輸入。示例代碼如下所示:
package example2;
import java.io.*;
/**
* 模擬網絡數據發送的測試類
*/
public class TestNet {
public static void main(String[] args) {
BufferedReader br = null;
String input;
try{
//初始化輸入流
br = new BufferedReader(
new InputStreamReader(System.in));
//循環接收輸入
while(true){
System.out.println("請輸入內容(quit代表退出程序):");
//讀取控制台輸入
input = br.readLine();
//判斷是否是結束
if(input.equals("quit")){
break; //結束程序
}
//模擬發送
NetDemoThread ndt = new NetDemoThread(input);
}
}catch(Exception e){
}finally{
try {
br.close();
} catch (Exception e) {}
}
}
}
package example2;
/**
* 通過繼承Thread類的方式模擬網絡通訊線程
*/
public class NetDemoThread extends Thread {
String data;
public NetDemoThread(String data){
this.data = data;
start();
}
public void run(){
try{
System.out.println("開始發送");
Thread.sleep(10000); //模擬網絡發送的延遲
System.out.println("發送完成,發送的內容是:" + data);
}catch(Exception e){}
}
}
在該示例中,TestNet類實現接收控制台輸入,並在接收到用戶輸入以後,啟動網絡通訊線程發送數據,當用戶在控制台輸入quit時,結束程序。NetDemoThread類實現模擬網絡通訊線程,在需要發送網絡數據時,創建一個NetDemoThread類型的線程對象,並將需要發送的內容作為參數傳入到該對象的內容,在run方法中,輸出線程的狀態,並使用一個延遲10秒,比實際的延遲要誇大很多,的代碼模擬發送時的線程延遲。由於這裡的延遲比較大,所以如果用戶輸入的數據速度比較快的話,會存在多個網絡通訊的線程同時運行。
下面是程序的運行結果:
請輸入內容(quit代表退出程序):
abc
請輸入內容(quit代表退出程序):
開始發送
123
請輸入內容(quit代表退出程序):
開始發送
tbc
請輸入內容(quit代表退出程序):
開始發送
faga
請輸入內容(quit代表退出程序):
開始發送
發送完成,發送的內容是:abc
hfsd
請輸入內容(quit代表退出程序):
開始發送
發送完成,發送的內容是:123
發送完成,發送的內容是:tbc
發送完成,發送的內容是:faga
發送完成,發送的內容是:hfsd
quit
在該次運行中,用戶依次輸入了:123、tbc、faga和hfsd,當用戶輸入完成以後,模擬網絡通訊的線程就被啟動,這個可以從輸出“開始發送”語句看出,當內容發送完成以後線程自然結束。最後輸入quit指令結束程序。
當然,該程序會在用戶輸入的內容不同時出現很多不同的結果,這些結果能夠使你體會到兩點:
1、多個網絡通訊的線程在同時工作,互不干擾。
2、當輸入quit以後,如果還有網絡通訊的線程沒有結束,則程序會等待到網絡通訊的線程結束以後才真正結束。
當然,這兩個簡單的例子只能夠使你熟悉基本的多線程編程的使用,還沒有進入到多線程編程的核心。
其實,當多線程一起運行時,除了帶來一系列的優勢以外,還會帶來一系列的問題。例如現實社會中,一個兒子繼承遺產時就很簡單,但是當有多個兒子呢?所以,下面來深入線程的概念,理解多線程編程存在的問題以及解決辦法。