Java中Socket的getInputStream()返回阻塞式字节流，需用BufferedInputStream、InputStreamReader+BufferedReader或byte[]批量读取，注意read()返回值含义、粘包/半包处理、异常捕获及try-with-resources关闭资源，并设置setSoTimeout避免无限阻塞。
Java 中通过 Socket 的 getInputStream() 读取数据，核心是获取字节流后按需解析内容，关键在于理解阻塞行为、缓冲机制和正确关闭资源。
拿到输入流后不能直接读，得选对读取方式
Socket 返回的 InputStream 是阻塞式字节流，调用 read() 时若无数据会一直等待。实际开发中不建议用单字节 read()，效率低且难处理边界。常用方式有：
-
用
BufferedInputStream包装：提升读取效率，减少系统调用次数 -
配合
InputStreamReader+BufferedReader：适合读文本（如 HTTP 响应、自定义协议行数据），支持readLine() -
用
byte[]数组批量读：如read(byte[] b)或read(byte[] b, int off, int len)，更可控
注意流的结束判断和粘包/半包问题
read() 返回值很重要：返回 -1 表示对端已关闭连接（EOF）；返回 0 不代表结束，只是本次没读到数据（但缓冲区可能还有）；返回正数才是实际读到的字节数。不要假设一次 read() 就能读完一整条消息——TCP 是流式协议，可能出现：
- 粘包：多个逻辑消息被合并成一个 TCP 段到达
- 半包：一个消息被拆成多次到达
解决方法取决于协议设计：固定长度、特殊分隔符（如 \n）、头部带长度字段等。例如用 BufferedReader.readLine() 就隐含了以换行符为界；若用字节数组，则需自己缓存 + 解析。
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
立即学习“Java免费学习笔记（深入）”；
别忘了异常处理和资源释放
网络 I/O 容易触发 IOException（如连接中断、超时），必须捕获处理。同时，InputStream 属于系统资源，务必在使用后关闭（推荐 try-with-resources）：
try (Socket socket = new Socket("localhost", 8080);
InputStream is = socket.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(is))) {
String line;
while ((line = reader.readLine()) != null) {
System.out.println(line);
}
} catch (IOException e) {
e.printStackTrace();
}
注意：关闭 Socket 会自动关闭其关联的输入输出流，但显式关闭流或使用 try-with-resources 更清晰可靠。
设置超时避免无限阻塞
默认情况下，read() 会永远等下去。生产环境必须设置读超时：
- 调用
socket.setSoTimeout(int timeout)（单位毫秒） - 超时后
read()抛出SocketTimeoutException（是IOException子类） - 超时不是断开连接，只是本次读操作放弃，可重试或做其他处理
