java中怎么判断socket是否连接
这期内容当中小编将会给大家带来有关java中怎么判断socket是否连接,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。
曲沃网站制作公司哪家好,找成都创新互联!从网页设计、网站建设、微信开发、APP开发、响应式网站开发等网站项目制作,到程序开发,运营维护。成都创新互联自2013年创立以来到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联。
在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是否连接了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注创新互联行业资讯频道。
网页标题:java中怎么判断socket是否连接
转载来源:http://scjbc.cn/article/gijicj.html