public class JettyWebSocketClient extends ObjectSE implements WebSocketClient, Lifecycle
WebSocketClient
で使用する WebSocketClient
実装。 注: Jetty WebSocketClient
はライフサイクル管理を必要とし、開始および停止する必要があります。これは、このクラスが Spring Bean として宣言され、デフォルトのコンストラクターで作成されたときに自動的に管理されます。詳細については、コンストラクターの注意事項を参照してください。
コンストラクターと説明 |
---|
JettyWebSocketClient() Jetty WebSocketClient のインスタンスを作成および管理するデフォルトのコンストラクター。 |
JettyWebSocketClient(org.eclipse.jetty.websocket.client.WebSocketClient jettyClient) Jetty WebSocketClient の既存のインスタンスを受け入れるコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<VoidSE> | execute(URISE url, HttpHeaders headers, WebSocketHandler handler) カスタムヘッダーを持つ WebSocketClient.execute(URI, WebSocketHandler) のバリアント。 |
reactor.core.publisher.Mono<VoidSE> | execute(URISE url, WebSocketHandler handler) 指定された URL に対してハンドシェイクリクエストを実行し、指定されたハンドラーで結果の WebSocket セッションを処理します。 |
org.eclipse.jetty.websocket.client.WebSocketClient | getJettyClient() 基になる Jetty WebSocketClient を返します。 |
boolean | isRunning() このコンポーネントが現在実行されているかどうかを確認します。 |
void | start() このコンポーネントを起動します。 |
void | stop() このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public JettyWebSocketClient()
WebSocketClient
のインスタンスを作成および管理するデフォルトのコンストラクター。インスタンスは、さらに構成するために getJettyClient()
で取得できます。 注: このコンストラクターが使用される場合、このクラスの Lifecycle
メソッドは Jetty WebSocketClient
に委譲されます。
public JettyWebSocketClient(org.eclipse.jetty.websocket.client.WebSocketClient jettyClient)
WebSocketClient
の既存のインスタンスを受け入れるコンストラクター。 注: このコンストラクターの使用は、Jetty WebSocketClient
が外部で管理されているため、このクラスの Lifecycle
メソッドが委譲されないことを意味します。
public org.eclipse.jetty.websocket.client.WebSocketClient getJettyClient()
WebSocketClient
を返します。public void start()
Lifecycle
コンポーネントがすでに実行されている場合は、例外をスローしないでください。
コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。
Lifecycle
の start
SmartLifecycle.isAutoStartup()
public void stop()
Lifecycle
SmartLifecycle
とその stop(Runnable)
バリアントの実装を検討してください。 この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle
Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。
コンポーネントが実行されていない(まだ開始されていない)場合は、例外をスローしないでください。
コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。
Lifecycle
の stop
SmartLifecycle.stop(Runnable)
, DisposableBean.destroy()
public boolean isRunning()
Lifecycle
コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true
を返します。
public reactor.core.publisher.Mono<VoidSE> execute(URISE url, WebSocketHandler handler)
WebSocketClient
WebSocketClient
の execute
url
- ハンドシェイク URLhandler
- WebSocket セッションのハンドラー Mono<Void>
の完了。public reactor.core.publisher.Mono<VoidSE> execute(URISE url, HttpHeaders headers, WebSocketHandler handler)
WebSocketClient
WebSocketClient.execute(URI, WebSocketHandler)
のバリアント。WebSocketClient
の execute
url
- ハンドシェイク URLheaders
- ハンドシェイクリクエストのカスタムヘッダー handler
- WebSocket セッションのハンドラー Mono<Void>
の完了。