远程服务器突然关闭时readObject不抛异常，如何检测服务器状态并重连？

当服务器突然断电、网络链路直接断开这类无TCP FIN包的静默关闭场景下，ObjectInputStream.readObject()会因为TCP没有主动检测机制而无限阻塞，不会抛出预期的IOException。以下是几种专业可行的解决方案：

1. 给Socket设置读取超时 #

直接利用TCP Socket的超时机制，强制readObject()在指定时间内无数据时抛出异常，以此判定连接异常：

Socket socket = new Socket("server-host", 8080);
// 设置读取超时时间，比如5秒（单位：毫秒）
socket.setSoTimeout(5000);
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());

try {
    Object obj = ois.readObject();
    // 正常处理对象
} catch (SocketTimeoutException e) {
    // 超时触发，判定连接可能已断开，执行重连逻辑
    closeResources(socket, ois);
    reconnect();
} catch (IOException | ClassNotFoundException e) {
    // 明确的IO异常，直接处理重连
    closeResources(socket, ois);
    reconnect();
}

注意：超时时间需要根据业务场景调整，避免误判正常的长等待场景

2. 实现应用层心跳机制 #

TCP默认的KeepAlive机制（默认2小时检测间隔）无法满足大部分业务的实时性需求，因此自定义应用层心跳是更可靠的方案：

• 定义一个可序列化的心跳对象：

public class Heartbeat implements Serializable {
    private static final long serialVersionUID = 1L;
    // 可添加心跳时间戳等信息
}

• 客户端启动独立线程定期发送心跳，同时在主线程读取数据时结合心跳超时判断：

boolean isConnected = true;
int heartbeatTimeoutCount = 0;
// 心跳发送线程
new Thread(() -> {
    while (isConnected) {
        try {
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(new Heartbeat());
            oos.flush();
            Thread.sleep(3000); // 每3秒发一次心跳
        } catch (IOException e) {
            isConnected = false;
            break;
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}).start();

// 主线程读取逻辑
while (isConnected) {
    try {
        Object obj = ois.readObject();
        if (obj instanceof Heartbeat) {
            // 收到服务器心跳回复，重置超时计数器
            heartbeatTimeoutCount = 0;
        } else {
            // 处理业务对象
        }
    } catch (SocketTimeoutException e) {
        heartbeatTimeoutCount++;
        if (heartbeatTimeoutCount >= 3) { // 连续3次超时判定连接断开
            isConnected = false;
            closeResources(socket, ois);
            reconnect();
        }
    } catch (IOException | ClassNotFoundException e) {
        isConnected = false;
        closeResources(socket, ois);
        reconnect();
    }
}

3. 切换到NIO非阻塞IO #

使用Java NIO的SocketChannel和Selector，实现非阻塞读取，避免无限阻塞：

Selector selector = Selector.open();
SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("server-host", 8080));
socketChannel.configureBlocking(false);
socketChannel.register(selector, SelectionKey.OP_READ);

while (true) {
    int readyChannels = selector.select(5000); // 每5秒轮询一次
    if (readyChannels == 0) {
        // 无就绪通道，检查连接状态
        if (!socketChannel.isConnected()) {
            reconnect();
            break;
        }
        continue;
    }

    Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator();
    while (keyIterator.hasNext()) {
        SelectionKey key = keyIterator.next();
        if (key.isReadable()) {
            ObjectInputStream ois = new ObjectInputStream(socketChannel.socket().getInputStream());
            try {
                Object obj = ois.readObject();
                // 处理对象
            } catch (IOException e) {
                key.cancel();
                reconnect();
            }
        }
        keyIterator.remove();
    }
}

4. 辅助检测：通过写操作验证连接 #

当readObject阻塞时，可尝试向输出流写入数据（比如心跳包），如果写入失败则直接判定连接断开：

try {
    // 尝试写入心跳包检测连接
    oos.writeObject(new Heartbeat());
    oos.flush();
} catch (IOException e) {
    // 写入失败，连接已断开
    closeResources(socket, ois);
    reconnect();
}

内容的提问来源于stack exchange，提问作者Manuel