要判断socket连接链路是否可用时,不能通过socket.isClosed() 和 socket.isConnected() 方法判断,要通过心跳包 socket.sendUrgentData(0xFF) 。

当第一次连接成功后, socket.isClosed() ==false, socket.isConnected()==true,只有在自己端代码中显示调用socket.close()方法时,socket.isClosed() ==true。

而链路的不可用时,自己端的socket是不知道的,仍然是 socket.isClosed() ==false, socket.isConnected()==true。

要通过心跳包 socket.sendUrgentData(0xFF)  进行测验。

我们来看如下代码运行后再继续:

服务端:

Java代码  
  1. package com.service;
  2. import java.net.*;
  3. /**
  4. * @说明 从这里启动一个服务端监听某个端口
  5. * @author 崔素强
  6. */
  7. public class DstService {
  8. public static void main(String[] args) {
  9. try {
  10. // 启动监听端口 8001
  11. ServerSocket ss = new ServerSocket(8001);
  12. // 没有连接这个方法就一直堵塞
  13. Socket s = ss.accept();
  14. // 将请求指定一个线程去执行
  15. new Thread(new DstServiceImpl(s)).start();
  16. } catch (Exception e) {
  17. e.printStackTrace();
  18. }
  19. }
  20. }

然后我们来看执行类,执行类在收到连接5秒后中断连接:

Java代码  
  1. package com.service;
  2. import java.net.Socket;
  3. /**
  4. * @说明 服务的具体执行类
  5. * @author 崔素强
  6. */
  7. public class DstServiceImpl implements Runnable {
  8. Socket socket = null;
  9. public DstServiceImpl(Socket s) {
  10. this.socket = s;
  11. }
  12. public void run() {
  13. try {
  14. int index = 1;
  15. while (true) {
  16. // 5秒后中断连接
  17. if (index > 5) {
  18. socket.close();
  19. System.out.println("服务端已经将连接关闭!");
  20. break;
  21. }
  22. index++;
  23. Thread.sleep(1 * 1000);
  24. }
  25. } catch (Exception e) {
  26. e.printStackTrace();
  27. }
  28. }
  29. }

我们在写一个客户端进行实验:

Java代码  
  1. package com.client;
  2. import java.net.*;
  3. /**
  4. * @说明 服务的客户端,会请求连接并实时打印连接对象的一些信息,但是不会进行流的操作
  5. * @author 崔素强
  6. */
  7. public class DstClient {
  8. public static void main(String[] args) {
  9. try {
  10. Socket socket = new Socket("127.0.0.1", 8001);
  11. socket.setKeepAlive(true);
  12. socket.setSoTimeout(10);
  13. while (true) {
  14. System.out.println(socket.isBound());
  15. System.out.println(socket.isClosed());
  16. System.out.println(socket.isConnected());
  17. System.out.println(socket.isInputShutdown());
  18. System.out.println(socket.isOutputShutdown());
  19. System.out.println("------------------------");
  20. Thread.sleep(3 * 1000);
  21. }
  22. } catch (Exception e) {
  23. e.printStackTrace();
  24. }
  25. }
  26. }

至于输出结果,虽然服务端已经中断连接,但是客户端一直输出下面内容:

Xml代码  
  1. true
  2. false
  3. true
  4. false
  5. false
  6. ------------------------

从连接对象的属性信息来看,连接似乎没有中断。但实际虽然内存对象可用,但是物理连接已经失效。所以和网上其他抄袭来抄袭去的说法一样,靠连接对象属性来判断连接的可用性是不可行的。

大家会说那就判断调用read方法是否报错呗。我之前有文章已经讨论了关于调用网络里面流的一些内容,在没有判断这个流可用之前,我们是不会调用read方法的,当然具体你是怎么做的我不知道我在说我的情况!

读取网络数据流时的那个方法是这样的:

Java代码  
  1. public static byte[] inputStreamToByte(InputStream inStream)
  2. throws Exception {
  3. int count = 0;
  4. int haveCheck = 0;
  5. // 如果在网络传输中数据没有完全传递,则方法返回0
  6. while (count == 0) {
  7. count = inStream.available();
  8. haveCheck++;
  9. if (haveCheck >= 50)
  10. return null;
  11. }
  12. byte[] b = new byte[count];
  13. inStream.read(b);
  14. return b;
  15. }

