Lors du développement d'un serveur WebSocket à l'aide de NetTy4, comment vous assurez-vous que le navigateur reconnaît correctement la réponse 401?

NetTy4 WebSocket Server: Gérez correctement les réponses du navigateur 401

Lors du développement de serveurs WebSocket à l'aide de NetTy4, il est souvent nécessaire de vérifier le jeton client. Si la vérification échoue, le serveur doit renvoyer le code d'état 401 et fermer la connexion. Cependant, les navigateurs ne parviennent parfois pas à recevoir cette réponse correctement. Cet article expliquera en détail comment résoudre ce problème.

Question: Utilisez var socket = new WebSocket("ws://127.0.0.1:18080/ws?token=xxxx"); Pour se connecter au serveur et le serveur vérifie le jeton. En cas de défaillance, le serveur renvoie 401 et ferme la connexion, mais le navigateur ne reçoit pas de réponse 401. L'extrait de code serveur est le suivant:

 private void httpResponse401 (ChannelHandlerContext ctx, fullhttprequest request) {
    FullHttpResponse Response = new DefaultfullHttpResponse (request.protoColVersion (), httpResponSestatus.unAuthorized);
    réponse.Headers (). set (httpheadernames.content_length, 0);
    ctx.writeAndFlush (Response) .AddListener (ChannelfUTUreListener.close);
    REFORENCECOUNTUTIL.Release (demande);
}

Cause: Le problème réside dans l'étape de la poignée de main WebSocket. La demande de poignée de main est une demande HTTP, mais une fois la poignée de main qui réussit, la communication n'est plus un protocole HTTP. Par conséquent, la réponse 401 doit être retournée dans la phase de poignée de main.

Solution: Vérifiez le jeton dans le code qui gère la demande de poignée de main WebSocket. Si la vérification échoue, la réponse 401 est directement renvoyée et la logique d'établissement de connexion WebSocket n'est pas exécutée.

Exemple de code amélioré:

 @Outrepasser
public void ChannelRead (ChannelHandlerContext CTX, objet msg) lève une exception {
    if (msg instanceof fullHttpRequest) {
        FullHttpRequest request = (fullHttpRequest) msg;
        String token = extractTokenFromRequest (request); // Extraire la fonction d'assistance du jeton if (! ValidateToken (jeton)) {
            HTTPRESPONSE401 (CTX, demande);
            retour;
        }

        // La vérification des jetons est passée, continuez WebSocket Handshake WebSocketServerHandshakerFactory WSFactory = new WebSocketServerHandshakerFactory (
                getwebsocketLocation (demande), null, false);
        WebSocketServerHandshaker Handshaker = wsfactory.newhandshaker (demande);
        if (handshaker == null) {
            WebsocketServerHandshakerFactory.SendUnSupportEdVersionResponse (ctx.Channel ());
        } autre {
            Handshaker.Handshake (ctx.Channel (), demande);
        }
    } else if (msg instanceof websocketframe) {
        // traite les cadres WebSocket}
}

chaîne privée ExtractTokenFromRequest (requête fullHttpRequest) {
    String uri = request.uri ();
    String [] parties = uri.split ("\\?");
    if (part.length> 1) {
        String [] params = parties [1] .split ("&");
        pour (String Param: params) {
            String [] keyValue = param.split ("=");
            if (keyvalue.length == 2 && keyvalue [0] .equals ("token")) {
                return keyValue [1];
            }
        }
    }
    retourner null;
}


Boolean ValidateToken privé (jeton de chaîne) {
    // Implémentez la logique de vérification du jet // Exemple, remplacez par la logique de vérification réelle}

private void httpResponse401 (ChannelHandlerContext ctx, fullhttprequest request) {
    FullHttpResponse Response = new defaultullHttpResponse (
            Httpversion.http_1_1, httpResponsestatus.unAuthorized);
    réponse.Headers (). Set (httpheadernames.content_type, "text / plain; charset = utf-8");
    Response.Headers (). Set (httpheadernames.content_length, réponse.Content (). ReadableBytes ());
    ctx.writeAndFlush (Response) .AddListener (ChannelfUTUreListener.close);
    REFORENCECOUNTUTIL.Release (demande);
}

En effectuant une vérification des jetons pendant la phase de poignée de main et en renvoyant une réponse 401, le navigateur peut identifier correctement la raison de la fermeture de la connexion, permettant ainsi un serveur WebSocket plus robuste. extractTokenFromRequest améliore la robustesse de l'extraction de jetons. Veuillez remplacer token dans l'exemple par votre logique de vérification réelle.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!