パッケージ org.springframework.web.reactive.socket.adapter

クラス UndertowWebSocketSession

java.lang.ObjectSE
org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession<T>
org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
org.springframework.web.reactive.socket.adapter.UndertowWebSocketSession
実装されたすべてのインターフェース:
Subscriber<VoidSE>, WebSocketSession
public class UndertowWebSocketSession extends AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
Undertow WebSocketChannel に適応する Spring WebSocketSession 実装。
導入:
5.0
作成者:
Violeta Georgieva, Rossen Stoyanchev

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

    • UndertowWebSocketSession

      public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory)

    • UndertowWebSocketSession

      public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, @Nullable reactor.core.publisher.Sinks.Empty<VoidSE> completionSink)

  • メソッドの詳細

    • canSuspendReceiving

      protected boolean canSuspendReceiving()
      クラスからコピーされた説明: AbstractListenerWebSocketSession
      基礎となる WebSocket API にフロー制御があり、メッセージの受信を一時停止および再開できるかどうか。

      注意 : サブクラスは、可能であれば一時停止モードで開始し、要求が受信されるまで待機することをお勧めします。

      次で指定:
      クラス AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の canSuspendReceiving 

    • suspendReceiving

      protected void suspendReceiving()
      クラスからコピーされた説明: AbstractListenerWebSocketSession
      受信したメッセージが処理され、ダウンストリームサブスクライバーによってより多くの要求が生成されるまで、受信を中断します。

      注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供しない場合、このメソッドは何もしないで、AbstractListenerWebSocketSession.canSuspendReceiving() は false を返す必要があります。

      次で指定:
      クラス AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の suspendReceiving 

    • resumeReceiving

      protected void resumeReceiving()
      クラスからコピーされた説明: AbstractListenerWebSocketSession
      ダウンストリームサブスクライバによって要求が生成された後、新しいメッセージの受信を再開します。

      注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供しない場合、このメソッドは何もしないで、AbstractListenerWebSocketSession.canSuspendReceiving() は false を返す必要があります。

      次で指定:
      クラス AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の resumeReceiving 

    • sendMessage

      protected boolean sendMessage(WebSocketMessage message) throws IOExceptionSE
      クラスからコピーされた説明: AbstractListenerWebSocketSession
      指定された WebSocket メッセージを送信します。

      注意 : プールされたバッファーが基になるコンテナーに適用される場合、サブクラスは、完全に書き込まれた後、ペイロードデータバッファーを解放します。

      次で指定:
      クラス AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の sendMessage 
      例外:
      IOExceptionSE

    • isOpen

      public boolean isOpen()
      インターフェースからコピーされた説明: WebSocketSession
      基になる接続が開いているかどうか。

    • close

      public reactor.core.publisher.Mono<VoidSE> close(CloseStatus status)
      インターフェースからコピーされた説明: WebSocketSession
      指定されたステータスで WebSocket セッションを閉じます。
      パラメーター:
      status - 終了ステータス