HQY 一个和谐有爱的空间

//在当前帧暂停cc.game.pause();1.

//进行下一帧cc.game.step();1.

//加入房间    onJoinRoom() {
this.client = new Colyseus.Client(this.server_url);
this.client.joinOrCreate(this.room_name, {/* options */ }).then(room => {
            console.log("joined successfully", room);
this.room = room;
//成功加入房间            this.joinSuccess();
        }).catch(e => {
            console.log("join error:\n", e);
        });
    },1.2.3.4.5.6.7.8.9.10.

onMessageListener(message) {
switch (message[0]) {
case "f":
this.onReceiveServerFrame(message);
break;
case "fs":
this.onReceiveServerFrame(message);
//把服务器帧同步到本地帧缓存后，读取并执行本地帧缓存                this.nextTick();
break;
default:
                console.warn("未处理的消息:");
                console.warn(message);
break;
        }
    },

//接收到服务器的帧数据后，放入本地缓存帧    onReceiveServerFrame(message) {
this.addFrames(message[1]);
    },

//按顺序保存至本地    addFrames(_frames) {
        _frames.forEach((m) => {
this.frames[m[0]] = m[1];
for (let i = m[0]; i > m[0] - this.serverFrameAcc; i--) {
if (this.frames[i] == undefined) {
this.frames[i] = [];
                }
            }
        });
    },1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.

//推进游戏    nextTick() {
this.runTick();
if (this.frames.length - this.frame_index > 100) {
//当缓存帧过多时，一次处理多个帧信息，加速执行            this.frame_inv = 0;
        } else if (this.frames.length - this.frame_index > this.serverFrameAcc) {
this.frame_inv = 0;
        } else {
if (this.readyToControl == false) {
this.readyToControl = true;
this.onReadyToControl();
            }
this.frame_inv = 1000 / (this.serverFrameRate * (this.serverFrameAcc + 1));
        }
//this.frame_inv 直接影响到了游戏的表现快慢，如果游戏卡顿，大量帧未及时执行，        //那么加快表现，直到本地帧追上服务器的帧数是最好的解决方式。        setTimeout(this.nextTick.bind(this), this.frame_inv)
    },1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.

//执行服务器的指令    runTick() {
let frame = null;
if (this.frames.length > 1) {
//第一帧延时处理，以免在初始的时候丢失第一帧            frame = this.frames[this.frame_index];
        }
if (frame) {
if (frame.length > 0) {
                frame.forEach((cmd) => {
//这里对应两个函数：cmd_input |  cmd_addplayer                    if (typeof this["cmd_" + cmd[1][0]] == "function") {
this["cmd_" + cmd[1][0]](cmd);
                    } else {
                        console.log("服务器处理函数cmd_" + cmd[1][0] + " 不存在");
                    }
                })
            }
this.frame_index++;
            cc.game.step();
        }
    },

//接收服务器的输入    cmd_input(cmd) {
this.players.forEach((p) => {
let PlayerScript = p.getComponent(PlayerController);
if (PlayerScript.sessionId == cmd[0]) {
//根据输入指令，更新玩家坐标                PlayerScript.updateInput(cmd[1][1])
            }
        })
    },

//接收服务器指令，进行创建玩家    cmd_addplayer(cmd) {
//已经存在的玩家不需要创建        let existPlayer = this.players.filter((p) => {
let PlayerScript = p.getComponent(PlayerController);
return (PlayerScript == null) ? false : (PlayerScript.sessionId == cmd[0]);
        });
if (existPlayer.length > 0) {
        } else {
//在本地创建一个对应的玩家            let player = cc.instantiate(this.playerPrefab);
            player.parent = cc.find("Canvas/gameWorld");
            player.position = cc.v2(0, 0);
let PlayerScript = player.getComponent(PlayerController);
            PlayerScript.sessionId = cmd[0];
            PlayerScript.isLocal = cmd[0] == this.room.sessionId;
            PlayerScript.setPlayerLab('玩家：' + cmd[0]);
this.players.push(player);
        }
    },1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.

//房间名称是 gamegameServer.define('game', GameRoom);1.

//处理消息    onMessage(client: Client, message: any) {
switch (message[0]) {
case "cmd":
this.onCmd(client, message);
break;
case "fs":
this.onGetAllFrames(client, message);
break;
default:
                console.log("接收到未处理的message:")
                console.log(message)
break;
        }
    }

//当收到用户的输入，存入frame_list    onCmd(client: Client, message: any) {
if (message[0] == "cmd" && message[1][0] == "addplayer") {
        }
this.frame_list_push([client.sessionId, message[1]]);
    }

//获取全部的帧数据    onGetAllFrames(client: Client, message: any) {
let frames = [];
for (let i = 0, len = this.frame_list.length; i < len; i++) {
if (this.frame_list[i] !== undefined) {
                frames.push([i, this.frame_list[i]]);
            }
        }
if (frames.length == 0) {
            frames = [[0, []]];
        }
this.send(client, ["fs", frames])
    }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.