在 Java Socket 编程中，socket.close() 会自动关闭底层输入输出流，因此显式调用 InputStream/OutputStream 及其包装流（如 ObjectInputStream、PrintWriter）的 close() 方法不仅冗余，还可能引发异常；关键在于按正确顺序关闭，并注意对象流的特殊行为。
在 java socket 编程中，`socket.close()` 会自动关闭底层输入输出流，因此显式调用 `inputstream`/`outputstream` 及其包装流（如 `objectinputstream`、`printwriter`）的 `close()` 方法不仅冗余，还可能引发异常；关键在于按正确顺序关闭，并注意对象流的特殊行为。
在您提供的 Connection 类中，close() 方法存在严重资源管理问题：不应独立关闭所有包装流，更不应在 socket.close() 之后再关闭流。原因如下：
✅ 正确原则：委托关闭，避免重复
Java 的 Socket 类在调用 socket.close() 时，会自动关闭其关联的 getInputStream() 和 getOutputStream()（参见 JDK 文档）。而所有基于这些流构建的包装流（如 BufferedReader、PrintWriter、ObjectInputStream、ObjectOutputStream）在 close() 时，最终也会尝试关闭其底层流——这将导致对已关闭流的重复关闭操作，可能抛出 IOException（如 “Stream closed”），或在某些 JVM 实现中静默失败但埋下隐患。
✅ 正确做法是：仅关闭 Socket 即可，它会级联关闭所有依赖的底层流。其他包装流无需（也不应）显式 close()。
⚠️ 特别注意：ObjectInputStream 与 ObjectOutputStream 的陷阱
您的代码同时持有了 objectOut 和 objectIn，并共用同一个 socket.getOutputStream() 和 socket.getInputStream() —— 这是非法且危险的：
// ❌ 错误：同一 OutputStream 被两个 ObjectOutputStream 共享（即使非同时） this.objectOut = new ObjectOutputStream(socket.getOutputStream()); // 已写入 header this.objectIn = new ObjectInputStream(socket.getInputStream()); // 期待匹配 header，但流已被污染
- ObjectOutputStream 构造时会向流写入 2 字节协议头（STREAM_MAGIC），而 ObjectInputStream 构造时会读取该头。若两者共享底层流（尤其未同步使用），极易因字节错位导致 StreamCorruptedException 或永久阻塞。
- 更严重的是：ObjectOutputStream 和 ObjectInputStream 必须成对、独占地使用同一 socket 的输入/输出流。不能与 PrintWriter/BufferedReader 混用同一方向的流（例如，PrintWriter 写文本 + ObjectOutputStream 写对象到同一 OutputStream 会导致协议冲突）。
✅ 推荐重构方式（二选一）：
- 方案 A（纯对象通信）：仅使用 ObjectInputStream / ObjectOutputStream，移除 PrintWriter 和 BufferedReader；
- 方案 B（混合协议）：严格分离通道，例如用 DataInputStream/DataOutputStream 处理原始协议帧，对象序列化仅用于特定消息体（需自定义封装）。
✅ 安全关闭的最佳实践代码
修正后的 Connection 类应简化关闭逻辑，并修复流冲突：
public class Connection implements AutoCloseable {
private final Socket socket;
private final ObjectOutputStream objectOut;
private final ObjectInputStream objectIn;
public Connection(Socket socket) throws IOException {
this.socket = Objects.requireNonNull(socket);
// ✅ 独占使用：outputStream 仅由 ObjectOutputStream 使用
this.objectOut = new ObjectOutputStream(socket.getOutputStream());
// ✅ 独占使用：inputStream 仅由 ObjectInputStream 使用
this.objectIn = new ObjectInputStream(socket.getInputStream());
}
@Override
public void close() throws IOException {
// ✅ 仅关闭 socket：自动释放 objectOut/objectIn 底层流
if (!socket.isClosed()) {
socket.close();
}
}
// 提供安全的写入方法（自动 flush）
public void sendObject(Object obj) throws IOException {
objectOut.writeObject(obj);
objectOut.flush(); // ? 关键：对象流需显式 flush，否则缓冲区数据不发送
}
// 可选：重置对象流状态（防内存泄漏）
public void resetObjectOutput() throws IOException {
objectOut.reset(); // 清空对象引用表，避免服务端/客户端内存持续增长
}
}
? 总结与注意事项
- 关闭顺序：永远先确保业务数据已 flush()（尤其是 ObjectOutputStream），再调用 socket.close()；不要反向操作。
- 不要重复关闭：socket.close() → 自动关闭 getInputStream()/getOutputStream() → 包装流 close() 变为无操作（或抛异常），故无需调用。
- 对象流必须配对独占：一个 socket 的 InputStream 只能被一个 ObjectInputStream 使用，OutputStream 同理；混用文本流与对象流将破坏序列化协议。
- 推荐使用 try-with-resources：让 Connection 实现 AutoCloseable，确保异常时仍能释放 socket。
遵循以上原则，才能构建健壮、可维护的 Java 网络通信组件。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
