作为一名 Java 开发工程师，你一定在实际开发中遇到过需要建立稳定连接、可靠传输、有序通信等场景。这时，TCP（Transmission Control Protocol） 通信就成为你必须掌握的重要技能之一。

TCP 是一种面向连接、可靠、基于字节流的传输协议，广泛应用于网页请求、文件传输、数据库通信、远程调用等对数据完整性要求较高的场景。

本文将带你全面掌握：

• TCP 的基本概念与特点
• TCP 与 UDP 的区别
• Java 中的 TCP 编程核心类（Socket、ServerSocket）
• TCP 通信的完整实现（客户端与服务端）
• TCP 的粘包与拆包问题处理
• 多线程处理 TCP 请求
• 实战：构建简单的 TCP 聊天程序、远程命令执行、文件传输
• 常见误区与最佳实践

并通过丰富的代码示例和真实项目场景讲解，帮助你写出更高效、更安全、结构更清晰的 Java TCP 通信代码。

---

🧱 一、什么是 TCP？

✅ TCP（Transmission Control Protocol）定义：

TCP 是一种面向连接、可靠、基于字节流的传输协议，它在发送数据前需要建立连接（三次握手），数据传输结束后释放连接（四次挥手）。

✅ TCP 的特点：

特点	描述
面向连接	发送数据前必须先建立连接
可靠传输	数据不会丢失，保证顺序
面向字节流	数据以字节流形式传输
有流量控制和拥塞控制	自动调整传输速率
传输效率较低	由于确认机制、重传机制，延迟较高
适用场景	文件传输、网页请求、数据库通信、远程登录等

---

🔍 二、TCP 与 UDP 的区别

对比项	TCP	UDP
是否连接	是（三次握手）	否（无连接）
是否可靠	是（有确认机制）	否（无确认）
数据顺序	保证顺序	不保证顺序
传输效率	相对较低	高
适用场景	文件传输、网页请求、数据库通信	视频会议、游戏、广播通信
Java 类	Socket、ServerSocket	DatagramSocket、DatagramPacket

---

🧠 三、Java 中的 TCP 编程核心类

✅ 1. ServerSocket

用于监听客户端连接，是 TCP 服务端的核心类。

✅ 2. Socket

用于客户端与服务端之间的通信，代表一个连接。

✅ 3. InputStream / OutputStream

用于读取和写入数据流。

---

🧪 四、Java TCP 通信实战示例

示例1：TCP 服务端（单线程）

import java.io.*;
import java.net.*;public class TcpServer {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(8888);System.out.println("服务端启动，等待连接...");Socket socket = serverSocket.accept(); // 等待客户端连接BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line = reader.readLine();System.out.println("收到客户端消息：" + line);socket.close();serverSocket.close();}
}

---

示例2：TCP 客户端

import java.io.*;
import java.net.*;public class TcpClient {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1", 8888);PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);writer.println("Hello Server");socket.close();}
}

---

🧱 五、TCP 的粘包与拆包问题

✅ 什么是粘包与拆包？

• 粘包（Sticky Packet）：多个数据包被合并成一个包接收。
• 拆包（Split Packet）：一个数据包被拆分成多个包接收。

✅ 原因：

• TCP 是面向字节流的协议，没有消息边界
• 操作系统或网络设备的缓冲区合并或拆分

✅ 解决方案：

1. 自定义协议头（如消息长度、消息类型）
2. 使用分隔符（如 \n、\r\n）
3. 使用固定长度的消息体
4. 使用 Netty 的 LineBasedFrameDecoder、DelimiterBasedFrameDecoder 等解码器

---

🧩 六、多线程处理 TCP 请求（服务端并发处理）

import java.io.*;
import java.net.*;
import java.util.concurrent.*;public class MultiThreadTcpServer {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(8888);ExecutorService pool = Executors.newCachedThreadPool();System.out.println("服务端启动，等待连接...");while (true) {Socket socket = serverSocket.accept();pool.execute(new ClientHandler(socket));}}static class ClientHandler implements Runnable {private final Socket socket;public ClientHandler(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while ((line = reader.readLine()) != null) {System.out.println("收到消息：" + line);}socket.close();} catch (IOException e) {e.printStackTrace();}}}
}

---

🧪 七、TCP 通信实战应用场景

场景1：构建 TCP 聊天程序（多线程）

