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

クラス ReactorNetty2WebSocketSession

java.lang.ObjectSE
org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession<T>
org.springframework.web.reactive.socket.adapter.Netty5WebSocketSessionSupport<ReactorNetty2WebSocketSession.WebSocketConnection>
org.springframework.web.reactive.socket.adapter.ReactorNetty2WebSocketSession
実装されたすべてのインターフェース:
WebSocketSession
public class ReactorNetty2WebSocketSession extends Netty5WebSocketSessionSupport<ReactorNetty2WebSocketSession.WebSocketConnection>
Reactor Netty の (Netty 5) NettyInbound および NettyOutbound で使用する WebSocketSession 実装。このクラスは ReactorNettyWebSocketSession に基づいています。
導入:
6.0
作成者:
Violeta Georgieva

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

    • ReactorNetty2WebSocketSession

      public ReactorNetty2WebSocketSession(reactor.netty5.http.websocket.WebsocketInbound inbound, reactor.netty5.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, Netty5DataBufferFactory bufferFactory)
      Netty5WebSocketSessionSupport.DEFAULT_FRAME_MAX_SIZE 値を使用するセッションのコンストラクター。

    • ReactorNetty2WebSocketSession

      public ReactorNetty2WebSocketSession(reactor.netty5.http.websocket.WebsocketInbound inbound, reactor.netty5.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, Netty5DataBufferFactory bufferFactory, int maxFramePayloadLength)
      追加の maxFramePayloadLength 引数を持つコンストラクター。
      導入:
      5.1

  • メソッドの詳細

    • getChannelId

      public io.netty5.channel.ChannelId getChannelId()
      基になる Netty チャネルの ID を返します。
      導入:
      5.3.4

    • receive

      public reactor.core.publisher.Flux<WebSocketMessage> receive()
      インターフェースからコピーされた説明: WebSocketSession
      受信メッセージのストリームへのアクセスを提供します。

      このストリームは、接続が閉じられたときに完了またはエラー信号を受け取ります。典型的な WebSocketHandler 実装では、このストリームは全体的な処理フローに組み込まれるため、接続が閉じられると処理が終了します。

      セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。

      次で指定:
      インターフェース WebSocketSession の receive 
      次で指定:
      クラス AbstractWebSocketSession<ReactorNetty2WebSocketSession.WebSocketConnection> の receive 

    • send

      public reactor.core.publisher.Mono<VoidSE> send(Publisher<WebSocketMessage> messages)
      インターフェースからコピーされた説明: WebSocketSession
      発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了する Mono<Void> を返します。

      セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。

      次で指定:
      インターフェース WebSocketSession の send 
      次で指定:
      クラス AbstractWebSocketSession<ReactorNetty2WebSocketSession.WebSocketConnection> の send 

    • isOpen

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

    • close

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

    • closeStatus

      public reactor.core.publisher.Mono<CloseStatus> closeStatus()
      インターフェースからコピーされた説明: WebSocketSession
      セッションがローカルまたはリモートで閉じられる CloseStatus へのアクセスを提供します。セッションがステータスなしで終了した場合は、空になります。