JAVA 判斷Socket 遠程端是否斷開連接

　　最近在做項目的時候，遇到這樣一個問題，如何判斷 Socket 遠程端連接是否關閉，如果關閉的話，就要重建連接Socket的類提供了一些已經封裝好的方法， 如  isClosed()、isConnected()、isInputStreamShutdown()、isOutputStreamShutdown()等，在測試時發現，這些方法都是本地端的狀態，無法判斷遠端是否已經斷開連接。

　　其實在socket類中有一個方法sendUrgentData，它會往輸出流發送一個字節的數據，只要對方Socket的SO_OOBINLINE屬性沒有打開，就會自動舍棄這個字節（在Java 中是拋出異常），而SO_OOBINLINE屬性默認情況下就是關閉的。

　　以下是示例代碼僅供參考：

public class Nksocket extends Thread{  
public String ip=null;//連接服務器的IP  
public Integer port=null;//連接服務器的端口  
private Socket socket=null;//套節字對象  
private boolean close = false; // 關閉連接標志位，true表示關閉，false表示連接  
private Integer sotimeout=1*1*10;//超時時間，以毫秒為單位  
//------------------------------------------------------------------------------  
public Nksocket(){  
   init();  
}  
public Nksocket(String ip,Integer port){  
   setIp(ip);  
   setPort(port);  
   init();  
}  
/** 
* 初始化socket對象 
*/  
public void init(){  
   try {  
    InetAddress address = InetAddress.getByName(getIp());  
    socket = new Socket(address,getPort());  
    socket.setKeepAlive(true);//開啟保持活動狀態的套接字  
    socket.setSoTimeout(sotimeout);//設置超時時間  
    close=!Send(socket,"2");//發送初始數據，發送成功則表示已經連接上，發送失敗表示已經斷開  
   }catch(UnknownHostException e) {  
    e.printStackTrace();  
   }catch(IOException e){  
    e.printStackTrace();  
   }  
}  
/** 
* 讀數據線程 
*/  
public void run() {  
   while(true){  
    //---------讀數據---------------------------  
    close = isServerClose(socket);//判斷是否斷開  
    if(!close){//沒有斷開，開始讀數據  
     String readtext = ReadText(socket);  
     if(readtext!=null && readtext.trim().length()>0){  
      System.out.println("讀取數據："+readtext);  
     }  
    }  
    //---------創建連接-------------------------  
    while(close){//已經斷開，重新建立連接  
     try{  
      System.out.println("重新建立連接："+getIp()+":"+getPort());  
      InetAddress address = InetAddress.getByName(getIp());  
      socket = new Socket(address,getPort());  
      socket.setKeepAlive(true);  
      socket.setSoTimeout(sotimeout);  
      close = !Send(socket,"2");  
      System.out.println("建立連接成功："+getIp()+":"+getPort());  
     }catch(Exception se){  
      System.out.println("創建連接失敗:"+getIp()+":"+getPort());  
      close=true;  
     }  
    }  
   }  
}  
/** 
* 發送數據，發送失敗返回false,發送成功返回true 
* @param csocket 
* @param message 
* @return 
*/  
public Boolean Send(Socket csocket,String message){  
   try{  
    PrintWriter out = new PrintWriter(socket.getOutputStream(), true);  
    out.println(message);  
    return true;  
   }catch(Exception se){  
    se.printStackTrace();  
    return false;  
   }  
}  
/** 
* 讀取數據，返回字符串類型 
* @param csocket 
* @return 
*/  
public String ReadText(Socket csocket){  
   try{  
    csocket.setSoTimeout(sotimeout);  
    InputStream input = csocket.getInputStream();  
    BufferedReader in = new BufferedReader(new InputStreamReader(input));  
    char[] sn = new char[1000];  
    in.read(sn);  
    String sc = new String(sn);  
    return sc;  
   }catch(IOException se){  
    return null;  
   }  
}  
/** 
* 判斷是否斷開連接，斷開返回true,沒有返回false 
* @param socket 
* @return 
*/  
public Boolean isServerClose(Socket socket){ try{ socket.sendUrgentData(0xFF);//發送1個字節的緊急數據，默認情況下，服務器端沒有開啟緊急數據處理，不影響正常通信 return false; }catch(Exception se){ return true; } }  
/** 
* 測試 
* @param ags 
*/  
public static void main(String[] ags){  
   Nksocket nksocket = new Nksocket("127.0.0.1",8090);  
   nksocket.start();  
}  
//------------------------------------------------------------------------------  
public String getIp() {  
   return ip;  
}  
public void setIp(String ip) {  
   this.ip = ip;  
}  
public Integer getPort() {  
   return port;  
}  
public void setPort(Integer port) {  
   this.port = port;  
}  
}  

　　

參考資料：

 http://blog.csdn.net/xyz_lmn/article/details/6146749

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