public class UndertowWebSocketSession extends AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
WebSocketChannel
に適応する Spring WebSocketSession
実装。AbstractListenerWebSocketSession.WebSocketSendProcessor
logger
コンストラクターと説明 |
---|
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.MonoProcessor<VoidSE> completionMono) 使用すべきではありません。 |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.Sinks.Empty<VoidSE> completionSink) |
修飾子と型 | メソッドと説明 |
---|---|
protected boolean | canSuspendReceiving() 基礎となる WebSocket API にフロー制御があり、メッセージの受信を一時停止および再開できるかどうか。 |
reactor.core.publisher.Mono<VoidSE> | close(CloseStatus status) 指定されたステータスで WebSocket セッションを閉じます。 |
boolean | isOpen() 基になる接続が開いているかどうか。 |
protected void | resumeReceiving() ダウンストリームサブスクライバによって要求が生成された後、新しいメッセージの受信を再開します。 |
protected boolean | sendMessage(WebSocketMessage message) 指定された WebSocket メッセージを送信します。 |
protected void | suspendReceiving() 受信したメッセージが処理され、ダウンストリームサブスクライバーによってより多くの要求が生成されるまで、受信を中断します。 |
closeStatus, getSendProcessor, onComplete, onError, onNext, onSubscribe, receive, send
binaryMessage, bufferFactory, getAttributes, getDelegate, getHandshakeInfo, getId, getLogPrefix, pingMessage, pongMessage, textMessage, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
close
public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory)
public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, @Nullable reactor.core.publisher.Sinks.Empty<VoidSE> completionSink)
@DeprecatedSE public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, @Nullable reactor.core.publisher.MonoProcessor<VoidSE> completionMono)
protected boolean canSuspendReceiving()
AbstractListenerWebSocketSession
注意 : サブクラスは、可能であれば一時停止モードで開始し、要求が受信されるまで待機することをお勧めします。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
の canSuspendReceiving
protected void suspendReceiving()
AbstractListenerWebSocketSession
注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供しない場合、このメソッドは何もしないで、AbstractListenerWebSocketSession.canSuspendReceiving()
は false
を返す必要があります。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
の suspendReceiving
protected void resumeReceiving()
AbstractListenerWebSocketSession
注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供しない場合、このメソッドは何もしないで、AbstractListenerWebSocketSession.canSuspendReceiving()
は false
を返す必要があります。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
の resumeReceiving
protected boolean sendMessage(WebSocketMessage message) throws IOExceptionSE
AbstractListenerWebSocketSession
注意 : プールされたバッファーが基になるコンテナーに適用される場合、サブクラスは、完全に書き込まれた後、ペイロードデータバッファーを解放します。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
の sendMessage
IOExceptionSE
public boolean isOpen()
WebSocketSession
public reactor.core.publisher.Mono<VoidSE> close(CloseStatus status)
WebSocketSession
status
- 終了ステータス