如何在 spring webflux Reactive websockets 中发送列表答案

【问题标题】：How to Send a list in spring webflux Reactive websockets如何在 spring webflux Reactive websockets 中发送列表
【发布时间】：2020-04-08 03:48:57
【问题描述】：

我正在使用 spring websockets，我想从存储库中返回一个项目列表

 List<Items> nameList = itemsService.getItems ();

如何在 websocket 会话中发送此列表

 public Mono<Void> handle(WebSocketSession webSocketSession) {
        System.out.println (webSocketSession.getId () + "sessionId" );
        List<Items> nameList = itemsService.getItems ();
        Flux<Items> output = Flux.fromIterable (nameList);
        Mono<Void> send = webSocketSession.
                send (output.map ((Items s) -> webSocketSession.binaryMessage (s)));
        return send;

这是我的处理方法，如何将项目列表发送到 websocket

【问题讨论】：

标签： java spring-boot websocket spring-webflux

【解决方案1】：

Flux<Items> flux = Flux.fromIterable (nameList);
        Flux<WebSocketMessage> webSocketMessageFlux = flux
                .map(itm ->convertIemsToString(itm)).map (item -> webSocketSession.textMessage (item));


        return webSocketSession.send (webSocketMessageFlux);

所以首先我将列表转换为通量然后将其转换为 websocketMessage 然后将 websocket 消息发送到将被推送到客户端的 seesion

【讨论】：