java socket 判断Socket连接失效

要判断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代码

package com.service;
import java.net.*;
/**
* @说明从这里启动一个服务端监听某个端口
* @author 崔素强
*/
public class DstService {
public static void main(String[] args) {
try {
// 启动监听端口 8001
ServerSocket ss = new ServerSocket(8001);
// 没有连接这个方法就一直堵塞
Socket s = ss.accept();
// 将请求指定一个线程去执行
new Thread(new DstServiceImpl(s)).start();
} catch (Exception e) {
e.printStackTrace();
}
}
}

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

Java代码

package com.service;
import java.net.Socket;
/**
* @说明服务的具体执行类
* @author 崔素强
*/
public class DstServiceImpl implements Runnable {
Socket socket = null;
public DstServiceImpl(Socket s) {
this.socket = s;
}
public void run() {
try {
int index = 1;
while (true) {
// 5秒后中断连接
if (index > 5) {
socket.close();
System.out.println("服务端已经将连接关闭！");
break;
}
index++;
Thread.sleep(1 * 1000);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}

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

Java代码

package com.client;
import java.net.*;
/**
* @说明服务的客户端，会请求连接并实时打印连接对象的一些信息，但是不会进行流的操作
* @author 崔素强
*/
public class DstClient {
public static void main(String[] args) {
try {
Socket socket = new Socket("127.0.0.1", 8001);
socket.setKeepAlive(true);
socket.setSoTimeout(10);
while (true) {
System.out.println(socket.isBound());
System.out.println(socket.isClosed());
System.out.println(socket.isConnected());
System.out.println(socket.isInputShutdown());
System.out.println(socket.isOutputShutdown());
System.out.println("------------------------");
Thread.sleep(3 * 1000);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}

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

Xml代码

true
false
true
false
false
------------------------

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

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

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

Java代码

public static byte[] inputStreamToByte(InputStream inStream)
throws Exception {
int count = 0;
int haveCheck = 0;
// 如果在网络传输中数据没有完全传递，则方法返回0
while (count == 0) {
count = inStream.available();
haveCheck++;
if (haveCheck >= 50)
return null;
}
byte[] b = new byte[count];
inStream.read(b);
return b;
}

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

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

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

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

Java代码

socket.sendUrgentData(0xFF); // 发送心跳包

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

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

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

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

我们来看如下例子，服务端不变：

Java代码