Блог

Я работал над spring web-flux reactive WebSocket, поэтому я пытался эмулировать двунаправленный канал текстовой связи, по которому я могу отправлять и получать сообщения, мне удалось успешно запустить сервер WebSocket

 public Mono<Void> handle(WebSocketSession webSocketSession) {
     webSocketSession.receive().map(msg -> msg.getPayloadAsText())
        .doOnNext(ReactiveWebSocketHandler::processMessage).then();

    Flux<WebSocketMessage> hello = Flux.just(webSocketSession.textMessage("hello"));
    return webSocketSession.send(hello);
  }
  

когда я запускаю приложение и попадаю в конечную точку, оно отвечает сообщением, но когда я пытаюсь отправить обработчик сообщений, он не получает, как установить двунаправленное соединение с веб-сокетами, поддерживающее работу