在socket類(lèi)中有一個(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)銷(xiāo)服務(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ì)及專(zhuān)業(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ù),返回字符串類(lèi)型 * @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)文章!