// 服务端
new Thread(() -> {try (ServerSocket serverSocket = new ServerSocket(8888)) {while (true) {Socket socket = serverSocket.accept();new Thread(() -> {try (BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {String line;while ((line = reader.readLine()) != null) {System.out.println("收到消息：" + line);}} catch (IOException e) {e.printStackTrace();}}).start();}} catch (IOException e) {e.printStackTrace();}
}).start();// 客户端
Socket socket = new Socket("127.0.0.1", 8888);
PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
writer.println("你好，服务器！");

---

场景2：远程命令执行（如 Telnet）

// 服务端接收命令并执行
Process process = Runtime.getRuntime().exec(line);
BufferedReader resultReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
String resultLine;
while ((resultLine = resultReader.readLine()) != null) {writer.println(resultLine);
}

---

场景3：TCP 文件传输

// 客户端发送文件
FileInputStream fis = new FileInputStream("send.txt");
OutputStream os = socket.getOutputStream();
byte[] buffer = new byte[1024];
int bytesRead;
while ((bytesRead = fis.read(buffer)) != -1) {os.write(buffer, 0, bytesRead);
}
os.flush();// 服务端接收文件
FileOutputStream fos = new FileOutputStream("received.txt");
InputStream is = socket.getInputStream();
byte[] buffer = new byte[1024];
int bytesRead;
while ((bytesRead = is.read(buffer)) != -1) {fos.write(buffer, 0, bytesRead);
}

---

🧱 八、TCP 通信最佳实践

实践	描述
显式关闭资源	使用 try-with-resources 或 finally 块关闭 socket、流
设置超时时间	避免长时间阻塞，如 socket.setSoTimeout(3000)
使用缓冲流提高效率	如 BufferedReader、BufferedWriter
使用多线程处理并发请求	服务端应为每个连接创建新线程或使用线程池
使用协议封装通信数据	自定义协议头、长度、内容，避免粘包
使用日志记录通信	方便排查问题
使用异常处理机制	捕获 IOException、UnknownHostException 等
使用 NIO 提升性能	如 SocketChannel + Selector
使用 Netty 构建高性能 TCP 应用	更高级的网络通信框架
使用 KeepAlive 保持连接	避免连接意外断开

---

🚫 九、常见误区与注意事项

误区	正确做法
忘记关闭 socket	使用 try-with-resources 自动关闭
不设置超时	导致程序挂起，应设置连接和读取超时
不处理异常	必须捕获并处理网络异常
不使用缓冲流	导致频繁 IO 操作，效率低
忽略协议设计	导致粘包、拆包问题，应设计协议头
使用字节流直接转字符串	应使用 InputStreamReader 指定编码
忽略并发处理	服务端应支持多线程或 NIO
不使用日志记录通信	难以排查问题，应记录请求和响应
不使用 KeepAlive	应设置 socket.setKeepAlive(true)
不使用 NIO	高并发下应使用非阻塞 IO 提升性能

---

📊 十、总结：Java TCP 通信核心知识点一览表

内容	说明
TCP 定义	面向连接、可靠、基于字节流的传输协议
TCP 特点	保证顺序、有确认机制、适合高可靠性传输
Java 类	Socket、ServerSocket、InputStream、OutputStream
通信流程	建立连接 → 读写数据 → 释放连接
粘包/拆包	需要设计协议头或使用分隔符处理
实际应用	聊天程序、远程调用、文件传输、数据库连接
最佳实践	显式关闭资源、设置超时、协议设计、多线程
注意事项	异常处理、日志记录、KeepAlive、NIO 使用

---

📎 十一、附录：Java TCP 通信常用技巧速查表

技巧	示例
获取本机 IP 地址	InetAddress.getLocalHost().getHostAddress()
获取远程 IP 地址	socket.getInetAddress().getHostAddress()
设置连接超时	socket.setSoTimeout(5000)
使用缓冲流	new BufferedReader(new InputStreamReader(...))
使用 NIO 实现非阻塞通信	SocketChannel + Selector
使用线程池处理客户端连接	ExecutorService 处理每个 socket 连接
使用 Netty 构建高性能 TCP 应用	NettyServerBootstrap
自定义协议头	消息长度 + 消息内容
使用 KeepAlive	socket.setKeepAlive(true)
使用 PrintWriter 发送文本	writer.println("message")

欢迎点赞、收藏、转发，也欢迎留言交流你在实际项目中遇到的 TCP 通信相关问题。我们下期再见 👋

📌 关注我，获取更多Java核心技术深度解析！