クラスの使用
org.springframework.web.reactive.socket.WebSocketMessage
パッケージ
説明
リアクティブ WebSocket 相互作用の抽象化とサポートクラス。
Spring の Reactive WebSocket API を WebSocket ランタイムとの間で適合させるクラス。
org.springframework.web.reactive.socket 内の WebSocketMessage 使用
修飾子と型メソッド説明WebSocketSession.binaryMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。WebSocketSession.pingMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用して ping WebSocketMessage を作成するファクトリメソッド。WebSocketSession.pongMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションにWebSocketSession.bufferFactory()
を使用してポン WebSocketMessage を作成するファクトリメソッド。WebSocketMessage.retain()
メッセージペイロードのデータバッファーを保持します。これは、ランタイムで役立ちます(例:WebSocketSession.textMessage
(StringSE payload) セッションにWebSocketSession.bufferFactory()
を使用してテキストWebSocketMessage
を作成するファクトリメソッド。修飾子と型メソッド説明reactor.core.publisher.Flux<WebSocketMessage>
WebSocketSession.receive()
受信メッセージのストリームへのアクセスを提供します。修飾子と型メソッド説明reactor.core.publisher.Mono<VoidSE>
WebSocketSession.send
(Publisher<WebSocketMessage> messages) 発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了するMono<Void>
を返します。org.springframework.web.reactive.socket.adapter 内の WebSocketMessage 使用
修飾子と型メソッド説明AbstractWebSocketSession.binaryMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pingMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pongMessage
(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.textMessage
(StringSE payload) protected WebSocketMessage
Netty5WebSocketSessionSupport.toMessage
(io.netty5.handler.codec.http.websocketx.WebSocketFrame frame) protected WebSocketMessage
NettyWebSocketSessionSupport.toMessage
(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) 修飾子と型メソッド説明reactor.core.publisher.Flux<WebSocketMessage>
AbstractListenerWebSocketSession.receive()
abstract reactor.core.publisher.Flux<WebSocketMessage>
AbstractWebSocketSession.receive()
reactor.core.publisher.Flux<WebSocketMessage>
ReactorNetty2WebSocketSession.receive()
reactor.core.publisher.Flux<WebSocketMessage>
ReactorNettyWebSocketSession.receive()
修飾子と型メソッド説明protected void
AbstractListenerWebSocketSession.WebSocketSendProcessor.discardData
(WebSocketMessage message) protected boolean
AbstractListenerWebSocketSession.WebSocketSendProcessor.isDataEmpty
(WebSocketMessage message) protected abstract boolean
AbstractListenerWebSocketSession.sendMessage
(WebSocketMessage message) 指定された WebSocket メッセージを送信します。protected boolean
JettyWebSocketSession.sendMessage
(WebSocketMessage message) protected boolean
StandardWebSocketSession.sendMessage
(WebSocketMessage message) protected boolean
UndertowWebSocketSession.sendMessage
(WebSocketMessage message) protected io.netty5.handler.codec.http.websocketx.WebSocketFrame
Netty5WebSocketSessionSupport.toFrame
(WebSocketMessage message) protected io.netty.handler.codec.http.websocketx.WebSocketFrame
NettyWebSocketSessionSupport.toFrame
(WebSocketMessage message) protected boolean
AbstractListenerWebSocketSession.WebSocketSendProcessor.write
(WebSocketMessage message) 修飾子と型メソッド説明reactor.core.publisher.Mono<VoidSE>
AbstractListenerWebSocketSession.send
(Publisher<WebSocketMessage> messages) abstract reactor.core.publisher.Mono<VoidSE>
AbstractWebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<VoidSE>
ReactorNetty2WebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<VoidSE>
ReactorNettyWebSocketSession.send
(Publisher<WebSocketMessage> messages)