tower_client/assets/script/game/common/NetManager.ts

import { FrameworkConf } from "../../framework/config/FrameworkConf";
import { Framework } from "../../framework/Framework";
import { GameEvent } from "../data/GameEvent";
import { StringUtil } from "../../framework/util/StringUtil";
import { ViewID } from "../../framework/config/LayerConf";


export let NetMgr: NetManager = null;

export class NetManager {
    private _socket: WebSocket = null;
    private _web_url = "";                              //服务器地址
    private _callback: Function = null;

    private _hear_time = 5;                            //心跳时间
    private _hear_time_out = 2;                        //心跳超次数()
    private _hear_time_cur = 0;                         //心跳超时次数
    private _hear_uuid = 0;                             //心跳定时器
    private _is_connect = false;                        //网络是否连接

    private _bReconnect = false;                            //是否重连
    private _bHandShake = false;                        //是否握手
    private _bProClose = false;                        //是否主动断开   
    
    private _uid = 0;
    private _seq = 0;

    //心跳超时 自动重连，超过5次则不再重连
    private _auto_reconnect_time = 0;
    private _auto_reconnect_time_out = 5;

    private _socketId = 0;

    static get instance() {
        if (NetMgr == null) {
            NetMgr = new NetManager();
        }
        return NetMgr;
    }


    //网络是否连接
    get is_connect() {
        return this._is_connect;
    }

    get is_handShake() {
        return this._bHandShake;
    }

    get bReconnect() {
        return this._bReconnect;
    }

    get bProClose() {
        return this._bProClose;
    }

    connect(url: string, callback: Function) {
        //this.close(false);

        let socketId = ++this._socketId
        this._clearHeart();
        this._web_url = url;
        this._callback = callback;
        this._socket = new WebSocket(this._web_url, 'default-protocol');
        this._socket.binaryType = "arraybuffer";

        this._socket.onopen = (event: any) => {
            if(socketId != this._socketId){
                return
            }
            callback && callback(0);
            callback = null;
            this._is_connect = true;
            this._bProClose = false

            this._auto_reconnect_time = 0
            this._hear_time_cur = 0
            
        };

        this._socket.onerror = (event: any) => {
            if(socketId != this._socketId){
                return
            }
            console.log("onerror:", event," socketId:",socketId);
            callback && callback(1);
            callback = null;
            this._is_connect = false;
            this._bHandShake = false
            this._clearHeart();
            // this._socket = null
            // this._autoReconnect(3)
            Framework.event.fireEvent(FrameworkConf.Event.NET_ERROR, event);
        };

        this._socket.onclose = (event: any) => {
            if(socketId != this._socketId){
                return
            }
            console.log("onclose1:", event," socketId:",socketId);
            this._is_connect = false;
            this._bHandShake = false
            this._bReconnect = false
            this._clearHeart();
            this._socket = null
            Framework.layer.open(ViewID.MaskUI,()=>{});
            if(!this._bProClose){
                this._autoReconnect(3)
            }
            else Framework.event.fireEvent(FrameworkConf.Event.NET_CLOSE, event);
        };

        this._socket.onmessage = (event: any) => {

            let Json = JSON.parse(event.data)
            // console.log(Json);
            
            if (Json.mod == 'user' && Json.act == 'handshake') {
                
                this._startHeart();
                
                if (Json.code == 0) {
                    Framework.layer.close(ViewID.MaskUI);
                    this._bHandShake = true
                   // if(Framework.layer.getUIView(ViewID.BombUI)){
                        //window.parent.postMessage(FrameworkConf.Event.NET_RECONNECT, "*");
                        this._uid = Json.data._id
                        Framework.event.fireEvent(FrameworkConf.Event.NET_RECONNECT, {});
                        this._bReconnect = false
                    //}
                    // if(!Framework.layer.getUIView(ViewID.BombUI)){
                    //     var args = { 'uid': Json.data._id, 'cash': Json.data.cash, 'state': 1 };
                    //     Framework.layer.open(ViewID.BombUI, null, args);
                    // }
                    
                }else {
		            this.close(false)

                    Framework.event.fireEvent(FrameworkConf.Event.NET_HANDSHAKE_ERROR, Json.code);
                    // 弹窗提示登陆失败
                    Framework.tips.setTips(Json.desc);
                }
            }else if (Json.mod == 'user' && Json.act == 'heart_beat') {
                this._hear_time_cur = 0;
                //console.error(Json)

            } else {
                if (Json.seq == this._seq) {
                    // 解开遮罩
                }

                // console.log("onmessage:",event.data);
                Framework.event.fireEvent(FrameworkConf.Event.NET_MSG, Json);
            }
        };
    }