就是说我们不会直接调用read方法,而available方法在流没有完整和网络中断时都会返回0,不会报错。

就是说就算你设置超时时间设置保持连接这些东西,只要你没有调用read的机会,你的程序就不会出问题。当然如果程序一直不调用read方法,那这个程序可真的够扯淡的了。

其实只要在使用这个连接的时候判断这个连接的可用性就行了,不要等着什么超时。

判断连接可用虽然网上一大片,其实就是那么回事,手动发送心跳包。

Java代码  
  1. socket.sendUrgentData(0xFF); // 发送心跳包

如果你的连接已经中断,那么这个方法就会报错。

至于什么是心跳包,直接上理论吧。

心跳包就是在客户端和服务器间定时通知对方自己状态的一个自己定义的命令字,按照一定的时间间隔发送,类似于心跳,所以叫做心跳包。 用来判断对方(设备,进程或其它网元)是否正常运行,采用定时发送简单的通讯包,如果在指定时间段内未收到对方响应,则判断对方已经离线。用于检测TCP的异常断开。基本原因是服务器端不能有效的判断客户端是否在线,也就是说,服务器无法区分客户端是长时间在空闲,还是已经掉线的情况。所谓的心跳包就是客户端定时发送简单的信息给服务器端告诉它我还在而已。代码就是每隔几分钟发送一个固定信息给服务端,服务端收到后回复一个固定信息如果服务端几分钟内没有收到客户端信息则视客户端断开。 比如有些通信软件长时间不使用,要想知道它的状态是在线还是离线就需要心跳包,定时发包收包。发包方:可以是客户也可以是服务端,看哪边实现方便合理,一般是客户端。服务器也可以定时发心跳下去。一般来说,出于效率的考虑,是由客户端主动向服务器端发包,而不是服务器向客户端发。客户端每隔一段时间发一个包,使用TCP的,用send发,使用UDP的,用sendto发,服务器收到后,就知道当前客户端还处于“活着”的状态,否则,如果隔一定时间未收到这样的包,则服务器认为客户端已经断开,进行相应的客户端断开逻辑处理!

当然不能单纯理解心跳包就是往对方放松数据,因为心跳包是用于状态验证的,不是真实的数据。

我们来看如下例子,服务端不变:

Java代码  
  1. package com.client;
  2. import java.net.*;
  3. /**
  4. * @说明 服务的客户端,会请求连接并实时打印连接对象的一些信息,但是不会进行流的操作
  5. * @author 崔素强
  6. */
  7. public class DstClient {
  8. public static void main(String[] args) {
  9. try {
  10. Socket socket = new Socket("127.0.0.1", 8001);
  11. socket.setKeepAlive(true);
  12. socket.setSoTimeout(10);
  13. while (true) {
  14. socket.sendUrgentData(0xFF); // 发送心跳包
  15. System.out.println("目前是正常的!");
  16. Thread.sleep(3 * 1000);
  17. }
  18. } catch (Exception e) {
  19. e.printStackTrace();
  20. }
  21. }
  22. }

看到控制台的输出:

Java代码  
  1. 目前是正常的!
  2. 目前是正常的!
  3. java.net.SocketException: Invalid argument: send
  4. at java.net.PlainSocketImpl.socketSendUrgentData(Native Method)
  5. at java.net.PlainSocketImpl.sendUrgentData(PlainSocketImpl.java:550)
  6. at java.net.Socket.sendUrgentData(Socket.java:928)
  7. at com.client.DstClient.main(DstClient.java:14)

那就是说,只要你的服务端断了,调用方法就会出错!

至于我说的他不会作为可见的数据你可以更改服务端代码打印客户端内容,你会发现服务端不会将心跳包内容展示给你!

Java代码  
  1. InputStream ips = socket.getInputStream();
  2. byte[] bt = inputStreamToByte(ips);
  3. if(null != bt)
  4. System.out.println(new String(bt));
  5. else
  6. System.out.println("Bt is null");
  7. System.out.println("****************************");

转载于:https://www.cnblogs.com/panchanggui/p/9664876.html

