类的使用
org.springframework.web.reactive.socket.WebSocketMessage
使用WebSocketMessage的程序包 程序包 说明 org.springframework.web.reactive.socket Abstractions and support classes for reactive WebSocket interactions.org.springframework.web.reactive.socket.adapter Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes.org.springframework.web.reactive.socket中WebSocketMessage的使用
返回WebSocketMessage的org.springframework.web.reactive.socket中的方法 修饰符和类型 方法 说明 WebSocketMessageWebSocketSession. binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)Factory method to create a binary WebSocketMessage using theWebSocketSession.bufferFactory()for the session.WebSocketMessageWebSocketSession. pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)Factory method to create a ping WebSocketMessage using theWebSocketSession.bufferFactory()for the session.WebSocketMessageWebSocketSession. pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)Factory method to create a pong WebSocketMessage using theWebSocketSession.bufferFactory()for the session.WebSocketMessageWebSocketMessage. retain()Retain the data buffer for the message payload, which is useful on runtimes (e.g.WebSocketMessageWebSocketSession. textMessage(String payload)Factory method to create a textWebSocketMessageusing theWebSocketSession.bufferFactory()for the session.返回变量类型为WebSocketMessage的类型的org.springframework.web.reactive.socket中的方法 修饰符和类型 方法 说明 reactor.core.publisher.Flux<WebSocketMessage>WebSocketSession. receive()Provides access to the stream of inbound messages.类型变量类型为WebSocketMessage的org.springframework.web.reactive.socket中的方法参数 修饰符和类型 方法 说明 reactor.core.publisher.Mono<Void>WebSocketSession. send(org.reactivestreams.Publisher<WebSocketMessage> messages)Give a source of outgoing messages, write the messages and return aMono<Void>that completes when the source completes and writing is done.org.springframework.web.reactive.socket.adapter中WebSocketMessage的使用
返回WebSocketMessage的org.springframework.web.reactive.socket.adapter中的方法 修饰符和类型 方法 说明 WebSocketMessageAbstractWebSocketSession. binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)WebSocketMessageAbstractWebSocketSession. pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)WebSocketMessageAbstractWebSocketSession. pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)WebSocketMessageAbstractWebSocketSession. textMessage(String payload)protected WebSocketMessageNettyWebSocketSessionSupport. toMessage(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)返回变量类型为WebSocketMessage的类型的org.springframework.web.reactive.socket.adapter中的方法 修饰符和类型 方法 说明 reactor.core.publisher.Flux<WebSocketMessage>AbstractListenerWebSocketSession. receive()abstract reactor.core.publisher.Flux<WebSocketMessage>AbstractWebSocketSession. receive()reactor.core.publisher.Flux<WebSocketMessage>ReactorNettyWebSocketSession. receive()参数类型为WebSocketMessage的org.springframework.web.reactive.socket.adapter中的方法 修饰符和类型 方法 说明 protected voidAbstractListenerWebSocketSession.WebSocketSendProcessor. discardData(WebSocketMessage message)protected booleanAbstractListenerWebSocketSession.WebSocketSendProcessor. isDataEmpty(WebSocketMessage message)protected abstract booleanAbstractListenerWebSocketSession. sendMessage(WebSocketMessage message)Send the given WebSocket message.protected booleanJettyWebSocketSession. sendMessage(WebSocketMessage message)protected booleanStandardWebSocketSession. sendMessage(WebSocketMessage message)protected booleanUndertowWebSocketSession. sendMessage(WebSocketMessage message)protected io.netty.handler.codec.http.websocketx.WebSocketFrameNettyWebSocketSessionSupport. toFrame(WebSocketMessage message)protected booleanAbstractListenerWebSocketSession.WebSocketSendProcessor. write(WebSocketMessage message)类型变量类型为WebSocketMessage的org.springframework.web.reactive.socket.adapter中的方法参数 修饰符和类型 方法 说明 reactor.core.publisher.Mono<Void>AbstractListenerWebSocketSession. send(org.reactivestreams.Publisher<WebSocketMessage> messages)abstract reactor.core.publisher.Mono<Void>AbstractWebSocketSession. send(org.reactivestreams.Publisher<WebSocketMessage> messages)reactor.core.publisher.Mono<Void>ReactorNettyWebSocketSession. send(org.reactivestreams.Publisher<WebSocketMessage> messages)