    /**
     * 关闭socket
     * @param bReconnect 是否重连 
     */
    close(bReconnect) {

        console.log("close test");
        this._socket && this._socket.close();
        this._socket = null;
        this._is_connect = false;
        this._bHandShake = false
        this._bProClose = true;
        this._clearHeart();
        // window.parent.postMessage(FrameworkConf.Event.NET_CLOSE, "*");
        

        if(bReconnect){
            Framework.layer.open(ViewID.MaskUI);
            this._autoReconnect()
        }
        else{
            Framework.layer.open(ViewID.MaskUI,()=>{},{closeTime:0});
            console.error("断开连接")
        }
    }

    send(msg: any) {
        //msg.uid = UserData['_id'];
        let msgStr = JSON.stringify(msg)
        // console.log(msgStr);
        // console.log(this._socket);
        if (this._socket) {

            //     // let strBuf = this.protoEncode(cmd, msg);
            //     // let buf = this.packet(strBuf);
            this._socket.send(msgStr)
        }
    }
    // uint8Array转typedArray
    typedArray(uint8Array) {
        var hex = Array.prototype.map
            .call(uint8Array, (x) => ('00' + x.toString(16)).slice(-2))
            .join('');
        var typedArray = new Uint8Array(hex.match(/[\da-f]{2}/gi).map(function (h) {
            return parseInt(h, 16)
        }))
        var buffer = typedArray.buffer;
        return buffer;
    }

    private _clearHeart() {
        (this._hear_uuid != 0) && Framework.time.unschedule(this._hear_uuid);
        this._hear_uuid = 0;
    }

    private _startHeart() {
        this._clearHeart();
        this._hear_uuid = Framework.time.schedule(() => {
            this._hear_time_cur += 1;

            if(this._hear_time_cur > this._hear_time_out){
                console.error("心跳超时",this._hear_time_cur);
                this.close(true);
                //this._autoReconnect()
            }
            else if (this._socket) {
                // this._hear_uuid = 0;
                this.netApiSend("user","heart_beat",{});
            }
        }, this._hear_time);
    }

    // 自动重连
    // delay:延迟时间
    private _autoReconnect(delay?:number) {
        if(this._bReconnect) {
            console.error("自动重连中",new Date());
            return
        }
        if (this._is_connect) {
            return;
        }
        if (this._auto_reconnect_time > this._auto_reconnect_time_out) {

            Framework.tips.setTips("Reconnection failed");
            console.error("多少次重连失败1")

            //window.parent.postMessage(FrameworkConf.Event.NET_ERROR, "*");
            Framework.layer.open(ViewID.MaskUI,()=>{},{closeTime:0});

            return;
        }



        delay = delay || 0
        if(delay > 0){
            Framework.time.scheduleOnce(()=>{
                this._autoReconnect()
            },delay)
            return 
        }



        console.log("自动重连");
        this._auto_reconnect_time += 1;
        this._bReconnect = true
        this.connect(this._web_url,this._callback)
    }


    netApiSend(mod, act, args) {
        let req = {
            mod: mod,
            act: act,
            args: args,
            uid: this._uid,
            seq: this._seq++,
        }
        Framework.event.fireEvent('cid', args);
        // if(act != "heart_beat"){
        //     console.log("发送", req);
        // }
        this.send(req);// 握手消息,返回在netmanger里面处理

        // 启动loading 遮罩id

    }
}