@Configuration
public class TomcatConfig {

 @Bean
 public WebServerFactoryCustomizer tomcatCustomer() {
  return new TomcatCustomerConfig();
 }

 public class TomcatCustomerConfig implements WebServerFactoryCustomizer<TomcatServletWebServerFactory> {
  @Override
  public void customize(TomcatServletWebServerFactory factory) {
   if (factory != null) {
    factory.setProtocol("org.apache.coyote.http11.Http11Protocol");
   }
  }
 }
}

@Override
public void bind() throws Exception {

 // Initialize thread count defaults for acceptor
 if (acceptorThreadCount == 0) {
  acceptorThreadCount = 1;
 }
 // Initialize maxConnections
 if (getMaxConnections() == 0) {
  // User hasn't set a value - use the default
  setMaxConnections(getMaxThreadsWithExecutor());
 }

 if (serverSocketFactory == null) {
  if (isSSLEnabled()) {
   serverSocketFactory =
    handler.getSslImplementation().getServerSocketFactory(this);
  } else {
   serverSocketFactory = new DefaultServerSocketFactory(this);
  }
 }
 //這邊做了ServerSocket的端口綁定
 if (serverSocket == null) {
  try {
   if (getAddress() == null) {
    //沒(méi)指定具體地址，Tomcat會(huì)監(jiān)聽(tīng)所有地址過(guò)來(lái)的請(qǐng)求
    serverSocket = serverSocketFactory.createSocket(getPort(),
                getBacklog());
   } else {
    //指定了具體地址，Tomcat只監(jiān)聽(tīng)這個(gè)地址過(guò)來(lái)的請(qǐng)求
    serverSocket = serverSocketFactory.createSocket(getPort(),
                getBacklog(), getAddress());
   }
  } catch (BindException orig) {
   String msg;
   if (getAddress() == null)
    msg = orig.getMessage() + " <null>:" + getPort();
   else
    msg = orig.getMessage() + " " +
    getAddress().toString() + ":" + getPort();
   BindException be = new BindException(msg);
   be.initCause(orig);
   throw be;
  }
 }

}

public void startInternal() throws Exception {

 if (!running) {
  running = true;
  paused = false;

  //創(chuàng)建線程池
  if (getExecutor() == null) {
   createExecutor();
  }
  //創(chuàng)建ConnectionLatch
  initializeConnectionLatch();
  //創(chuàng)建accept線程，這個(gè)線程是請(qǐng)求處理的初始線程
  startAcceptorThreads();
  // Start async timeout thread
  Thread timeoutThread = new Thread(new AsyncTimeout(),
           getName() + "-AsyncTimeout");
  timeoutThread.setPriority(threadPriority);
  timeoutThread.setDaemon(true);
  timeoutThread.start();
 }
}

protected final void startAcceptorThreads() {
 int count = getAcceptorThreadCount();
 acceptors = new Acceptor[count];
 //根據(jù)配置，設(shè)置一定數(shù)量的accept線程
 for (int i = 0; i < count; i++) {
  acceptors[i] = createAcceptor();
  String threadName = getName() + "-Acceptor-" + i;
  acceptors[i].setThreadName(threadName);
  Thread t = new Thread(acceptors[i], threadName);
  t.setPriority(getAcceptorThreadPriority());
  t.setDaemon(getDaemon());
  t.start();
 }
}

protected class Acceptor extends AbstractEndpoint.Acceptor {

  @Override
  public void run() {

   int errorDelay = 0;
   // Loop until we receive a shutdown command
   while (running) {
    // Loop if endpoint is paused
    while (paused && running) {
     state = AcceptorState.PAUSED;
     try {
      Thread.sleep(50);
     } catch (InterruptedException e) {
      // Ignore
     }
    }

    if (!running) {
     break;
    }
    state = AcceptorState.RUNNING;

    try {
     //if we have reached max connections, wait
     //達(dá)到連接上限，acceptor線程進(jìn)入等待狀態(tài)，直到其他線程釋放,這是一種簡(jiǎn)單的通過(guò)連接數(shù)量進(jìn)行流量控制的手段
     //通過(guò)實(shí)現(xiàn)AQS組件實(shí)現(xiàn)（LimitLatch），思路是先初始化同步器的最大限制值，然后每接收一個(gè)套接字就將計(jì)數(shù)變量累加1，每關(guān)閉一個(gè)套接字將計(jì)數(shù)變量減1
     countUpOrAwaitConnection();
     Socket socket = null;
     try {
      //accept下個(gè)socket連接，如果一直沒(méi)有連接過(guò)來(lái)這個(gè)方法阻塞
      socket = serverSocketFactory.acceptSocket(serverSocket);
     } catch (IOException ioe) {
      //有異常的話釋放一個(gè)連接數(shù)
      countDownConnection();
      errorDelay = handleExceptionWithDelay(errorDelay);
      throw ioe;
     }
     // Successful accept, reset the error delay
     errorDelay = 0;
     //對(duì)socket進(jìn)行適當(dāng)配置
     if (running && !paused && setSocketOptions(socket)) {
      // 處理這個(gè)socket請(qǐng)求，這邊也是重點(diǎn)。
      if (!processSocket(socket)) {
       countDownConnection();
       // Close socket right away
       closeSocket(socket);
      }
     } else {
      countDownConnection();
      // Close socket right away
      closeSocket(socket);
     }
    } catch (IOException x) {
     if (running) {
      log.error(sm.getString("endpoint.accept.fail"), x);
     }
    } catch (NullPointerException npe) {
     if (running) {
      log.error(sm.getString("endpoint.accept.fail"), npe);
     }
    } catch (Throwable t) {
     ExceptionUtils.handleThrowable(t);
     log.error(sm.getString("endpoint.accept.fail"), t);
    }
   }
   state = AcceptorState.ENDED;
  }
 }

<Connector port="8443" protocol="org.apache.coyote.http11.Http11NioProtocol"
   maxThreads="150" SSLEnabled="true">
 <SSLHostConfig>
  <Certificate certificateKeystoreFile="conf/localhost-rsa.jks"
      type="RSA" />
 </SSLHostConfig>
</Connector>

protected class SocketProcessor implements Runnable {
 //進(jìn)行Debug調(diào)試的時(shí)候可以從這個(gè)類(lèi)的run方法開(kāi)始調(diào)試
	@Override
 public void run() { 
 	//對(duì)套接字進(jìn)行處理并輸出響應(yīng)
  //對(duì)連接限流器LimitLatch減一
  //關(guān)閉套接字
 }
}