本文是一份围绕 Java Socket 通信的教程与代码示例的实战指南，覆盖从基础原理到实际客户端/服务器实现的完整流程，帮助开发者快速掌握网络编程的要点。
1. Java Socket通信的基础原理
1.1 端口、IP与套接字的概念
在网络通信中，IP地址用于定位主机，端口用于定位主机上的应用进程，而 套接字是应用层与传输层之间的抽象端点，承担数据的发送与接收。理解这些概念对于后续的客户端/服务器实现至关重要。
在 Java 中，服务器端通常借助 ServerSocket 来监听指定端口，客户端则通过 Socket 发起连接。一旦建立连接，双方通过输入输出流进行 数据传输，从而完成一次完整的请求-响应通信。
// 端口/套接字概念的简单演示（示意性代码，非完整应用）
public class PortDemo {public static void main(String[] args) {int port = 8080;// 端口是应用层的入口，服务器端通过端口对外提供服务System.out.println("将监听端口: " + port);}
}
1.2 阻塞与非阻塞模型的概念
阻塞模型是 Java Socket 的默认行为，调用 accept()、read 等操作会阻塞，直到发生事件或数据到达。该特性简单易用，但在高并发场景下容易导致资源等待与吞吐下降。
非阻塞模型（NIO）通过 Selector、Channel 等机制实现事件驱动和就绪通知，适合大规模并发场景。学习路线通常先掌握阻塞 IO 的核心流程，再逐步迁移到 NIO 以提升并发处理能力。
// 阻塞模型下的服务器核心循环（示意）
import java.net.ServerSocket;
import java.net.Socket;public class BlockingServerCore {public static void main(String[] args) throws Exception {ServerSocket server = new ServerSocket(8080);while (true) {Socket client = server.accept(); // 阻塞：等待客户端连接// 这里通常分派到线程处理}}
}
2. Java客户端实现：从连接到数据读取
2.1 连接服务器的步骤
要与服务器建立通信，客户端需要先知道服务器的 IP 与 端口，通过 Socket 创建连接。一旦连接成功，客户端就可以通过 输入流 与 输出流 进行数据传输。
在实际开发中，异常处理、连接超时与资源释放都需关注，通常采用 try-with-resources 语法来确保流和套接字被正确关闭。
// 客户端建立连接的最简示例
try (Socket socket = new Socket("127.0.0.1", 8080)) {// 获取输入输出流并进行数据传输
}
2.2 简单的回显客户端示例
为了快速验证通信链路的可用性，可以实现一个简单的回显客户端：向服务器发送文本，服务器回传相同的内容或带有前缀的响应，用于检查网络通路是否畅通。
在实现时，常用的 IO 组件包括 BufferedReader、PrintWriter，以及底层的 InputStream / OutputStream，以提升数据读取和写入的效率。
import java.net.Socket;
import java.io.*;public class EchoClient {public static void main(String[] args) throws Exception {try (Socket socket = new Socket("127.0.0.1", 8080);BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));PrintWriter out = new PrintWriter(socket.getOutputStream(), true);BufferedReader console = new BufferedReader(new InputStreamReader(System.in))) {String line;while ((line = console.readLine()) != null) {out.println(line);System.out.println("服务器回传: " + in.readLine());}}}
}
3. Java服务器端实现：多线程与并发
3.1 单线程服务器示例
初学者阶段可以从单线程实现入手，理解连接接收、数据读写和资源释放的基本流程。单线程模型在并发场景下容易被阻塞，因此需要在后续引入并发设计。
单线程服务器的核心流程包括：监听端口、接受连接、在客户端与服务器之间进行 读取/写出，并对异常进行处理以避免资源泄漏。
import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;public class SimpleServer {public static void main(String[] args) throws Exception {try (ServerSocket server = new ServerSocket(8080)) {System.out.println("服务器启动，等待连接...");Socket client = server.accept();BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));PrintWriter out = new PrintWriter(client.getOutputStream(), true);String line;while ((line = in.readLine()) != null) {out.println("回显: " + line);}}}
}
3.2 多客户端并发处理
在生产环境中，为了提升吞吐量和响应性，通常会引入并发模型：为每个客户端创建独立线程，或使用线程池来复用工作线程，避免频繁创建销毁带来的开销。
下面的示例展示了一个基于线程池的简单实现：主循环负责接受连接，工作线程负责具体的客户端通信。这样的结构有利于实现可扩展的客户端/服务器实现。
import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolServer {public static void main(String[] args) throws Exception {ServerSocket server = new ServerSocket(8080);ExecutorService pool = Executors.newFixedThreadPool(10);System.out.println("线程池服务器启动");while (true) {final Socket client = server.accept();pool.submit(() -> {try (BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));PrintWriter out = new PrintWriter(client.getOutputStream(), true)) {String line;while ((line = in.readLine()) != null) {out.println("处理: " + line);}} catch (IOException e) {// 处理异常}});}}
}
