Java复用Socket时，刷新BufferedOutputStream前如何检查服务器可用性？

首先要明确：TCP连接本身无法主动实时检测对方是否异常宕机，这是由TCP的传输特性决定的——当你调用flush()发送数据时，操作系统只是把数据放到发送缓冲区，就算对方已经断开，只要缓冲区没满，首次flush()不会立刻抛出异常，只有当后续发送或系统尝试确认时，才会发现连接失效。

你之前尝试的方法之所以无效，原因如下：

• Socket.isConnected()仅表示该Socket曾经成功建立过连接，完全不代表当前连接状态
• InetAddress.isReachable()是通过ICMP ping检测主机可达性，和TCP连接是否存活没有直接关联（对方主机可能在线，但对应端口的服务已经宕机）
• SocketChannel的状态检查逻辑和Socket本质一致，无法突破TCP的限制

下面给出几种可行的解决方案：

1. 主动心跳检测 #

和服务器约定一个简单的心跳协议，在发送业务数据前，先发送心跳包并等待响应，以此验证连接有效性：

// 验证连接是否存活的方法，需和服务器约定心跳指令
private boolean isConnectionAlive() throws IOException {
    // 发送心跳包（比如自定义的"PING"指令，结尾加换行方便服务器识别）
    output.write("PING\n".getBytes());
    output.flush();
    
    // 尝试读取服务器的心跳响应，利用已设置的soTimeout超时
    input.mark(1024); // 标记当前位置，方便后续回滚
    int readByte = input.read();
    
    if (readByte == -1) {
        // 读取到-1说明连接已断开
        return false;
    }
    // 将读取的字节放回输入流，不影响后续业务数据处理
    input.reset();
    return true;
}

private void send() throws IOException {
    if (!isConnectionAlive()) {
        // 连接失效，执行重建逻辑
        reconnect();
    }
    output.write("Hello".getBytes());
    output.flush();
}

// 重建连接的方法
private void reconnect() throws IOException {
    // 关闭旧连接
    connection.close();
    output.close();
    input.close();
    
    // 重新建立连接
    connection = new Socket();
    InetSocketAddress server = new InetSocketAddress("server", port);
    connection.setSoTimeout(2000);
    connection.setKeepAlive(true);
    // 可添加之前的TCP Keep-Alive参数优化
    connection.connect(server, 2000);
    output = new BufferedOutputStream(connection.getOutputStream());
    input = new BufferedInputStream(connection.getInputStream());
}

注意：必须和服务器端配合实现心跳响应逻辑，否则该方法无法生效。

2. 优化TCP Keep-Alive参数 #

系统默认的TCP Keep-Alive间隔很长（比如Linux默认2小时），可以手动调整参数让系统更快检测到死连接：

Socket connection = new Socket();
InetSocketAddress server = new InetSocketAddress("server", port);
connection.setSoTimeout(2000);
connection.setKeepAlive(true);

// 以下参数需要JDK 1.7+支持，且仅在部分操作系统（Linux/Windows）生效
// 设置空闲多久后开始发送Keep-Alive探测包（单位：秒）
connection.setOption(StandardSocketOptions.TCP_KEEPIDLE, 30);
// 探测包未得到响应时，重试的间隔（单位：秒）
connection.setOption(StandardSocketOptions.TCP_KEEPINTVL, 5);
// 最大重试次数
connection.setOption(StandardSocketOptions.TCP_KEEPCNT, 3);

connection.connect(server, 2000);

这种方式是让操作系统主动维护连接状态，当对方宕机后，系统会在约30+5*3=45秒内检测到连接失效，后续的flush()就会抛出异常。但注意这是系统层面的检测，仍然存在一定延迟，且不同操作系统的参数支持情况可能不同。

3. 绑定业务请求-响应逻辑 #

如果你的业务通信是请求-响应模式（发送数据后需要服务器返回确认），可以直接通过读取响应来判断连接状态：

private void send() throws IOException {
    output.write("Hello".getBytes());
    output.flush();
    
    // 读取服务器的响应数据
    byte[] buffer = new byte[1024];
    int readLen = input.read(buffer);
    if (readLen == -1) {
        throw new IOException("服务器已断开连接");
    }
    
    // 处理服务器响应...
}

这种方式最可靠，因为直接和业务流程绑定，不需要额外的心跳协议，只要服务器没有返回响应，就能立刻感知连接问题。

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