java如何判斷socket的連接？

在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; 
} 
}

以上就是java判斷socket是否連接的詳細內容，更多請關注億速云其它相關文章！