Java TCP通信案例怎么实操

wen java案例 2026-07-01 21

Java TCP通信案例怎么实操：从零搭建稳定Socket通信的完整指南

目录导读

TCP通信基础与Java实现原理
环境准备与核心类解析
完整实操案例：客户端与服务端一对一通信
进阶：多客户端并发通信的线程池方案
常见问题与性能优化问答
总结与最佳实践

TCP通信基础与Java实现原理

TCP（传输控制协议）是面向连接的、可靠的、基于字节流的传输层协议，在Java中，TCP通信主要通过java.net.ServerSocket（服务端）和java.net.Socket（客户端）两个核心类实现，其工作流程遵循“三握四挥”机制：建立连接时三次握手,断开连接时四次挥手。

Java TCP通信案例怎么实操

核心概念速查：

IP地址 + 端口号：唯一标识网络中的某个进程
输入/输出流：通过InputStream和OutputStream进行数据读写
阻塞特性：默认情况下，accept()、read()方法会阻塞当前线程

为什么选择Java进行TCP通信开发？ Java提供了完善的网络编程API，跨平台性强，且通过多线程能轻松处理高并发场景，相比C/C++，Java的内存管理更安全,不易出现缓冲区溢出等问题。

环境准备与核心类解析

1 工具与环境

JDK 1.8+
IDE（推荐IntelliJ IDEA或Eclipse）
无额外第三方依赖，纯JDK内置API

2 核心类一览

类名	作用	关键方法
`ServerSocket`	服务端监听端口，等待客户端连接	`accept()`、`bind()`
`Socket`	表示客户端连接或服务端连接客户端的套接字	`getInputStream()`、`getOutputStream()`、`close()`
`InetAddress`	封装IP地址信息	`getByName()`

3 通信流程图

graph LR
A[服务端启动] --> B[创建ServerSocket]
B --> C[绑定端口并监听]
C --> D[调用accept等待连接]
D --> E[客户端创建Socket]
E --> F[连接服务端IP+端口]
F --> G[建立TCP连接]
G --> H[通过IO流交换数据]
H --> I[关闭连接]

完整实操案例：客户端与服务端一对一通信

1 服务端代码（Server.java）

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class TCPServer {
    public static void main(String[] args) {
        int port = 8888; // 监听端口
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("服务端启动，监听端口: " + port);
            Socket socket = serverSocket.accept(); // 阻塞等待客户端连接
            System.out.println("客户端连接成功: " + socket.getInetAddress());
            BufferedReader reader = new BufferedReader(
                new InputStreamReader(socket.getInputStream()));
            PrintWriter writer = new PrintWriter(
                new OutputStreamWriter(socket.getOutputStream()), true);
            String msg;
            while ((msg = reader.readLine()) != null) {
                System.out.println("收到客户端消息: " + msg);
                writer.println("服务端回复: " + msg.toUpperCase());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

2 客户端代码（Client.java）

import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class TCPClient {
    public static void main(String[] args) {
        String serverIp = "127.0.0.1"; // 本地回环地址
        int port = 8888;
        try (Socket socket = new Socket(serverIp, port);
             BufferedReader reader = new BufferedReader(
                 new InputStreamReader(socket.getInputStream()));
             PrintWriter writer = new PrintWriter(
                 new OutputStreamWriter(socket.getOutputStream()), true);
             Scanner scanner = new Scanner(System.in)) {
            System.out.println("已连接服务端，输入消息（输入exit退出）:");
            String input;
            while (!(input = scanner.nextLine()).equals("exit")) {
                writer.println(input);
                System.out.println("服务端回复: " + reader.readLine());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

3 运行测试步骤

先启动TCPServer，看到“服务端启动”日志
再启动TCPClient，输入任意字符
服务端接收后返回大写转换后的消息
客户端输入“exit”主动断开连接

注意事项：

客户端必须指定正确的IP和端口
使用try-with-resources自动关闭资源，避免内存泄漏
PrintWriter构造函数的第二个参数autoFlush设为true，确保数据实时发送

进阶：多客户端并发通信的线程池方案

真实业务中，服务端需要同时处理多个客户端连接，每个连接分配一个独立线程,使用线程池管理资源。

1 改进版服务端（使用线程池）

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class MultiThreadTCPServer {
    public static void main(String[] args) {
        int port = 8888;
        ExecutorService threadPool = Executors.newFixedThreadPool(10);
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("多线程服务端启动...");
            while (true) {
                Socket socket = serverSocket.accept();
                threadPool.submit(() -> handleClient(socket));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    private static void handleClient(Socket socket) {
        try (socket) {
            System.out.println("处理客户端: " + socket.getInetAddress());
            BufferedReader reader = new BufferedReader(
                new InputStreamReader(socket.getInputStream()));
            PrintWriter writer = new PrintWriter(
                new OutputStreamWriter(socket.getOutputStream()), true);
            String msg;
            while ((msg = reader.readLine()) != null) {
                System.out.println(Thread.currentThread().getName() + " 收到: " + msg);
                writer.println("线程" + Thread.currentThread().getId() + "回复: " + msg);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

线程池优势说明：