当前位置：首页 > 文章列表 > 文章 > java教程 > 在Java中如何使用Socket进行TCP通信

在Java中如何使用Socket进行TCP通信

2025-10-17 08:45:14 0浏览收藏

小伙伴们对文章编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《在Java中如何使用Socket进行TCP通信》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

答案：Java中使用Socket进行TCP通信需依赖ServerSocket和Socket类，服务端通过ServerSocket监听指定端口并接受客户端连接，获得Socket实例后通过输入输出流收发数据；客户端通过Socket连接服务端并交换信息；为支持多客户端，可为每个连接创建独立线程处理；需注意端口占用、资源释放、流阻塞及异常处理等问题，建议使用try-with-resources确保资源安全关闭。

在Java中使用Socket进行TCP通信，主要依赖于java.net.Socket和java.net.ServerSocket这两个类。TCP通信是面向连接的，保证数据可靠传输，适合需要稳定通信的场景，比如文件传输、即时消息等。

1. 服务端如何监听客户端连接

服务端通过ServerSocket绑定一个端口，等待客户端连接。一旦有客户端接入，会返回一个Socket实例用于后续通信。

示例代码：

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

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

        Socket socket = serverSocket.accept(); // 阻塞等待客户端连接
        System.out.println("客户端已连接：" + socket.getInetAddress());

        // 获取输入流，读取客户端发送的数据
        BufferedReader in = new BufferedReader(
            new InputStreamReader(socket.getInputStream())
        );

        String message = in.readLine();
        System.out.println("收到消息：" + message);

        // 向客户端发送响应
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        out.println("消息已收到");

        // 关闭资源
        in.close();
        out.close();
        socket.close();
        serverSocket.close();
    }
}

2. 客户端如何连接服务端并发送数据

客户端使用Socket指定服务端IP和端口发起连接，连接成功后可以通过输入输出流与服务端交换数据。

示例代码：

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

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("localhost", 8888); // 连接本地8888端口

        // 发送消息到服务端
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        out.println("Hello, Server!");

        // 接收服务端响应
        BufferedReader in = new BufferedReader(
            new InputStreamReader(socket.getInputStream())
        );

        String response = in.readLine();
        System.out.println("服务端响应：" + response);

        // 关闭资源
        out.close();
        in.close();
        socket.close();
    }
}

3. 处理多客户端连接（使用线程）

如果服务端需要同时处理多个客户端，可以为每个连接创建一个独立线程。

修改服务端代码：

public class MultiClientServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("多客户端服务器启动...");

        while (true) {
            Socket socket = serverSocket.accept();
            // 每个客户端分配一个线程
            new Thread(new ClientHandler(socket)).start();
        }
    }

    // 处理单个客户端的线程
    static class ClientHandler implements Runnable {
        private Socket socket;

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

        public void run() {
            try {
                BufferedReader in = new BufferedReader(
                    new InputStreamReader(socket.getInputStream())
                );
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

                String message;
                while ((message = in.readLine()) != null) {
                    System.out.println("客户端说：" + message);
                    out.println("回显：" + message);
                }

                in.close();
                out.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}