WebSocketSession。send什么也不做

Question

我正在编写一个游戏，当一个玩家结束回合时，我想通知对手轮到他玩了。

所以我在“播放器”类中存储了WebSocket会话，所以我只需要得到一个播放器的实例来访问他的WebSocket会话。

问题是，当我使用存储在“player”实例中的websocketsession的“send”方法时，什么都没有发生。

下面是我将WebSocketSession存储在播放器对象中的代码，它实际上可以从前端正确接收消息，并且能够发送回消息，并且可以正常工作：

@Component("ReactiveWebSocketHandler")
public class ReactiveWebSocketHandler implements WebSocketHandler {
    
    @Autowired
    private AuthenticationService authenticationService;
    
    @Override
    public Mono<Void> handle(WebSocketSession webSocketSession) {

        Flux<WebSocketMessage> output = webSocketSession.receive()
                .map(msg -> {
                    String payloadAsText = msg.getPayloadAsText();
                    Account account = authenticationService.getAccountByToken(payloadAsText);
                    Games.getInstance().getGames().get(account.getIdCurrentGame()).getPlayerById(account.getId()).setSession(webSocketSession);
                    return "WebSocketSession id: " + webSocketSession.getId();
                })
                .map(webSocketSession::textMessage);

        return webSocketSession
                .send(output);
    }
}

这是我用来通知对手玩家轮到它玩的代码，“opponentSession.send”方法似乎不会产生任何结果，没有错误消息，而且我在前端似乎什么也没有收到。会话的ID与handle方法中的相同，因此我认为会话对象很好，而且websocket会话在我进行测试时已打开并准备就绪：

@RequestMapping(value = "/game/endTurn", method = RequestMethod.POST)
GameBean endTurn(
        @RequestHeader(value = "token", required = true) String token) {
    ObjectMapper mapper = new ObjectMapper();

    Account account = authenticationService.getAccountByToken(token);
    gameService.endTurn(account);

    Game game = gameService.getGameByAccount(account);
    //GameBean opponentGameBean = game.getOpponentGameState(account.getId());
    //WebSocketMessage webSocketMessage = opponentSession.textMessage(mapper.writeValueAsString(opponentGameBean));
    WebSocketSession opponentSession = game.getPlayerById(game.getOpponentId(account.getId())).getSession();
    WebSocketMessage webSocketMessage = opponentSession.textMessage("test message");

    opponentSession.send(Mono.just(webSocketMessage));

    return gameService.getGameStateByAccount(account);
}
}

您可以在屏幕截图上看到句柄方法正常工作，我能够发送和接收消息。WebSocket输入和输出

有人知道我怎样才能提出反对意见吗。send方法工作正常，以便我可以在前端接收消息？

Answer 1

您正在为您的websocket和websocket会话使用Reactor栈#发送并返回一个Mono

在您的endpoint中，它看起来不像您正在使用webflux，所以您处于同步世界中，所以除了block

opponentSession.send(Mono.just(webSocketMessage)).block();

如果您使用的是网络流量，那么您应该更改您的方法以返回单声道，并执行以下操作：

return opponentSession.send(Mono.just(webSocketMessage)).then(gameService.getGameStateByAccount(account));

如果您不熟悉这一点，您应该查看projectreactor和WebFlux