webflux 实现服务端推送消息

在WebFlux中，我们可以使用WebSocketHandler接口来实现服务端推送消息。WebSocketHandler的handle方法可以处理WebSocket通讯，参数是WebSocketSession对象，可以用来获取客户端信息、接收消息和发送消息。在handle方法中，可以通过receive方法获取到接收到的消息流，然后使用map操作对消息进行处理，并通过send方法发送消息流。

以下是一个示例代码：

import org.springframework.web.reactive.socket.WebSocketHandler;
import org.springframework.web.reactive.socket.WebSocketSession;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class MyWebSocketHandler implements WebSocketHandler {

    @Override
    public Mono<Void> handle(WebSocketSession session) {
        Flux<String> messageFlux = session.receive()
                .map(message -> "ECHO -> " + message.getPayloadAsText());

        return session.send(messageFlux.map(session::textMessage));
    }
}

在上面的示例中，handle方法中使用receive方法获取到接收到的消息流，并使用map操作添加了"ECHO -> "前缀。然后，通过send方法将处理后的消息流发送出去。