Java基于TCP协议的Socket通信实战：原理与多线程实现

顾星河

发布时间：2026-10-16 | 4人浏览过

原创

本文深入解析Java网络编程核心——TCP Socket通信。内容涵盖ServerSocket的关键配置（如backlog队列长度）、连接建立流程，并提供一套完整的多线程服务器端与客户端代码示例，实现稳定的数据收发与并发处理。

TCP与Socket核心机制

第1步：理解TCP传输特性

TCP（Transmission Control Protocol）是面向连接的、可靠的、基于字节流的传输层通信协议。在因特网协议族中，它位于IP层之上，应用层之下，负责提供类似管道的可靠数据传输。相比UDP的不可靠包交换，TCP通过以下机制确保数据无误：

序号与确认：为每个数据包分配序号，接收端返回ACK确认；若发送端在RTT内未收到确认，则重传数据。
校验和：发送和接收时均计算校验和，检测数据是否有误。
流量控制：通过滑动窗口等机制避免发送方速度超过接收方处理能力。

第2步：掌握Socket套接字概念

Socket（套接字）是通信链路的句柄，描述IP地址和端口。在Java中，相关类库位于 java.net 包：
- ServerSocket：用于服务器端监听端口。
- Socket：用于建立网络连接。
两者均通过内部类 SocketImpl 完成底层操作。关键API包括：

accept()：阻塞等待并接受一个客户端连接，返回Socket实例。
getInputStream()：获取输入流，读取对方发来的数据。
getOutputStream()：获取输出流，向对方发送数据。

ServerSocket构建与配置

第3步：创建并绑定服务器端口

在使用 ServerSocket 前，需选择合适的构造函数。常用方式如下：

new ServerSocket(port)：绑定指定端口，使用系统默认背对列长度。
new ServerSocket(port, backlog)：指定端口及连接请求队列长度。
new ServerSocket() + bind()：先创建对象，再绑定端口（允许在绑定前设置选项，如 SO_REUSEADDR）。

注意：绑定低端口（1-1023）可能需要管理员权限；若端口被占用或权限不足，将抛出 BindException。

第4步：配置连接请求队列（Backlog）

backlog 参数定义了操作系统接受但未立即处理的连接请求队列最大长度。当队列满时，新的客户端连接会被拒绝（抛出 ConnectException）。

队列满场景：若服务器未调用 accept() 取出连接，队列迅速填满后新客户端将无法连接。
动态处理：若服务器循环调用 accept()，队列腾出空间后，新客户端可继续连接。

例如，设置 backlog=3 且服务器暂不处理连接时，客户端尝试100次连接仅前3次成功，后续均失败。

第5步：多网卡环境下的IP绑定

若主机有多个IP，可通过第四个构造参数显式指定绑定的IP地址：

ServerSocket serverSocket = new ServerSocket(8000, 10, InetAddress.getByName("192.168.3.4"));

此外，推荐使用空参构造后绑定，以便在绑定前启用 SO_REUSEADDR 选项，防止服务器重启时因端口处于TIME_WAIT状态而无法立即复用：

ServerSocket serverSocket = new ServerSocket();
serverSocket.setReuseAddress(true);
serverSocket.bind(new InetSocketAddress(8000));

多线程Socket通信实战

第6步：编写服务端主逻辑（多任务处理）

为避免单个 accept() 处理耗时过长导致阻塞后续连接，服务端需为每个客户端创建独立线程。以下是支持用户登录验证的服务端代码：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        // 1. 创建ServerSocket监听8888端口
        ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("***服务器启动，等待连接***");

        int count = 0;
        while (true) {
            // 2. 阻塞等待并接受连接
            Socket socket = serverSocket.accept();
            count++;
            
            // 3. 为每个连接启动新线程
            new Thread(new ServerThread(socket)).start();
            System.out.println("当前在线客户端数：" + count);
        }
    }
}

第7步：实现线程级业务逻辑（读写分离）

每个线程负责处理单一客户端的数据交互。典型流程为：获取输入流解析指令 → 业务处理 → 获取输出流返回响应 → 关闭资源。

import java.io.*;
import java.net.Socket;

public class ServerThread implements Runnable {
    private Socket socket;

    public ServerThread(Socket socket) { this.socket = socket; }

    @Override
    public void run() {
        BufferedReader br = null;
        PrintWriter pw = null;
        try {
            // 初始化流
            InputStream is = socket.getInputStream();
            OutputStream os = socket.getOutputStream();
            br = new BufferedReader(new InputStreamReader(is));
            pw = new PrintWriter(os, true); // 自动刷新

            // 读取客户端信息
            String msg;
            while ((msg = br.readLine()) != null) {
                System.out.println("收到消息：" + msg);
                if ("用户名：whf;密码：789".equals(msg)) {
                    pw.println("欢迎您！");
                    break; // 验证成功退出循环
                } else {
                    pw.println("账号或密码错误");
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 安全关闭资源
            try {
                if (socket != null) socket.close();
            } catch (IOException e) { e.printStackTrace(); }
        }
    }
}

第8步：编写客户端发起连接

客户端需指定服务器地址与端口，获取输出流发送数据，获取输入流接收响应，并注意关闭连接以释放TCP链路。

import java.io.*;
import java.net.Socket;

public class Client {
    public static void main(String[] args) {
        try {
            // 1. 建立连接
            Socket socket = new Socket("localhost", 8888);

            // 2. 发送数据
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os);
            pw.write("用户名：whf;密码：789");
            pw.flush();
            socket.shutdownOutput(); // 结束发送，通知服务端

            // 3. 读取响应
            InputStream is = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            String response;
            while ((response = br.readLine()) != null) {
                System.out.println("服务器回应：" + response);
            }

            // 4. 关闭资源
            br.close();
            pw.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}