import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * TCP回显服务器实现类
 * 功能：接收客户端消息并原样返回（回显）
 */
public class TcpEchoServer {
    private ServerSocket serverSocket = null;  // 服务器套接字对象

    // 构造方法：初始化服务器并绑定端口
    public TcpEchoServer(int port) throws IOException {
        serverSocket = new ServerSocket(port);  // 创建ServerSocket并绑定指定端口
    }

    /**
     * 启动服务器核心逻辑
     */
    public void start() throws IOException {
        System.out.println("启动服务器");
        
        // 创建线程池（动态调整线程数量，适合短任务）
        ExecutorService executorService = Executors.newCachedThreadPool();

        // 持续监听客户端连接
        while (true) {
            // 阻塞等待客户端连接
            Socket clientSocket = serverSocket.accept();
            
            // 将客户端连接提交给线程池处理
            executorService.submit(() -> {
                try {
                    processConnection(clientSocket);  // 处理单个客户端连接
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
        }
    }

    /**
     * 处理单个客户端连接的完整生命周期
     * @param clientSocket 客户端套接字对象
     */
    private void processConnection(Socket clientSocket) throws IOException {
        // 打印客户端连接信息
        System.out.printf("[%s:%d] 客户端上线!\n", 
                         clientSocket.getInetAddress(), 
                         clientSocket.getPort());
        
        // 使用try-with-resources自动关闭流
        try (InputStream inputStream = clientSocket.getInputStream();
             OutputStream outputStream = clientSocket.getOutputStream()) {
            
            // 使用Scanner和PrintWriter包装流对象
            Scanner scanner = new Scanner(inputStream);    // 输入流扫描器
            PrintWriter printWriter = new PrintWriter(outputStream);  // 输出流写入器

            // 持续处理客户端请求
            while (true) {
                // 1. 检测连接状态（若输入流中没有数据，说明客户端断开）
                if (!scanner.hasNext()) {
                    System.out.printf("[%s:%d] 客户端下线!\n", 
                                    clientSocket.getInetAddress(), 
                                    clientSocket.getPort());
                    break;
                }
                
                // 2. 读取请求并处理
                String request = scanner.next();    // 读取客户端请求（空格分隔）
                String response = process(request); // 处理请求生成响应

                // 3. 返回响应给客户端
                printWriter.println(response);  // 写入响应
                printWriter.flush();            // 强制刷新缓冲区
            }
        } catch (IOException e) {
            throw new RuntimeException(e);
        } finally {
            try {
                clientSocket.close();  // 确保关闭客户端套接字
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    }

    /**
     * 处理请求的核心逻辑（示例为简单回显）
     * @param request 客户端请求内容
     * @return 返回与请求相同的字符串
     */
    private String process(String request) {
        // 此处可添加业务逻辑（示例直接返回原内容）
        return request;
    }

    /**
     * 主方法：启动服务器实例
     */
    public static void main(String[] args) throws IOException {
        TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);  // 创建服务器实例（端口9090）
        tcpEchoServer.start();  // 启动服务器
    }
}

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

public class TcpEchoClient {
    // 定义一个Socket对象，用于与服务器建立连接
    private Socket socket = null;

    // 构造函数，用于初始化客户端并连接到指定的服务器IP和端口
    private TcpEchoClient(String serverIp, int serverPort) throws IOException {
        // 创建一个Socket对象，连接到指定的服务器IP和端口
        socket = new Socket(serverIp, serverPort);
    }

    // 启动客户端，开始与服务器进行通信
    public void start() {
        // 创建一个Scanner对象，用于从控制台读取用户输入
        Scanner scanner = new Scanner(System.in);
        try (
            // 获取Socket的输入流，用于接收服务器发送的数据
            InputStream inputStream = socket.getInputStream();
            // 获取Socket的输出流，用于向服务器发送数据
            OutputStream outputStream = socket.getOutputStream()
        ) {
            // 创建一个Scanner对象，用于从输入流中读取服务器发送的数据
            Scanner scannerNet = new Scanner(inputStream);
            // 创建一个PrintWriter对象，用于向输出流中写入数据
            PrintWriter writer = new PrintWriter(outputStream);

            // 进入一个无限循环，持续与服务器进行通信
            while (true) {
                // 从控制台读取用户输入的数据
                String request = scanner.next();
                // 将用户输入的数据发送到服务器
                writer.println(request);
                // 刷新输出流，确保数据被发送
                writer.flush();
                // 从服务器读取响应数据
                String response = scannerNet.next();
                // 将服务器返回的响应数据打印到控制台
                System.out.println(response);
            }
        } catch (IOException e) {
            // 如果发生IO异常，抛出运行时异常
            throw new RuntimeException(e);
        }
    }

    // 主函数，程序的入口
    public static void main(String[] args) throws IOException {
        // 创建一个TcpEchoClient对象，连接到本地服务器的9090端口
        TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9090);
        // 启动客户端，开始与服务器通信
        client.start();
    }
}