17.3. コネクター設定

手順17.2 HTTP コネクターのスレッドプールの設定

1. スレッドファクトリーの定義

   設定ファイルを開きます（スタンドアロンサーバーに対して変更する場合はstandalone.xml、ドメインベースの設定に対して変更する場合は domain.xml ）。このファイルは EAP_HOME/standalone/configuration または EAP_HOME/domain/configuration フォルダーにあります。
   次のサブシステムエントリーを追加します。値はサーバーの要件に合わせて変更します。

   <subsystem xmlns="urn:jboss:domain:threads:1.1">
       <thread-factory name="http-connector-factory" thread-name-pattern="HTTP-%t" priority="9" group-name="uq-thread-pool"/>
   </subsystem>
   

   管理 CLI を使用してこのタスクを実行する場合は、CLI コマンドプロンプトで次のコマンドを実行します。

   [standalone@localhost:9999 /] ./subsystem=threads/thread-factory=http-connector-factory:add(thread-name-pattern="HTTP-%t", priority="9", group-name="uq-thread-pool")

2. エクゼキューターの作成

   6 つの組み込みエクゼキュータークラスの 1 つを使用して、このファクトリーのエクゼキューターとして動作します。6 つのエクゼキューターは以下のとおりです。

   • unbounded-queue-thread-pool: このタイプのスレッドプールは常にタスクを許可します。実行されているスレッドの最大数を下回ると、新しいスレッドが起動し、送信されたタスクが実行されます。それ以外の場合、タスクはスレッドが利用可能になるとバインドされていない FIFO キューに置かれます。

     注記

     Executors.singleThreadExecutor() が提供する単一スレッドエグゼキュータータイプは、スレッド制限が 1 つに制限されているバインドされていないキューエグゼキューターです。このタイプのエクゼキューターは unbounded-queue-thread-pool-executor 要素を使用してデプロイされます。
   • bounded-queue-thread-pool: このタイプのエクゼキューターは固定長のキューと、core サイズと maximum サイズという 2 つのプールサイズを維持します。タスクが受け入れられると、実行中のプールスレッドの数が core サイズ未満の場合は、タスクの実行に新しいスレッドが開始されます。スペースがキューに残ると、タスクはキューに配置されます。実行中のプールスレッドの数が maximum サイズ未満の場合は、新しいスレッドが開始されてタスクを実行します。エグゼキューターでブロックが有効になっていると、呼び出しスレッドは、キューで領域が利用可能になるまでブロックします。ハンドオフエクゼキューターが設定されている場合、タスクは Handoff エグゼキューターに委任されます。そうでない場合は、タスクは拒否されます。
   • blocking-bounded-queue-thread-pool: スレッドの送信タスクがブロックされるバインドされたキューを持つスレッドプールエクゼキューター。このようなスレッドプールにはコアおよび最大サイズがあり、指定されたキューの長さがあります。タスクが送信されると、実行中のスレッド数がコアサイズ未満の場合、新しいスレッドが作成されます。そうでないと、キューに余裕がある場合はタスクはキューに置かれます。実行中スレッドの数が最大サイズ未満の場合は、新しいスレッドが作成されます。そうでないと、呼び出し元は、その部屋がキューで利用可能になるまでブロックされます。
   • queueless-thread-pool: 場合によっては、別のスレッドでタスクを実行するには単純なスレッドプールが必要であり、キューを干渉しないタスクを完了するため、スレッドを再利用する必要があります。このタイプのプールは、タスクを受け入れ、他の実行中のタスクが完了するまで実行を遅らせるのではなく、タスクは常に承認直後に開始するなど、長時間実行されるタスクを処理するのに適しています。このタイプのエクゼキューターは queueless-thread-pool-executor 要素を使用して宣言されます。
   • blocking-queueless-thread-pool: スレッドの送信タスクがブロックされるキューのないスレッドプールエクゼキューター。タスクが送信されると、実行中のスレッド数が最大サイズ未満の場合は、新しいスレッドが作成されます。それ以外の場合は、呼び出し元は、別のスレッドがタスクを完了し、新しいタスクを許可するまでブロックします。
   • scheduled-thread-pool: これは、java.util.concurrent.ScheduledThreadPoolExecutor クラスに基づいて、特定の時間および時間間隔でタスクを実行する特別なタイプのエクゼキューターです。このタイプのエクゼキューターは scheduled-thread-pool-executor 要素で設定されます。
   この例では、unbounded-queue-thread-pool を使用してエクゼキューターとして機能します。サーバーのニーズに合わせて max-threads および keepalive-time パラメーターの値を変更します。

   <unbounded-queue-thread-pool name="uq-thread-pool">
     <thread-factory name="http-connector-factory" />
     <max-threads count="10" />
     <keepalive-time time="30" unit="seconds" />
   </unbounded-queue-thread-pool>

   管理 CLI を使用する場合は、以下を行います。

   [standalone@localhost:9999 /] ./subsystem=threads/unbounded-queue-thread-pool=uq-thread-pool:add(thread-factory="http-connector-factory", keepalive-time={time=30, unit="seconds"}, max-threads=30)

3. HTTP Web コネクターがこのスレッドプールを使用するようにする

   同じ設定ファイルで、Web サブシステム下にある HTTP コネクター要素を見つけ、前の手順で定義したスレッドプールを使用するよう編集します

   <connector name="http" protocol="HTTP/1.1" scheme="http" socket-binding="http" executor="uq-thread-pool" />

   管理 CLI を使用する場合は、以下を実行します。

   [standalone@localhost:9999 /] ./subsystem=web/connector=http:write-attribute(name=executor, value="uq-thread-pool")

4. サーバーの再起動

   サーバー（スタンドアロンまたはドメイン）を再起動して、変更を有効にします。以下の管理 CLI コマンドを使用して、上記の手順からの変更が実施されたかどうかを確認します。

   [standalone@localhost:9999 /] ./subsystem=threads:read-resource(recursive=true)
   {                  
       "outcome" => "success",
       "result" => {
           "blocking-bounded-queue-thread-pool" => undefined,
           "blocking-queueless-thread-pool" => undefined,
           "bounded-queue-thread-pool" => undefined,
           "queueless-thread-pool" => undefined,
           "scheduled-thread-pool" => undefined,
           "thread-factory" => {"http-connector-factory" => {
               "group-name" => "uq-thread-pool",
               "name" => "http-connector-factory",
               "priority" => 9,
               "thread-name-pattern" => "HTTP-%t"
           }},
           "unbounded-queue-thread-pool" => {"uq-thread-pool" => {
               "keepalive-time" => {
                   "time" => 30L,
                   "unit" => "SECONDS"
               },
               "max-threads" => 30,
               "name" => "uq-thread-pool",
               "thread-factory" => "http-connector-factory"
           }}
       }
   }
   [standalone@localhost:9999 /] ./subsystem=web/connector=http:read-resource(recursive=true)
   {
       "outcome" => "success",
       "result" => {
           "configuration" => undefined,
           "enable-lookups" => false,
           "enabled" => true,
           "executor" => "uq-thread-pool",
           "max-connections" => undefined,
           "max-post-size" => 2097152,
           "max-save-post-size" => 4096,
           "name" => "http",
           "protocol" => "HTTP/1.1",
           "proxy-name" => undefined,
           "proxy-port" => undefined,
           "redirect-port" => 443,
           "scheme" => "http",
           "secure" => false,
           "socket-binding" => "http",
           "ssl" => undefined,
           "virtual-server" => undefined
       }
   }