ServerImpl是http、https服务的实现。

下表为ServerImpl的成员

部分成员函数

bind (InetSocketAddress addr, int backlog) : 绑定ip地址和backlog

public void bind (InetSocketAddress addr, int backlog) throws IOException {
    if (bound) {
        throw new BindException ("HttpServer already bound");
    }
    if (addr == null) {
        throw new NullPointerException ("null address");
    }
    ServerSocket socket = schan.socket();
    socket.bind (addr, backlog);
    bound = true;
}

setExecutor (Executor executor)：设置Executor， 必须在server没有启动的时候设置。

DefaultExecutor会直接执行run(), 这种情况下是没有启动新的线程的。

public void setExecutor (Executor executor) {
    if (started) {
        throw new IllegalStateException ("server already started");
    }
    this.executor = executor;
}
private static class DefaultExecutor implements Executor {
    public void execute (Runnable task) {
        task.run();
    }
}
public Executor getExecutor () {
    return executor;
}

start() : 启动一个dispatcher线程，将started设置为true

public void start () {
    if (!bound || started || finished) {
        throw new IllegalStateException ("server in wrong state");
    }
    if (executor == null) {
        executor = new DefaultExecutor();
    }
    dispatcherThread = new Thread(null, dispatcher, "HTTP-Dispatcher", 0, false);
    started = true;
    dispatcherThread.start();
}

stop(): 唤醒selector处理事件; 关闭所有的HttpConnection(对于allConnections上锁); 取消定时器; 等待dispatcherThread结束。

public void stop (int delay) {
    if (delay < 0) {
        throw new IllegalArgumentException ("negative delay parameter");
    }
    terminating = true;
    try { schan.close(); } catch (IOException e) {}
    selector.wakeup();
    long latest = System.currentTimeMillis() + delay * 1000;
    while (System.currentTimeMillis() < latest) {
        delay();
        if (finished) {
            break;
        }
    }
    finished = true;
    selector.wakeup();
    synchronized (allConnections) {
        for (HttpConnection c : allConnections) {
            c.close();
        }
    }
    allConnections.clear();
    idleConnections.clear();
    timer.cancel();
    if (timer1Enabled) {
        timer1.cancel();
    }
    if (dispatcherThread != null && dispatcherThread != Thread.currentThread()) {
        try {
            dispatcherThread.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            logger.log (Level.TRACE, "ServerImpl.stop: ", e);
        }
    }
}

createContext (String path, HttpHandler handler)： 会根据路径和处理者去获得一个HttpContextImpl对象， 并且加入到ContextList类型的对象contexts中。该方法被synchronized修饰。

removeContext (String path), removeContext (HttpContext context)： 从contexts中移除一个HttpContext类型的对象。该方法被synchronized修饰。

addEvent (Event r) ：添加事件并且唤醒selector，利用lolock上锁。

void addEvent (Event r) {
    synchronized (lolock) {
        events.add (r);
        selector.wakeup();
    }
}

closeConnection(HttpConnection conn): 关闭连接，并且从连接池中移除