public interface ThreadPool<Job extends Runnable> {/*** 线程池开始*/void execute(Job job);/*** 关闭线程池*/void shutDown();/*** 添加线程* @param num*/void addWorkers(int num);/*** 减少线程* @param num*/void removeWorker(int num);/*** 获取正在等待的线程数量* @return*/int getJobSize();
}

public class DefaultThreadPool<Job extends Runnable> implements ThreadPool<Job> {private static final int MAX_WORKER_NUMBERS = 10;private static final int DEFAULT_WORKERS_NUMBERS = 2 * (Runtime.getRuntime().availableProcessors()) + 1;private static final int MIN_WORDER_NUMBERS = 1;private final LinkedList<Job> jobs = new LinkedList<Job>();//管理工作线程的集合private final List<Worker> workers = Collections.synchronizedList(new ArrayList<Worker>());private int workerNum = DEFAULT_WORKERS_NUMBERS;private AtomicLong threadNum = new AtomicLong();/*** 线程开始运行*/public DefaultThreadPool() {initWorkers(DEFAULT_WORKERS_NUMBERS);}public DefaultThreadPool(int num) {workerNum = num > MAX_WORKER_NUMBERS ? MAX_WORKER_NUMBERS : num < MIN_WORDER_NUMBERS ? MIN_WORDER_NUMBERS : num;}/*** 初始化线程** @param defaultWorkersNumbers*/private void initWorkers(int defaultWorkersNumbers) {for (int i = 0; i < defaultWorkersNumbers; i++) {Worker worker = new Worker();workers.add(worker);Thread thread = new Thread(worker, "ThreadPool-worker" + threadNum.incrementAndGet());thread.start();}}/*** 执行任务** @param job*/@Overridepublic void execute(Job job) {if (job != null) {synchronized (jobs) {jobs.addLast(job);jobs.notify();}}}/*** 关闭线程*/@Overridepublic void shutDown() {for (Worker worker : workers) {if (worker != null) {worker.shutDown();}}}/*** 添加线程** @param num*/@Overridepublic void addWorkers(int num) {synchronized (jobs) {if (num + this.workerNum > MAX_WORKER_NUMBERS) {num = MAX_WORKER_NUMBERS - this.workerNum;}initWorkers(num);this.workerNum += num;}}/*** 移除线程** @param num*/@Overridepublic void removeWorker(int num) {synchronized (jobs) {if (num > workerNum) {throw new IllegalArgumentException("much workNum");}int count = 0;while (count < num) {Worker worker = workers.get(count);if (workers.remove(worker)) {worker.shutDown();count++;}}this.workerNum -= count;}}/*** 获取工作线程的数量** @return*/@Overridepublic int getJobSize() {return jobs.size();}/*** 工作线程*/public class Worker implements Runnable {private volatile boolean running = false;@Overridepublic void run() {while (running) {Job job = null;synchronized (jobs) {while (jobs.isEmpty()) {try {jobs.wait();} catch (InterruptedException ex) {ex.printStackTrace();Thread.currentThread().interrupt();return;}}job = jobs.removeFirst();}if (job != null) {try {job.run();} catch (Exception ex) {ex.printStackTrace();}}}}public void shutDown() {this.running = false;}}
}

public class SimleHttpHandler {static ThreadPool<HttpRequestHandler> threadPool = new DefaultThreadPool<HttpRequestHandler>(1);public String basePath;private ServerSocket serverSocket;@Resourceprivate HttpRequestHandler httpRequstHandler;int port = 8080;/*** 设置端口** @param port*/public void setPort(int port) {if (port > 0) {this.port = port;}}/*** 设置基本路径** @param basePath*/public void setBasePath(String basePath) {if (basePath != null) {boolean exist = new File(basePath).exists();boolean directory = new File(basePath).isDirectory();if (exist && directory) {this.basePath = basePath;}}}/*** 开始线程** @throws Exception*/public void start() throws Exception {serverSocket = new ServerSocket(port);Socket socket = null;while ((socket = serverSocket.accept()) != null) {try {threadPool.execute(new HttpRequestHandler(socket, basePath));} catch (Exception ex) {ex.printStackTrace();} finally {serverSocket.close();}}}
}

@Component
public class HttpRequestHandler implements Runnable {private Socket socket;private String basePath;@Resourceprivate ServerRequestManager serverRequestManager;public HttpRequestHandler(Socket socket, String basePath) {this.basePath = basePath;this.socket = socket;}@Overridepublic void run() {serverRequestManager.dealRequest(basePath);}
}

 */
@Component
public class ServerRequestManager {private Socket socket;public static final String httpOK = "HTTP/1.1 200 ok";public static final String molly = "Server:Molly";public static final String contentType = "Content-Type:";/*** 处理请求** @param basePath*/public void dealRequest(String basePath) {String content = null;BufferedReader br = null;BufferedReader reader = null;PrintWriter out = null;InputStream in = null;try {reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String header = reader.readLine();String filePath = basePath + header.split(" ")[1];out = new PrintWriter(socket.getOutputStream());if (filePath.endsWith("jpg") || filePath.endsWith("ico")) {in = new FileInputStream(filePath);ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();int index = 0;while ((index = in.read()) != -1) {byteArrayOutputStream.write(index);}byte[] array = byteArrayOutputStream.toByteArray();out.print(httpOK);out.print(molly);out.println(contentType + " image/jpeg");out.println("Content-Length" + array.length);out.print("");socket.getOutputStream().write(array, 0, array.length);} else {br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath)));out = new PrintWriter(socket.getOutputStream());out.print(httpOK);out.print(molly);out.print(contentType + "text/html; Charset =UTF-8");out.print("");while ((content = br.readLine()) != null) {out.print(content);}}out.flush();} catch (final Exception ex) {ex.printStackTrace();out.println("HTTP/1.1 500");out.println("");out.flush();} finally {close(br, in, out, socket);}}/*** 关闭流** @param closeables*/public static void close(Closeable... closeables) {if (closeables != null) {for (Closeable closeable : closeables) {try {closeable.close();} catch (Exception ex) {ex.printStackTrace();}}}}
}