java http proxy

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

public class SimpleHttpProxy {
    public static void main(String[] args) throws IOException {
        int port = 8080; // 代理服务器监听的端口
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("Proxy server started on port " + port);

        while (true) {
            Socket clientSocket = serverSocket.accept();
            new Thread(new ProxyHandler(clientSocket)).start();
        }
    }

    static class ProxyHandler implements Runnable {
        private Socket clientSocket;

        public ProxyHandler(Socket clientSocket) {
            this.clientSocket = clientSocket;
        }

        @Override
        public void run() {
            try (
                BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
                Socket serverSocket = new Socket("example.com", 80); // 目标服务器地址和端口
                BufferedReader serverIn = new BufferedReader(new InputStreamReader(serverSocket.getInputStream()));
                PrintWriter serverOut = new PrintWriter(serverSocket.getOutputStream(), true)
            ) {
                // 将客户端请求转发到目标服务器
                String requestLine;
                while ((requestLine = in.readLine()) != null && !requestLine.isEmpty()) {
                    serverOut.println(requestLine);
                }

                // 将目标服务器的响应转发回客户端
                String responseLine;
                while ((responseLine = serverIn.readLine()) != null) {
                    out.println(responseLine);
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    clientSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

import java.util.concurrent.*;

public class SimpleHttpProxy {
    public static void main(String[] args) throws IOException {
        int port = 8080;
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("Proxy server started on port " + port);

        ExecutorService executorService = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池

        while (true) {
            Socket clientSocket = serverSocket.accept();
            executorService.submit(new ProxyHandler(clientSocket));
        }
    }
}