java如何判斷socket的連接？

在socket類中有一個(gè)方法sendUrgentData，它會(huì)往輸出流發(fā)送一個(gè)字節(jié)的數(shù)據(jù)，只要對(duì)方Socket的SO_OOBINLINE屬性沒(méi)有打開(kāi)，就會(huì)自動(dòng)舍棄這個(gè)字節(jié)（在Java 中是拋出異常），而SO_OOBINLINE屬性默認(rèn)情況下就是關(guān)閉的。

成都創(chuàng)新互聯(lián)公司自成立以來(lái)，一直致力于為企業(yè)提供從網(wǎng)站策劃、網(wǎng)站設(shè)計(jì)、做網(wǎng)站、成都網(wǎng)站建設(shè)、電子商務(wù)、網(wǎng)站推廣、網(wǎng)站優(yōu)化到為企業(yè)提供個(gè)性化軟件開(kāi)發(fā)等基于互聯(lián)網(wǎng)的全面整合營(yíng)銷服務(wù)。公司擁有豐富的網(wǎng)站建設(shè)和互聯(lián)網(wǎng)應(yīng)用系統(tǒng)開(kāi)發(fā)管理經(jīng)驗(yàn)、成熟的應(yīng)用系統(tǒng)解決方案、優(yōu)秀的網(wǎng)站開(kāi)發(fā)工程師團(tuán)隊(duì)及專業(yè)的網(wǎng)站設(shè)計(jì)師團(tuán)隊(duì)。

示例：

public class Nksocket extends Thread{ 
public String ip=null;//連接服務(wù)器的IP 
public Integer port=null;//連接服務(wù)器的端口 
private Socket socket=null;//套節(jié)字對(duì)象 
private boolean close = false; // 關(guān)閉連接標(biāo)志位，true表示關(guān)閉，false表示連接 
private Integer sotimeout=1*1*10;//超時(shí)時(shí)間，以毫秒為單位 
//------------------------------------------------------------------------------ 
public Nksocket(){ 
   init(); 
} 
public Nksocket(String ip,Integer port){ 
   setIp(ip); 
   setPort(port); 
   init(); 
} 
/**
* 初始化socket對(duì)象
*/ 
public void init(){ 
   try { 
    InetAddress address = InetAddress.getByName(getIp()); 
    socket = new Socket(address,getPort()); 
    socket.setKeepAlive(true);//開(kāi)啟保持活動(dòng)狀態(tài)的套接字 
    socket.setSoTimeout(sotimeout);//設(shè)置超時(shí)時(shí)間 
    close=!Send(socket,"2");//發(fā)送初始數(shù)據(jù)，發(fā)送成功則表示已經(jīng)連接上，發(fā)送失敗表示已經(jīng)斷開(kāi) 
   }catch(UnknownHostException e) { 
    e.printStackTrace(); 
   }catch(IOException e){ 
    e.printStackTrace(); 
   } 
} 
/**
* 讀數(shù)據(jù)線程
*/ 
public void run() { 
   while(true){ 
    //---------讀數(shù)據(jù)--------------------------- 
    close = isServerClose(socket);//判斷是否斷開(kāi) 
    if(!close){//沒(méi)有斷開(kāi)，開(kāi)始讀數(shù)據(jù) 
     String readtext = ReadText(socket); 
     if(readtext!=null && readtext.trim().length()>0){ 
      System.out.println("讀取數(shù)據(jù)："+readtext); 
     } 
    } 
    //---------創(chuàng)建連接------------------------- 
    while(close){//已經(jīng)斷開(kāi)，重新建立連接 
     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("創(chuàng)建連接失敗:"+getIp()+":"+getPort()); 
      close=true; 
     } 
    } 
   } 
} 
/**
* 發(fā)送數(shù)據(jù)，發(fā)送失敗返回false,發(fā)送成功返回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; 
   } 
} 
/**
* 讀取數(shù)據(jù)，返回字符串類型
* @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; 
   } 
} 
/**
* 判斷是否斷開(kāi)連接，斷開(kāi)返回true,沒(méi)有返回false
* @param socket
* @return
*/ 
public Boolean isServerClose(Socket socket){ 
   try{ 
    socket.sendUrgentData(0xFF);//發(fā)送1個(gè)字節(jié)的緊急數(shù)據(jù)，默認(rèn)情況下，服務(wù)器端沒(méi)有開(kāi)啟緊急數(shù)據(jù)處理，不影響正常通信 
    return false; 
   }catch(Exception se){ 
    return true; 
   } 
} 
/**
* 測(cè)試
* @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是否連接的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注創(chuàng)新互聯(lián)其它相關(guān)文章！

新聞標(biāo)題：java如何判斷socket的連接？
轉(zhuǎn)載來(lái)于：http://muchs.cn/article0/ihseio.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動(dòng)態(tài)網(wǎng)站、企業(yè)建站、響應(yīng)式網(wǎng)站、搜索引擎優(yōu)化、網(wǎng)站導(dǎo)航、建站公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)