package com.webserver.core;

import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 *webServer主类
 */
public class WebServer {
	private ServerSocket server;
	//声明线程池变量
	private ExecutorService pool;
	
	public WebServer() {
		try {
			//创建线程池对象，最多并发100个线程
			pool = Executors.newFixedThreadPool(100);
			server = new ServerSocket(8088);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public void start() {
		try {
			/*
			 * 暂时不开启接收多次客户端连接
			 */
			while(true) {
				Socket socket = server.accept();
//				//启动一个线程处理该客户端交互
				ClientHandler handler = new ClientHandler(socket);
//				Thread t = new Thread(handler);
				//将客户端服务任务提交到线程池
				pool.execute(handler);
//				t.start();
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
		WebServer server = new WebServer();
		server.start();
	}
	
	
	
}