原文:http://ivan4126.blog.163.com/blog/static/20949109220135284278806/

最近在開發中遇到一個問題，就是如何判斷遠端伺服器是否已經斷開連線，如果斷開那麼需要重新連線。

首先想到socket類的方法isClosed()、isConnected()、isInputStreamShutdown()、isOutputStreamShutdown()等，但經過試驗並檢視相關文件，這些方法都是本地端的狀態，無法判斷遠端是否已經斷開連線。

然後想到是否可以通過OutputStream傳送一段測試資料，如果傳送失敗就表示遠端已經斷開連線，類似ping，但是這樣會影響到正常的輸出資料，遠端無法把正常資料和測試資料分開。

最後又回到socket類，發現有一個方法sendUrgentData，檢視文件後得知它會往輸出流傳送一個位元組的資料，只要對方Socket的SO_OOBINLINE屬性沒有開啟，就會自動捨棄這個位元組，而SO_OOBINLINE屬性預設情況下就是關閉的，太好了，正是我需要的！

java socekt 同步套節字程式設計主要用到java.net.Socket類，通常情況下我們需要socket的長連線模式。其次就是在連線的另一端斷開之後需要及時響應。

對於連線的判斷，socket提供的isClosed,isConnected等都是判斷本地套節字的狀態。要判斷運程的連線，可以通過傳送緊急資料來判斷，緊急資料傳送成功與否，就表示遠端是否斷開。

1. publicclass Nksocket extends Thread{  
2. public String ip=null;//連線伺服器的IP
3. public Integer port=null;//連線伺服器的埠
4. private Socket socket=null;//套節字物件
5. privateboolean close = false; // 關閉連線標誌位，true表示關閉，false表示連線
6. private Integer sotimeout=1*1*10;//超時時間，以毫秒為單位
7. //------------------------------------------------------------------------------
8. public Nksocket(){  
9.    init();  
10. }  
11. public Nksocket(String ip,Integer port){  
12.    setIp(ip);  
13.    setPort(port);  
14.    init();  
15. }  
16. /** 
17. * 初始化socket物件 
18. */
19. publicvoid init(){  
20.    try {  
21.     InetAddress address = InetAddress.getByName(getIp());  
22.     socket = new Socket(address,getPort());  
23.     socket.setKeepAlive(true);//開啟保持活動狀態的套接字
24.     socket.setSoTimeout(sotimeout);//設定超時時間
25.     close=!Send(socket,"2");//傳送初始資料，傳送成功則表示已經連線上，傳送失敗表示已經斷開
26.    }catch(UnknownHostException e) {  
27.     e.printStackTrace();  
28.    }catch(IOException e){  
29.     e.printStackTrace();  
30.    }  
31. }  
32. /** 
33. * 讀資料執行緒 
34. */
35. publicvoid run() {  
36.    while(true){  
37.     //---------讀資料---------------------------
38.     close = isServerClose(socket);//判斷是否斷開
39.     if(!close){//沒有斷開，開始讀資料
40.      String readtext = ReadText(socket);  
41.      if(readtext!=null && readtext.trim().length()>0){  
42.       System.out.println("讀取資料："+readtext);  
43.      }  
44.     }  
45.     //---------建立連線-------------------------
46.     while(close){//已經斷開，重新建立連線
47.      try{  
48.       System.out.println("重新建立連線："+getIp()+":"+getPort());  
49.       InetAddress address = InetAddress.getByName(getIp());  
50.       socket = new Socket(address,getPort());  
51.       socket.setKeepAlive(true);  
52.       socket.setSoTimeout(sotimeout);  
53.       close = !Send(socket,"2");  
54.       System.out.println("建立連線成功："+getIp()+":"+getPort());  
55.      }catch(Exception se){  
56.       System.out.println("建立連線失敗:"+getIp()+":"+getPort());  
57.       close=true;  
58.      }  
59.     }  
60.    }  
61. }  
62. /** 
63. * 傳送資料，傳送失敗返回false,傳送成功返回true 
64. * @param csocket 
65. * @param message 
66. * @return 
67. */
68. public Boolean Send(Socket csocket,String message){  
69.    try{  
70.     PrintWriter out = new PrintWriter(socket.getOutputStream(), true);  
71.     out.println(message);  
72.     returntrue;  
73.    }catch(Exception se){  
74.     se.printStackTrace();  
75.     returnfalse;  
76.    }  
77. }  
78. /** 
79. * 讀取資料，返回字串型別 
80. * @param csocket 
81. * @return 
82. */
83. public String ReadText(Socket csocket){  
84.    try{  
85.     csocket.setSoTimeout(sotimeout);  
86.     InputStream input = csocket.getInputStream();  
87.     BufferedReader in = new BufferedReader(new InputStreamReader(input));  
88.     char[] sn = newchar[1000];  
89.     in.read(sn);  
90.     String sc = new String(sn);  
91.     return sc;  
92.    }catch(IOException se){  
93.     returnnull;  
94.    }  
95. }  
96. /** 
97. * 判斷是否斷開連線，斷開返回true,沒有返回false 
98. * @param socket 
99. * @return 
100. */
101. public Boolean isServerClose(Socket socket){  
102.    try{  
103.     socket.sendUrgentData(0);//傳送1個位元組的緊急資料，預設情況下，伺服器端沒有開啟緊急資料處理，不影響正常通訊
104.     returnfalse;  
105.    }catch(Exception se){  
106.     returntrue;  
107.    }  
108. }  
109. /** 
110. * 測試 
111. * @param ags 
112. */
113. publicstaticvoid main(String[] ags){  
114.    Nksocket nksocket = new Nksocket("127.0.0.1",8089);  
115.    nksocket.start();  
116. }  
117. //------------------------------------------------------------------------------
118. public String getIp() {  
119.    return ip;  
120. }  
121. publicvoid setIp(String ip) {  
122.    this.ip = ip;  
123. }  
124. public Integer getPort() {  
125.    return port;  
126. }  
127. publicvoid setPort(Integer port) {  
128.    this.port = port;  
129. }  
130. }