クラス JettyXhrTransport
java.lang.ObjectSE
org.springframework.web.socket.sockjs.client.AbstractXhrTransport
org.springframework.web.socket.sockjs.client.JettyXhrTransport
- 実装されたすべてのインターフェース:
Lifecycle
、InfoReceiver
、Transport
、XhrTransport
Jetty の
HttpClient
に基づく XHR トランスポート。 テスト目的(負荷テストなど)で使用する場合、HttpClient
プロパティを設定して、通常よりも多くの接続とスレッドを許可する必要があります。例:
HttpClient httpClient = new HttpClient(); httpClient.setMaxConnectionsPerDestination(1000); httpClient.setExecutor(new QueuedThreadPool(500));
- 導入:
- 4.1
- 作成者:
- Rossen Stoyanchev
フィールドサマリー
クラス org.springframework.web.socket.sockjs.client.AbstractXhrTransport から継承されたフィールド
logger, PRELUDE
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected void
connectInternal
(TransportRequest transportRequest, WebSocketHandler handler, URISE url, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, CompletableFutureSE<WebSocketSession> connectFuture) protected ResponseEntity<StringSE>
executeInfoRequestInternal
(URISE infoUrl, HttpHeaders headers) protected ResponseEntity<StringSE>
executeRequest
(URISE url, org.eclipse.jetty.http.HttpMethod method, HttpHeaders headers, StringSE body) executeSendRequestInternal
(URISE url, HttpHeaders headers, TextMessage message) org.eclipse.jetty.client.HttpClient
boolean
このコンポーネントが現在実行されているかどうかを確認します。void
start()
このコンポーネントを起動します。void
stop()
このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。クラス org.springframework.web.socket.sockjs.client.AbstractXhrTransport から継承されたメソッド
connectAsync, connectInternal, executeInfoRequest, executeSendRequest, getTransportTypes, isXhrStreamingDisabled, setXhrStreamingDisabled
コンストラクターの詳細
JettyXhrTransport
public JettyXhrTransport(org.eclipse.jetty.client.HttpClient httpClient)
メソッドの詳細
getHttpClient
public org.eclipse.jetty.client.HttpClient getHttpClient()start
public void start()インターフェースからコピーされた説明:Lifecycle
このコンポーネントを起動します。コンポーネントがすでに実行されている場合は、例外をスローしないでください。
コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。
stop
public void stop()インターフェースからコピーされた説明:Lifecycle
このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle
とそのstop(Runnable)
バリアントの実装を検討してください。この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、
Lifecycle
Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。コンポーネントが実行されていない(まだ開始されていない)場合は、例外をスローしないでください。
コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。
isRunning
public boolean isRunning()インターフェースからコピーされた説明:Lifecycle
このコンポーネントが現在実行されているかどうかを確認します。コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、
true
を返します。connectInternal
protected void connectInternal(TransportRequest transportRequest, WebSocketHandler handler, URISE url, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, CompletableFutureSE<WebSocketSession> connectFuture) - 次で指定:
- クラス
AbstractXhrTransport
のconnectInternal
executeInfoRequestInternal
- 次で指定:
- クラス
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)