クラス JettyXhrTransport

java.lang.ObjectSE
org.springframework.web.socket.sockjs.client.AbstractXhrTransport
org.springframework.web.socket.sockjs.client.JettyXhrTransport
実装済みのインターフェース一覧:
Lifecycle, InfoReceiver, Transport, XhrTransport
public class JettyXhrTransport extends AbstractXhrTransport implements Lifecycle
Jetty の HttpClient に基づく XHR トランスポート。

テスト目的 (負荷テストなど) で使用する場合は、HttpClient プロパティを設定して、通常よりも多くの接続とスレッドを許可する必要があります。例:

HttpClient httpClient = new HttpClient();
httpClient.setMaxConnectionsPerDestination(1000);
httpClient.setExecutor(new QueuedThreadPool(500));
導入:
4.1
作成者:
Rossen Stoyanchev

  • コンストラクターの詳細

    • JettyXhrTransport

      public JettyXhrTransport(org.eclipse.jetty.client.HttpClient httpClient)

  • メソッドの詳細

    • getHttpClient

      public org.eclipse.jetty.client.HttpClient getHttpClient()

    • start

      public void start()
      インターフェースからコピーされた説明: Lifecycle
      このコンポーネントを起動します。

      コンポーネントがすでに実行されている場合は、例外をスローしないでください。

      コンテナーの場合、これにより、自動起動しないコンポーネントも含め、適用されるすべてのコンポーネントにハードスタートシグナルが伝播されます。

      次で指定:
      インターフェース Lifecycle の start 
      関連事項:

    • stop

      public void stop()
      インターフェースからコピーされた説明: Lifecycle
      このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

      この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。

      コンポーネントが実行されていない（まだ開始されていない）場合は、例外をスローしないでください。

      コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

      次で指定:
      インターフェース Lifecycle の stop 
      関連事項:

    • isRunning

      public boolean isRunning()
      インターフェースからコピーされた説明: Lifecycle
      このコンポーネントが現在実行されているかどうかを確認します。

      コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

      次で指定:
      インターフェース Lifecycle の isRunning 
      戻り値:
      コンポーネントが現在実行中かどうか

    • connectInternal

      protected void connectInternal(TransportRequest transportRequest, WebSocketHandler handler, URISE url, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, CompletableFutureSE<WebSocketSession> connectFuture)
      次で指定:
      クラス AbstractXhrTransport の connectInternal 

    • executeInfoRequestInternal

      protected ResponseEntity<StringSE> executeInfoRequestInternal(URISE infoUrl, HttpHeaders headers)
      次で指定:
      クラス AbstractXhrTransport の executeInfoRequestInternal 

    • executeSendRequestInternal

      public ResponseEntity<StringSE> executeSendRequestInternal(URISE url, HttpHeaders headers, TextMessage message)
      次で指定:
      クラス AbstractXhrTransport の executeSendRequestInternal 

    • executeRequest

      protected ResponseEntity<StringSE> executeRequest(URISE url, org.eclipse.jetty.http.HttpMethod method, HttpHeaders headers, @Nullable StringSE body)