BS架构模拟

package com.cfqp;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;

public class Server {
    private static ExecutorService pool = new ThreadPoolExecutor(2, 5, 6, TimeUnit.SECONDS,
            new ArrayBlockingQueue<>(2), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());

    public static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(8080);

        while (true) {
            Socket socket = serverSocket.accept();
            pool.execute(new ServerWriterRunnable(socket));
        }
    }
}

class ServerWriterRunnable implements Runnable {
    private Socket socket;

    public ServerWriterRunnable(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        OutputStream os = null;
        try {
            os = socket.getOutputStream();
            PrintStream ps = new PrintStream(os);
            ps.println("HTTP/1/1 200 OK");
            ps.println("Content-Type:text/html;charset=UTF-8");
            ps.println();
            ps.println("<span style='color:red';fontsize:90px'>《My Dream And My Future》</span>");
            ps.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}