每日一博 | WebFlux 定点推送,全推送灵活 Websocket 运用
前言 WebFlux 本身提供了对 WebSocket 协议的支持,处理 WebSocket 请求需要对应的 handler 实现 WebSocketHandler 接口,每一个 WebSocket 都有一个关联的 WebSocketSession,包含了建立请求时的握手信息HandshakeInfo,以及其它相关的信息。可以通过 session 的receive()方法来接收客户端的数据,通过 session 的send()方法向客户端发送数据。 示例 下面是一个简单的 WebSocketHandler 示例: @Component public class EchoHandler implements WebSocketHandler { public Mono<Void> handle(WebSocketSession session) { return session.send( session.receive().map( msg -> session.textMessage("ECHO -> " + msg.getPayloadAsText...




