Java Socket通信核心是TCP流式连接封装,需手动处理协议解析、粘包等;客户端Socket连接服务端,服务端ServerSocket accept等待连接;读写阻塞且无超时,需显式close。

Java中Socket通信的核心逻辑是什么
Java的Socket和ServerSocket本质是TCP连接的封装,不处理协议解析、粘包、心跳或重连——这些都得自己补。客户端用Socket连服务端IP+端口,服务端用ServerSocket在指定端口accept()等待连接。一次连接对应一个双向字节流,读写操作阻塞,没超时机制,默认无限等。
如何写出可运行的最小Socket示例
以下是最简但能跑通的双端代码,注意关键点:
- 服务端必须先启动,否则客户端
new Socket("127.0.0.1", 8080)会抛ConnectException - 双方都需显式调用
close(),否则端口可能被占用、连接不释放 -
BufferedReader.readLine()按行读取,要求发送方末尾带\n(如pw.println("hello"))
import java.io.*;
import java.net.*;
// 服务端
public class SimpleServer {
public static void main(String[] args) throws IOException {
ServerSocket ss = new ServerSocket(8080);
Socket s = ss.accept(); // 阻塞直到有连接
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
PrintWriter pw = new PrintWriter(s.getOutputStream(), true);
String line = br.readLine();
pw.println("echo: " + line);
s.close();
ss.close();
}
}
import java.io.*;
import java.net.*;
// 客户端
public class SimpleClient {
public static void main(String[] args) throws IOException {
Socket s = new Socket("127.0.0.1", 8080);
PrintWriter pw = new PrintWriter(s.getOutputStream(), true);
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
pw.println("test");
System.out.println(br.readLine());
s.close();
}
}
为什么read()经常卡住或读不到完整数据
这是初学者最常踩的坑:TCP是流式协议,InputStream.read()只保证读至少1字节,不保证读完一整条消息。没有长度头、分隔符或固定包长时,根本无法判断“一条消息”在哪结束。
- 用
readLine()的前提是对方发的是文本且每行结尾有\n或\r\n - 用
read(byte[] b)时,返回值是实际读到的字节数,必须检查,不能直接当完整包处理 - 不要依赖
available()判断是否有数据——它只反映内核缓冲区当前字节数,不可靠 - 真正健壮的做法是定义协议:比如前4字节为int表示长度,再读对应字节数
ServerSocket.accept()之后要不要开新线程
要。默认accept()是阻塞的,一个连接处理完才能接下一个;如果在accept()后的处理逻辑里做耗时操作(比如文件IO、数据库查询),后续连接会被排队卡住。
立即学习“Java免费学习笔记(深入)”;
- 简单场景可用
new Thread(() -> handle(s)).start() - 高并发建议用
ExecutorService管理线程池,避免无限制创建线程 - 注意共享资源(如
PrintWriter)不是线程安全的,每个连接应独占自己的输入输出流 - JDK 1.7+ 可考虑
try-with-resources自动关闭流,但需确保异常时仍能释放连接
Connection reset、Broken pipe、半关闭状态等问题的基础。











