java tcp通信

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

public class TCPServer {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(8080)) {
            System.out.println("服务器已启动，等待客户端连接...");
            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("客户端已连接");
                new Thread(new ClientHandler(socket)).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    static class ClientHandler implements Runnable {
        private Socket socket;

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

        @Override
        public void run() {
            try (
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true)
            ) {
                String inputLine;
                while ((inputLine = in.readLine()) != null) {
                    System.out.println("收到客户端消息: " + inputLine);
                    out.println("服务器已收到: " + inputLine);
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

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

public class TCPClient {
    public static void main(String[] args) {
        try (Socket socket = new Socket("localhost", 8080);
             BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
             BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in))) {

            String userInput;
            while ((userInput = stdIn.readLine()) != null) {
                out.println(userInput);
                System.out.println("服务器回复: " + in.readLine());
            }
        } catch (UnknownHostException e) {
            System.err.println("未知主机: " + e.getMessage());
        } catch (IOException e) {
            System.err.println("I/O 错误: " + e.getMessage());
        }
    }
}

解释说明

1. TCPServer 类:

   • 创建一个 ServerSocket 对象并绑定到端口 8080。
   • 使用 accept() 方法等待客户端连接。
   • 每当有新的客户端连接时，创建一个新的线程来处理该客户端的通信。

2. ClientHandler 类:

   • 实现了 Runnable 接口，用于处理每个客户端的通信。
   • 使用 BufferedReader 读取客户端发送的消息，使用 PrintWriter 发送消息给客户端。

3. TCPClient 类:

   • 创建一个 Socket 对象，连接到服务器的 IP 地址和端口号（这里使用的是 localhost 和 8080）。
   • 使用 BufferedReader 读取服务器的回复，使用 PrintWriter 向服务器发送消息。
   • 用户可以通过标准输入（键盘）输入消息并发送给服务器。