コネクタコンポーネントから Tomcat のスレッドモデルを見る - BIO モード (推奨)

@構成
パブリッククラスTomcatConfig {

 @ビーン
 パブリック WebServerFactoryCustomizer tomcatCustomizer() {
  新しいTomcatCustomerConfig()を返します。
 }

 パブリッククラスTomcatCustomerConfigはWebServerFactoryCustomizer<TomcatServletWebServerFactory>を実装します。
  @オーバーライド
  パブリック void カスタマイズ (TomcatServletWebServerFactory ファクトリー) {
   if (ファクトリー != null) {
    factory.setProtocol("org.apache.coyote.http11.Http11Protocol");
   }
  }
 }
}

@オーバーライド
パブリック void bind() は例外をスローします {

 // アクセプタのスレッド数のデフォルトを初期化する
 アクセプタスレッドカウント == 0 の場合
  アクセプタスレッド数 = 1;
 }
 // maxConnectionsを初期化する
 getMaxConnections() == 0 の場合 {
  // ユーザーが値を設定していない場合は、デフォルトを使用します
  Executor で接続できる最大スレッド数を設定します。
 }

 (serverSocketFactory == null)の場合{
  SSLが有効になっている場合
   サーバーソケットファクトリー =
    ハンドラ.getSslImplementation().getServerSocketFactory(これ);
  } それ以外 {
   serverSocketFactory = 新しい DefaultServerSocketFactory(this);
  }
 }
 // ServerSocket のポートバインディングは次のとおりです。if (serverSocket == null) {
  試す {
   getAddress() が null の場合
    //特定のアドレスが指定されていない場合、Tomcatはすべてのアドレスからのリクエストをリッスンします。serverSocket = serverSocketFactory.createSocket(getPort(),
                バックログを取得します。
   } それ以外 {
    //特定のアドレスを指定します。Tomcat はこのアドレスからのリクエストのみをリッスンします。serverSocket = serverSocketFactory.createSocket(getPort(),
                getBacklog()、getAddress());
   }
  } catch (BindException orig) {
   文字列メッセージ;
   getAddress() が null の場合
    msg = orig.getMessage() + " <null>:" + getPort();
   それ以外
    メッセージ = orig.getMessage() + " " +
    getAddress().toString() + ":" + getPort();
   BindException は、新しい BindException(msg) になります。
   be.initCause(orig);
   投げる;
  }
 }

}

パブリック void startInternal() 例外をスローします {

 if (!実行中) {
  実行中 = true;
  一時停止 = false;

  //スレッドプールを作成する if (getExecutor() == null) {
   エグゼキュータを作成します。
  }
  //ConnectionLatch を作成する
  接続ラッチを初期化します。
  // リクエスト処理の初期スレッドである Accept スレッドを作成します。startAcceptorThreads();
  // 非同期タイムアウトスレッドを開始する
  スレッドタイムアウトThread = new Thread(new AsyncTimeout(),
           getName() + "-AsyncTimeout");
  タイムアウトスレッド。優先度を設定します。(スレッド優先度);
  タイムアウトスレッド.setDaemon(true);
  タイムアウトスレッドを開始します。
 }
}

保護された最終void startAcceptorThreads() {
 スレッドカウントを取得します。
 acceptors = 新しいAcceptor[count];
 //設定に応じて、受け入れスレッドの数を設定します for (int i = 0; i < count; i++) {
  アクセプタ[i] = createAcceptor();
  文字列 threadName = getName() + "-Acceptor-" + i;
  アクセプタ[i].setThreadName(スレッド名);
  スレッド t = new Thread(acceptors[i], threadName);
  t.setPriority(getAcceptorThreadPriority());
  t.setDaemon(getDaemon());
  t.start();
 }
}

保護されたクラス Acceptor は AbstractEndpoint.Acceptor を拡張します {

  @オーバーライド
  パブリックボイド実行() {

   エラー遅延 = 0;
   // シャットダウンコマンドを受信するまでループします
   （実行中）{
    // エンドポイントが一時停止している場合はループする
    while (一時停止中 && 実行中) {
     状態 = AcceptorState.PAUSED;
     試す {
      スレッド.sleep(50);
     } キャッチ (InterruptedException e) {
      // 無視する
     }
    }

    if (!実行中) {
     壊す;
    }
    状態 = AcceptorState.RUNNING;

    試す {
     //最大接続数に達した場合は待機します
     //接続制限に達すると、アクセプタ スレッドは他のスレッドが解放されるまで待機状態になります。これは、接続数によるフロー制御の単純な手段です。 //これは、AQS コンポーネント (LimitLatch) を実装することで実現されます。考え方としては、まず同期装置の最大制限を初期化し、次にソケットを受信するたびに count 変数を 1 ずつ増やし、ソケットを閉じるたびに count 変数を 1 ずつ減らします。
     カウントアップまたは接続待ち();
     ソケット socket = null;
     試す {
      //次のソケット接続を受け入れます。接続が確立されない場合、このメソッドはブロックされます。socket = serverSocketFactory.acceptSocket(serverSocket);
     } キャッチ (IOException ioe) {
      //例外が発生した場合は接続を解放します countDownConnection();
      エラー遅延 = handleExceptionWithDelay(エラー遅延);
      ioeを投げる;
     }
     // 正常に承認されました。エラー遅延をリセットします
     エラー遅延 = 0;
     //ソケットを適切に設定します if (running && !paused && setSocketOptions(socket)) {
      // このソケット要求を処理します。これが重要なポイントでもあります。
      if (!processSocket(socket)) {
       カウントダウン接続();
       // すぐにソケットを閉じる
       ソケットを閉じます。
      }
     } それ以外 {
      カウントダウン接続();
      // すぐにソケットを閉じる
      ソケットを閉じます。
     }
    } キャッチ (IOException x) {
     if (実行中) {
      ログエラー(sm.getString("endpoint.accept.fail"), x);
     }
    } キャッチ (NullPointerException npe) {
     if (実行中) {
      ログエラー(sm.getString("endpoint.accept.fail"), npe);
     }
    } キャッチ (Throwable t) {
     例外をスローする
     ログエラー(sm.getString("endpoint.accept.fail"), t);
    }
   }
   状態 = AcceptorState.ENDED;
  }
 }

<コネクタ ポート="8443" プロトコル="org.apache.coyote.http11.Http11NioProtocol"
   最大スレッド数="150" SSL有効="true">
 <SSLホスト構成>
  <証明書 certificateKeystoreFile="conf/localhost-rsa.jks"
      タイプ = "RSA" />
 </SSLホスト構成>
</コネクタ>

保護されたクラス SocketProcessor は Runnable を実装します {
 //デバッグ時には、このクラスのrunメソッドからデバッグを開始できます@Override
 パブリックボイド実行() { 
 	//ソケットを処理して応答を出力する //接続リミッター LimitLatch を 1 減らす //ソケットを閉じる}
}