Netty4 WebSocket ?? : ???? 401 ??? ???? ?????

NetTy4? ???? WebSocket ??? ??? ?? ?? ????? ??? ???????. ??? ???? ??? 401 ?? ??? ???? ??? ??????. ??? ????? ???? ??? ?????? ????. ? ???? ??? ???? ??? ??? ?????.

?? : var socket = new WebSocket("ws://127.0.0.1:18080/ws?token=xxxx"); ??? ???? ??? ??? ?????. ??? ??? 401? ???? ??? ?? ? ????? 401 ????? ????. ?? ?? ? ??? ??? ????.

 ?? void httpresponse401 (Chann
    fullhttpresponse ?? = ??? defaultfullhtttpresponse (request.protocolversion (), httpresponsestatus.unauthorized);
    response.headers (). set (httpheadernames.content_length, 0);
    ctx.writeAndflush (??) .addlistener (channelfuturelistener.close);
    ?? CountUtil.Release (??);
}

?? : ??? WebSocket ?? ??? ??? ????. ?? ??? ??? HTTP ?????, ?? ???? ??? ?? ??????? ? ?? HTTP ????? ????. ??? 401 ??? ?? ??? ???? ????????.

??? : WebSocket ?? ??? ??? ???? ??? ??? ??????. ??? ???? 401 ??? ?? ???? WebSocket ?? ?? ??? ???? ????.

?? ? ?? ? :

 @??
public void channelread (Chann
    if (fullhttprequest? msg instance) {
        fullhttprequest request = (fullhttprequest) msg;
        ??? ?? = ExtractTokenFromRequest (??); // ??? ??? ?? ?? if (! validateToken (??)) {
            httpresponse401 (CTX, ??);
            ??;
        }

        // ?? ??? ???? WebSocketServerHandshakerFactory wsfactory = ??? WebSocketServerHandshakerFactory
                getWebSocketLocation (??), null, false);
        WebSocketServerHandshaker ?? ??? = wsfactory.newhandshaker (??);
        if (handshaker == null) {
            WebSocketServerHandshakerFactory.SendunSupportedVersionResponse (ctx.channel ());
        } ? ?? {
            Handshaker.handshake (ctx.channel (), ??);
        }
    } else if (msg instanceof webSocketFrame) {
        // Process WebSocket ???}
}

?? ??? extractokenfromRequest (fullHttPrequest ??) {
    ??? uri = request.uri ();
    ??? [] parts = uri.split ( "\\?");
    if (parts.length> 1) {
        ??? [] params = parts [1] .split ( "&");
        for (??? param : params) {
            ??? [] keyValue = param.split ( "=");
            if (keyValue.length == 2 && keyValue [0] .Equals ( "Token")) {
                return keyvalue [1];
            }
        }
    }
    ? ??;
}


Private Boolean ValidAteToken (String Token) {
    // ???? ?? ?? ??? ??????. // ?, ?? ?? ??? ?????}

?? void httpresponse401 (Chann
    fullhttpresponse ?? = ??? defaultfullhttpresponse (
            httpversion.http_1_1, httpresponsestatus.unauthorized);
    response.headers (). set (httpheadernames.content_type, "text/plain; charset = utf-8");
    response.headers (). set (httpheadernames.content_length, response.content (). readableBytes ());
    ctx.writeAndflush (??) .addlistener (channelfuturelistener.close);
    ?? CountUtil.Release (??);
}

?? ??? ???? ?? ??? ???? 401 ??? ?????? ????? ??? ??? ??? ???? ?????? ??? WebSocket ??? ???? ? ? ????. extractTokenFromRequest ??? ?? ??? ???? ??????. ??? token ??? ?? ?? ??? ?????.

? ??? NetTy4? ???? WebSocket ??? ??? ? ????? 401 ??? ???? ????? ???? ??? ??????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!