java socket 判断Socket连接失效相关推荐

  1. 如何判断Socket连接失效

    在开发工程中对Socket进行管理时对于这个连接的超时和是否失效进行研究. 对于连接超时和失效肯定会想到设置超时时间和判断连接是否可用.但是设置超时时间后起作用是在调用read方法的时候,如果只是设置 ...

  2. java socket 对方关闭_java Socket判断对方是否已关闭连接

    如何判断远端socket是否已经断开连接,如果断开那么需要重新连接. 1通过socket类的方法isClosed().isConnected().isInputStreamShutdown().isO ...

  3. JAVA 判断Socket 远程端是否断开连接

    JAVA 判断Socket 远程端是否断开连接 最近在做项目的时候,遇到这样一个问题,如何判断 Socket 远程端连接是否关闭,如果关闭的话,就要重建连接Socket的类提供了一些已经封装好的方法, ...

  4. java判断socket是否连接_java判断socket是否连接

    在socket类中有一个方法sendUrgentData,它会往输出流发送一个字节的数据,只要对方Socket的SO_OOBINLINE属性没有打开,就会自动舍弃这个字节(在Java 中是抛出异常), ...

  5. Java实现SSL Socket长连接

    一.单向认证 1.生成服务端密钥(配置了jdk的环境变量即可用keytool命令) 命令:keytool -genkey -keystore server_ks.jks -storepass serv ...

  6. JAVA网络编程Socket常见问题 【长连接专题】

    一. 网络程序运行过程中的常见异常及处理 第1个异常是 java.net.BindException:Address already in use: JVM_Bind. 该异常发生在服务器端进行new ...

  7. C语言socket connect()函数(初始化套接字上的连接)(未完)(如何测试socket是否已经断开,如何判断socket是否断开)

    参考文章:C网络编程socket之connect函数 需研究下这个函数超时多久才返回... 文章目录 项目中注释解释 man 2 文档解释 关于上面man 2 手册中所提到的connect()案例,在 ...

  8. java socket建立长连接_Java Web项目中使用Socket通信多线程、长连接的方法

    很多时候在javaweb项目中我们需要用到Socket通信来实现功能,在web中使用Socket我们需要建立一个监听程序,在程序启动时,启动socket监听.我们的应用场景是在java项目中,需要外接 ...

  9. C#socket通信时,怎样判断socket双方是否断开连接

    我在Server端new了一个socket,然后bind,开了一个线程来accept前来连接的client,每接到一个client前来连接就新开一个线程和它进行通信. 我把Server端得到的sock ...

最新文章

  1. JavaScript高级程序设计学习笔记二(在HTML中使用JavaScript)
  2. [2018/11/14]思考
  3. ubuntu系统阅读CHM文档的最终解决方案
  4. matlab如何创建table,MATLAB table数据结构 首篇
  5. 如何关闭Windows10任务栏里的应用图标
  6. The Event System
  7. IoC反转控制初步认识
  8. .Net的类型构造器-static构造函数
  9. 树莓派安装python2.7_树莓派3 + raspbian lite + OpenCV 3 环境搭建
  10. 深入浅出OOP(一): 多态和继承(早期绑定/编译时多态)
  11. 复习webpack4之PWA打包配置
  12. 菜鸟的spring security学习教程
  13. logo语言是计算机语言吗,LOGO语言的编程
  14. 第二章 让你的kali系统变得更好用
  15. 高端存储系统的发展方向展望
  16. qq 能上但是打不开网页
  17. linux平台运行 mr程序,MR程序的几种提交运行模式
  18. ffmpeg音频格式转码(编码器)
  19. 国内CDN的排名情况
  20. STM32MP157 Linux系统移植开发篇19:Linux内核Wi-Fi驱动移植

热门文章

  1. 使用Vitamio打造自己的Android万能播放器(7)——在线播放(下载视频)
  2. Spring_HelloWord
  3. 关于VerifyError
  4. Interactive Reflection Editing (SIGGRAPH ASIA 09)
  5. PHP从零开始--字段修饰符数据操作SQL语言
  6. 汇编 --- 从磁盘(扇区2到18)上读取数据到内存中
  7. javascript --- 让函数的实例可以链式调用
  8. kubernetes 集群部署
  9. Drbd+Pacemaker实现高可用
  10. background-size