binary encode

apps/client/assets/Scripts/Entity/Actor/ActorManager.ts

@@ -1,10 +1,10 @@
 import { _decorator, instantiate, ProgressBar, Label } from 'cc';
 import { EntityManager } from '../../Base/EntityManager';
-import { ApiMsgEnum, EntityTypeEnum, IActor, InputTypeEnum, IVec2 } from '../../Common';
+import { ApiMsgEnum, EntityTypeEnum, IActor, InputTypeEnum, IVec2, toFixed } from '../../Common';
 import { EntityStateEnum } from '../../Enum';
 import DataManager from '../../Global/DataManager';
 import NetworkManager from '../../Global/NetworkManager';
-import { rad2Angle, toFixed } from '../../Utils';
+import { rad2Angle } from '../../Utils';
 import { WeaponManager } from '../Weapon/WeaponManager';
 import { PlayerStateMachine } from './ActorStateMachine';
 const { ccclass } = _decorator;
@@ -59,9 +59,9 @@ export class ActorManager extends EntityManager implements IActor {
             return
         }
 
-        const { x, y } = DataManager.Instance.jm.input
-        NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
-            input: {
+        if (DataManager.Instance.jm.input.length()) {
+            const { x, y } = DataManager.Instance.jm.input
+            NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
                 type: InputTypeEnum.ActorMove,
                 id: this.id,
                 direction: {
@@ -69,8 +69,9 @@ export class ActorManager extends EntityManager implements IActor {
                     y: toFixed(y),
                 },
                 dt: toFixed(dt)
-            }
-        })
+            })
+        }
+
     }
 
     render(data: IActor) {

apps/client/assets/Scripts/Entity/Weapon/WeaponManager.ts

@@ -1,11 +1,10 @@
 import { _decorator, Node, Vec2, UITransform } from 'cc'
 import { EntityManager } from '../../Base/EntityManager'
-import { ApiMsgEnum, EntityTypeEnum, InputTypeEnum } from '../../Common'
+import { ApiMsgEnum, EntityTypeEnum, InputTypeEnum, toFixed } from '../../Common'
 import { EntityStateEnum, EventEnum } from '../../Enum'
 import DataManager from '../../Global/DataManager'
 import EventManager from '../../Global/EventManager'
 import NetworkManager from '../../Global/NetworkManager'
-import { toFixed } from '../../Utils'
 import { WeaponStateMachine } from './WeaponStateMachine'
 const { ccclass } = _decorator
 
@@ -62,18 +61,16 @@ export class WeaponManager extends EntityManager {
     const directionVec2 = new Vec2(pointWorldPos.x - anchorWorldPos.x, pointWorldPos.y - anchorWorldPos.y).normalize()
 
     NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
-      input: {
-        type: InputTypeEnum.WeaponShoot,
-        owner: this.owner,
-        position: {
-          x: toFixed(pointStagePos.x),
-          y: toFixed(pointStagePos.y),
-        },
-        direction: {
-          x: toFixed(directionVec2.x),
-          y: toFixed(directionVec2.y),
-        },
-      }
+      type: InputTypeEnum.WeaponShoot,
+      owner: this.owner,
+      position: {
+        x: toFixed(pointStagePos.x),
+        y: toFixed(pointStagePos.y),
+      },
+      direction: {
+        x: toFixed(directionVec2.x),
+        y: toFixed(directionVec2.y),
+      },
     })
   }
 }

apps/client/assets/Scripts/Global/DataManager.ts

@@ -1,6 +1,6 @@
 import { Node, Prefab, SpriteFrame } from 'cc'
 import Singleton from '../Base/Singleton'
-import { EntityTypeEnum, IBullet, IClientInput, InputTypeEnum, IRoom, IState } from '../Common'
+import { EntityTypeEnum, IBullet, IClientInput, InputTypeEnum, IRoom, IState, toFixed } from '../Common'
 import { ActorManager } from '../Entity/Actor/ActorManager'
 import { BulletManager } from '../Entity/Bullet/BulletManager'
 import { EventEnum } from '../Enum'
@@ -82,8 +82,8 @@ export default class DataManager extends Singleton {
           return
         }
 
-        player.position.x += x * PLAYER_SPEED * dt
-        player.position.y += y * PLAYER_SPEED * dt
+        player.position.x += toFixed(x * PLAYER_SPEED * dt)
+        player.position.y += toFixed(y * PLAYER_SPEED * dt)
         player.direction = { x, y }
         break
       }
@@ -112,8 +112,8 @@ export default class DataManager extends Singleton {
             const player = players[j];
             if (((player.position.x - bullet.position.x) ** 2 + (player.position.y - bullet.position.y) ** 2) < (PLAYER_RADIUS + BULLET_RADIUS) ** 2) {
               EventManager.Instance.emit(EventEnum.ExplosionBorn, bullet.id, {
-                x: (player.position.x + bullet.position.x) / 2,
-                y: (player.position.y + bullet.position.y) / 2,
+                x: toFixed((player.position.x + bullet.position.x) / 2),
+                y: toFixed((player.position.y + bullet.position.y) / 2),
               })
 
               player.hp -= WEAPON_DAMAGE
@@ -132,8 +132,8 @@ export default class DataManager extends Singleton {
         }
 
         for (const bullet of this.state.bullets) {
-          bullet.position.x += bullet.direction.x * BULLET_SPEED * dt
-          bullet.position.y += bullet.direction.y * BULLET_SPEED * dt
+          bullet.position.x += toFixed(bullet.direction.x * BULLET_SPEED * dt)
+          bullet.position.y += toFixed(bullet.direction.y * BULLET_SPEED * dt)
         }
       }
     }

apps/client/assets/Scripts/Global/NetworkManager.ts

@@ -1,5 +1,7 @@
 import Singleton from '../Base/Singleton'
-import { IModel } from '../Common';
+import { ApiMsgEnum, IModel, strdecode, strencode } from '../Common';
+import { binaryEncode } from '../Common/Binary';
+import { binaryDecode } from '../Utils';
 
 const TIMEOUT = 5000
 
@@ -17,7 +19,7 @@ export default class NetworkManager extends Singleton {
 
   ws: WebSocket
   port = 8888
-  cbs: Map<string, Function[]> = new Map()
+  maps: Map<ApiMsgEnum, Function[]> = new Map()
   isConnected = false
 
   connect() {
@@ -27,6 +29,8 @@ export default class NetworkManager extends Singleton {
         return
       }
       this.ws = new WebSocket(`ws://localhost:${this.port}`)
+
+      this.ws.binaryType = 'arraybuffer';
       this.ws.onopen = () => {
         console.log("ws onopen")
         this.isConnected = true
@@ -45,15 +49,15 @@ export default class NetworkManager extends Singleton {
 
       this.ws.onmessage = (e) => {
         try {
-          const json = JSON.parse(e.data)
+          const json = binaryDecode(e.data)
           const { name, data } = json
           try {
-            if (this.cbs.has(name) && this.cbs.get(name).length) {
+            if (this.maps.has(name) && this.maps.get(name).length) {
               console.log(json);
-              this.cbs.get(name).forEach(cb => cb(data))
+              this.maps.get(name).forEach(cb => cb(data))
             }
           } catch (error) {
-            console.log("this.cbs.get(name).forEach(cb => cb(restData))", error)
+            console.log("this.maps.get(name).forEach(cb => cb(restData))", error)
           }
 
         } catch (error) {
@@ -80,7 +84,7 @@ export default class NetworkManager extends Singleton {
         }
         this.listenMsg(name as any, cb)
 
-        this.ws.send(JSON.stringify({ name, data }))
+        this.sendMsg(name as any, data)
       } catch (error) {
         console.log(error)
         resolve({ success: false, error: error as Error })
@@ -89,21 +93,24 @@ export default class NetworkManager extends Singleton {
   }
 
   sendMsg<T extends keyof IModel['msg']>(name: T, data: IModel['msg'][T]) {
-    this.ws.send(JSON.stringify({ name, data }))
+    const view = binaryEncode(name, data)
+    console.log("view", view.buffer);
+
+    this.ws.send(view.buffer)
   }
 
   listenMsg<T extends keyof IModel['msg']>(name: T, cb: (args: IModel['msg'][T]) => void) {
-    if (this.cbs.has(name)) {
-      this.cbs.get(name).push(cb)
+    if (this.maps.has(name)) {
+      this.maps.get(name).push(cb)
     } else {
-      this.cbs.set(name, [cb])
+      this.maps.set(name, [cb])
     }
   }
 
-  unlistenMsg(name: string, cb: Function) {
-    if (this.cbs.has(name)) {
-      const index = this.cbs.get(name).indexOf(cb)
-      index > -1 && this.cbs.get(name).splice(index, 1)
+  unlistenMsg(name: ApiMsgEnum, cb: Function) {
+    if (this.maps.has(name)) {
+      const index = this.maps.get(name).indexOf(cb)
+      index > -1 && this.maps.get(name).splice(index, 1)
     }
   }
 }

apps/client/assets/Scripts/Scene/BattleManager.ts

@@ -8,7 +8,6 @@ import NetworkManager from '../Global/NetworkManager';
 import ObjectPoolManager from '../Global/ObjectPoolManager';
 import { BulletManager } from '../Entity/Bullet/BulletManager';
 import { ApiMsgEnum, EntityTypeEnum, IMsgServerSync, InputTypeEnum } from '../Common';
-import { toFixed } from '../Utils';
 
 const { ccclass } = _decorator;
 
@@ -86,7 +85,7 @@ export class BattleManager extends Component {
         map.setParent(this.stage)
     }
 
-    handleSync({ inputs }: IMsgServerSync) {
+    handleSync(inputs: IMsgServerSync) {
         for (const input of inputs) {
             DataManager.Instance.applyInput(input)
         }
@@ -102,7 +101,7 @@ export class BattleManager extends Component {
 
     tick(dt: number) {
         this.tickPlayer(dt)
-        this.tickGlobal(dt)
+        // this.tickGlobal(dt)
     }
 
     tickPlayer(dt: number) {
@@ -115,14 +114,14 @@ export class BattleManager extends Component {
         }
     }
 
-    tickGlobal(dt: number) {
-        NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
-            input: {
-                type: InputTypeEnum.TimePast,
-                dt: toFixed(dt),
-            }
-        })
-    }
+    // tickGlobal(dt: number) {
+    //     NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
+    //         input: {
+    //             type: InputTypeEnum.TimePast,
+    //             dt: toFixed(dt),
+    //         }
+    //     })
+    // }
 
     render() {
         this.renderPlayer()

apps/client/assets/Scripts/Utils/index.ts

@@ -1,4 +1,5 @@
 import { SpriteFrame } from "cc"
+import { ApiMsgEnum, InputTypeEnum, strdecode } from "../Common"
 
 const INDEX_REG = /\((\d+)\)/
 
@@ -9,4 +10,78 @@ export const sortSpriteFrame = (spriteFrame: Array<SpriteFrame>) =>
 
 export const rad2Angle = (rad: number) => rad / Math.PI * 180
 
-export const toFixed = (num: number, digit: number = 4): number => Math.floor(num * 10 ** digit) / 10 ** digit
+export const binaryDecode = (buffer: ArrayBuffer) => {
+  let index = 0
+  const view = new DataView(buffer)
+  const type = view.getUint8(index++)
+
+  if (type === ApiMsgEnum.MsgClientSync) {
+    const inputType = view.getUint8(index++)
+    if (inputType === InputTypeEnum.ActorMove) {
+      const id = view.getUint8(index++)
+      const directionX = view.getFloat32(index)
+      index += 4
+      const directionY = view.getFloat32(index)
+      index += 4
+      const dt = view.getFloat32(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.ActorMove,
+          id,
+          direction: {
+            x: directionX,
+            y: directionY,
+          },
+          dt
+        }
+      }
+
+      return msg
+    } else if (inputType === InputTypeEnum.WeaponShoot) {
+      const id = view.getUint8(index++)
+      const positionX = view.getFloat32(index)
+      index += 4
+      const positionY = view.getFloat32(index)
+      index += 4
+      const directionX = view.getFloat32(index)
+      index += 4
+      const directionY = view.getFloat32(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.WeaponShoot,
+          id,
+          position: {
+            x: positionX,
+            y: positionY,
+          },
+          direction: {
+            x: directionX,
+            y: directionY,
+          },
+        }
+      }
+
+      return msg
+    } else {
+      const dt = view.getFloat32(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.TimePast,
+          dt,
+        }
+      }
+      return msg
+    }
+  } else {
+    return {
+      name: type,
+      data: JSON.parse(strdecode(new Uint8Array(buffer.slice(1))))
+    }
+  }
+}

apps/server/src/Common/Binary.ts

@@ -0,0 +1,67 @@
+import { ApiMsgEnum, InputTypeEnum } from "./Enum";
+import { strencode } from "./Utils";
+
+export const binaryEncode = (proto: ApiMsgEnum, data: any): DataView => {
+  if (proto === ApiMsgEnum.MsgClientSync) {
+    switch (data.type) {
+      case InputTypeEnum.ActorMove: {
+        let index = 0
+        const ab = new ArrayBuffer(3 + 12)
+        const view = new DataView(ab)
+        view.setUint8(index++, proto)
+        view.setUint8(index++, data.type)
+        view.setUint8(index++, data.id)
+        view.setFloat32(index, data.direction.x)
+        index += 4
+        view.setFloat32(index, data.direction.y)
+        index += 4
+        view.setFloat32(index, data.dt)
+        index += 4
+        return view
+      }
+      case InputTypeEnum.WeaponShoot: {
+        let index = 0
+        const ab = new ArrayBuffer(3 + 16)
+        const view = new DataView(ab)
+        view.setUint8(index++, proto)
+        view.setUint8(index++, data.type)
+        view.setUint8(index++, data.id)
+        view.setFloat32(index, data.position.x)
+        index += 4
+        view.setFloat32(index, data.position.y)
+        index += 4
+        view.setFloat32(index, data.direction.x)
+        index += 4
+        view.setFloat32(index, data.direction.y)
+        index += 4
+        return view
+      }
+      case InputTypeEnum.TimePast: {
+        let index = 0
+        const ab = new ArrayBuffer(1 + 1 + 4)
+        const view = new DataView(ab)
+        view.setUint8(index++, proto)
+        view.setUint8(index++, data.type)
+        view.setFloat32(index, data.dt)
+        index += 4
+        return view
+      }
+      default: {
+        const ab = new ArrayBuffer(0)
+        const view = new DataView(ab)
+        return view
+      }
+    }
+  } else {
+    let index = 0
+    const str = JSON.stringify(data)
+    const ta = strencode(str)
+    const ab = new ArrayBuffer(ta.length + 1)
+    const view = new DataView(ab)
+    view.setUint8(index++, proto)
+    for (let i = 0; i < ta.length; i++) {
+      view.setUint8(index++, ta[i])
+    }
+    return view
+  }
+}

apps/server/src/Common/Binary.ts.meta

@@ -0,0 +1,9 @@
+{
+  "ver": "4.0.23",
+  "importer": "typescript",
+  "imported": true,
+  "uuid": "9888254e-f4d1-4b2a-a814-75fb288e474f",
+  "files": [],
+  "subMetas": {},
+  "userData": {}
+}

apps/server/src/Common/Enum.ts

@@ -1,23 +1,46 @@
+// export enum ApiMsgEnum {
+//   ApiPlayerList = 'ApiPlayerList',
+//   ApiPlayerJoin = 'ApiPlayerJoin',
+//   ApiRoomList = 'ApiRoomList',
+//   ApiRoomCreate = 'ApiRoomCreate',
+//   ApiRoomJoin = 'ApiRoomJoin',
+//   ApiRoomLeave = 'ApiRoomLeave',
+//   ApiGameStart = 'ApiGameStart',
+//   MsgPlayerList = 'MsgPlayerList',
+//   MsgRoomList = 'MsgRoomList',
+//   MsgRoom = 'MsgRoom',
+//   MsgGameStart = 'MsgGameStart',
+//   MsgClientSync = 'MsgClientSync',
+//   MsgServerSync = 'MsgServerSync',
+// }
+
 export enum ApiMsgEnum {
-  ApiPlayerList = 'ApiPlayerList',
-  ApiPlayerJoin = 'ApiPlayerJoin',
-  ApiRoomList = 'ApiRoomList',
-  ApiRoomCreate = 'ApiRoomCreate',
-  ApiRoomJoin = 'ApiRoomJoin',
-  ApiRoomLeave = 'ApiRoomLeave',
-  ApiGameStart = 'ApiGameStart',
-  MsgPlayerList = 'MsgPlayerList',
-  MsgRoomList = 'MsgRoomList',
-  MsgRoom = 'MsgRoom',
-  MsgGameStart = 'MsgGameStart',
-  MsgClientSync = 'MsgClientSync',
-  MsgServerSync = 'MsgServerSync',
+  ApiPlayerList,
+  ApiPlayerJoin,
+  ApiRoomList,
+  ApiRoomCreate,
+  ApiRoomJoin,
+  ApiRoomLeave,
+  ApiGameStart,
+  MsgPlayerList,
+  MsgRoomList,
+  MsgRoom,
+  MsgGameStart,
+  MsgClientSync,
+  MsgServerSync,
 }
 
+// export enum InputTypeEnum {
+//   ActorMove = 'ActorMove',
+//   WeaponShoot = 'WeaponShoot',
+//   TimePast = 'TimePast',
+// }
+
+
 export enum InputTypeEnum {
-  ActorMove = 'ActorMove',
-  WeaponShoot = 'WeaponShoot',
-  TimePast = 'TimePast',
+  ActorMove,
+  WeaponShoot,
+  TimePast,
 }
 
 export enum EntityTypeEnum {

apps/server/src/Common/Msg.ts

@@ -22,10 +22,6 @@ export interface IMsgGameStart {
   state: IState
 }
 
-export interface IMsgClientSync {
-  input: IClientInput
-}
+export type IMsgClientSync = IClientInput
 
-export interface IMsgServerSync {
-  inputs: Array<IClientInput>
-}
+export type IMsgServerSync = Array<IClientInput>

apps/server/src/Common/Utils.ts

@@ -0,0 +1,42 @@
+export const toFixed = (num: number, digit: number = 4): number => Math.floor(num * 10 ** digit) / 10 ** digit
+
+export const strencode = (str: string) => {
+  let byteArray: number[] = [];
+  for (let i = 0; i < str.length; i++) {
+    let charCode = str.charCodeAt(i);
+    if (charCode <= 0x7f) {
+      byteArray.push(charCode);
+    } else if (charCode <= 0x7ff) {
+      byteArray.push(0xc0 | (charCode >> 6), 0x80 | (charCode & 0x3f));
+    } else if (charCode <= 0xffff) {
+      byteArray.push(0xe0 | (charCode >> 12), 0x80 | ((charCode & 0xfc0) >> 6), 0x80 | (charCode & 0x3f));
+    } else {
+      byteArray.push(0xf0 | (charCode >> 18), 0x80 | ((charCode & 0x3f000) >> 12), 0x80 | ((charCode & 0xfc0) >> 6), 0x80 | (charCode & 0x3f));
+    }
+  }
+  return new Uint8Array(byteArray);
+}
+
+export const strdecode = (bytes: Uint8Array) => {
+  let array: number[] = [];
+  let offset = 0;
+  let charCode = 0;
+  let end = bytes.length;
+  while (offset < end) {
+    if (bytes[offset] < 128) {
+      charCode = bytes[offset];
+      offset += 1;
+    } else if (bytes[offset] < 224) {
+      charCode = ((bytes[offset] & 0x3f) << 6) + (bytes[offset + 1] & 0x3f);
+      offset += 2;
+    } else if (bytes[offset] < 240) {
+      charCode = ((bytes[offset] & 0x0f) << 12) + ((bytes[offset + 1] & 0x3f) << 6) + (bytes[offset + 2] & 0x3f);
+      offset += 3;
+    } else {
+      charCode = ((bytes[offset] & 0x07) << 18) + ((bytes[offset + 1] & 0x3f) << 12) + ((bytes[offset + 1] & 0x3f) << 6) + (bytes[offset + 2] & 0x3f);
+      offset += 4;
+    }
+    array.push(charCode);
+  }
+  return String.fromCharCode.apply(null, array);
+}

apps/server/src/Common/Utils.ts.meta

@@ -0,0 +1,9 @@
+{
+  "ver": "4.0.23",
+  "importer": "typescript",
+  "imported": true,
+  "uuid": "b44d77f2-f4af-4b06-bc29-986d191fe180",
+  "files": [],
+  "subMetas": {},
+  "userData": {}
+}

apps/server/src/Core/MyServer.ts

@@ -0,0 +1,64 @@
+import { EventEmitter } from 'stream';
+import WebSocket, { WebSocketServer } from 'ws';
+import { ApiMsgEnum } from '../Common';
+import { Connection, ConnectionEventEnum } from './Connection';
+
+export interface IMyServerOptions {
+  port: number
+}
+
+export enum MyServerEventEnum {
+  Connect = 'Connect',
+  DisConnect = 'DisConnect',
+}
+
+export class MyServer extends EventEmitter {
+  wss?: WebSocketServer
+  port: number
+  connections: Set<Connection> = new Set()
+  apiMap: Map<ApiMsgEnum, Function> = new Map()
+
+  constructor({ port = 8080 }: Partial<IMyServerOptions>) {
+    super()
+    this.port = port
+  }
+
+  start() {
+    return new Promise((resolve, reject) => {
+      this.wss = new WebSocketServer({ port: this.port });
+      this.wss.on('connection', this.handleConnect.bind(this));
+
+      this.wss.on("error", (e) => {
+        reject(e)
+      })
+
+      this.wss.on("close", () => {
+        console.log("MyServer 服务关闭");
+      })
+
+      this.wss.on("listening", () => {
+        resolve(true)
+      })
+    })
+
+  }
+
+  handleConnect(ws: WebSocket) {
+    //初始化
+    const connection = new Connection(this, ws)
+
+    //向外告知有人来了
+    this.connections.add(connection)
+    this.emit(MyServerEventEnum.Connect, connection)
+
+    //向外告知有人走了
+    connection.on(ConnectionEventEnum.Close, (code: number, reason: string) => {
+      this.connections.delete(connection)
+      this.emit(MyServerEventEnum.DisConnect, connection, code, reason)
+    })
+  }
+
+  setApi(apiName: ApiMsgEnum, cb: Function) {
+    this.apiMap.set(apiName, cb)
+  }
+}

apps/server/src/biz/Player.ts

@@ -1,4 +1,4 @@
-import Connection from '../Core/Connection'
+import { Connection } from "../Core"
 
 export default class Player {
   id: number

apps/server/src/biz/PlayerManager.ts

@@ -1,9 +1,8 @@
 import Singleton from '../Base/Singleton'
 import { ApiMsgEnum, IApiPlayerJoinReq } from '../Common'
+import { Connection } from '../Core'
 import Player from './Player'
 import RoomManager from './RoomManager'
-import Connection from '../Core/Connection'
-
 export default class PlayerManager extends Singleton {
   static get Instance() {
     return super.GetInstance<PlayerManager>()

apps/server/src/biz/Room.ts

@@ -1,4 +1,4 @@
-import { ApiMsgEnum, EntityTypeEnum, IClientInput, IState } from '../Common'
+import { ApiMsgEnum, EntityTypeEnum, IClientInput, InputTypeEnum, IState, toFixed } from '../Common'
 import type Player from './Player'
 import PlayerManager from './PlayerManager'
 import RoomManager from './RoomManager'
@@ -6,12 +6,14 @@ import RoomManager from './RoomManager'
 export default class Room {
   id: number
   players: Set<Player> = new Set()
+  lastSyncTime?: number
+
+  private inputs: Array<IClientInput> = []
 
   constructor(rid: number) {
     this.id = rid
   }
 
-  private inputs: Array<IClientInput> = []
 
   join(uid: number) {
     const player = PlayerManager.Instance.getPlayerById(uid)
@@ -71,12 +73,15 @@ export default class Room {
     this.listenPlayer()
     setInterval(() => {
       this.syncInput()
-    }, 300)
+    }, 100)
+    setInterval(() => {
+      this.timePast()
+    }, 16)
   }
 
   listenPlayer() {
     for (const player of this.players) {
-      player.connection.listenMsg(ApiMsgEnum.MsgClientSync, ({ input }) => {
+      player.connection.listenMsg(ApiMsgEnum.MsgClientSync, (input) => {
         this.inputs.push(input)
       })
     }
@@ -85,10 +90,21 @@ export default class Room {
   syncInput() {
     const inputs = this.inputs
     this.inputs = []
+
+
     for (const player of this.players) {
-      player.connection.sendMsg(ApiMsgEnum.MsgServerSync, {
-        inputs
-      })
+      player.connection.sendMsg(ApiMsgEnum.MsgServerSync, inputs)
     }
   }
+
+  timePast() {
+    let now = process.uptime();
+    const dt = now - (this.lastSyncTime ?? now)
+    this.inputs.push({
+      type: InputTypeEnum.TimePast,
+      dt: toFixed(dt)
+    })
+    this.lastSyncTime = now;
+
+  }
 }

apps/server/src/common/index.ts

@@ -1,12 +1,12 @@
 import { IApiGameStartReq, IApiGameStartRes, IApiPlayerJoinReq, IApiPlayerJoinRes, IApiPlayerListReq, IApiPlayerListRes, IApiRoomCreateReq, IApiRoomCreateRes, IApiRoomJoinReq, IApiRoomJoinRes, IApiRoomLeaveReq, IApiRoomLeaveRes, IApiRoomListReq, IApiRoomListRes } from './Api'
 import { ApiMsgEnum } from './Enum'
 import { IMsgClientSync, IMsgGameStart, IMsgPlayerList, IMsgRoom, IMsgRoomList, IMsgServerSync } from './Msg'
-import { IClientInput } from './State'
 export * from './Api'
 export * from './Msg'
 export * from './Enum'
 export * from './Model'
 export * from './State'
+export * from './Utils'
 
 export interface IModel {
   api: {

apps/server/src/core/Connection.ts

@@ -1,17 +1,18 @@
 import WebSocket from 'ws';
 import { EventEmitter } from 'stream';
-import MyServer, { IData } from '.';
-import { getTime } from '../Utils';
-import { IModel } from '../Common';
+import { MyServer } from './MyServer';
+import { binaryDecode, getTime } from '../Utils';
+import { ApiMsgEnum, IModel } from '../Common';
+import { binaryEncode } from '../Common/Binary';
 
 export enum ConnectionEventEnum {
   Close = 'Close',
 }
 
-export default class Connection extends EventEmitter {
+export class Connection extends EventEmitter {
   server: MyServer
   ws: WebSocket
-  msgMap: Map<string, Function[]> = new Map()
+  msgMap: Map<ApiMsgEnum, Function[]> = new Map()
   playerId?: number;
 
   constructor(server: MyServer, ws: WebSocket) {
@@ -24,10 +25,12 @@ export default class Connection extends EventEmitter {
     })
 
     this.ws.on('message', (buffer: Buffer) => {
-      const str = buffer.toString()
+      // const str = buffer.toString()
       try {
-        const { name, data } = JSON.parse(str)
-        console.log(`${getTime()}接收|${this.playerId || -1}|${str}`)
+        const json = binaryDecode(buffer)
+        const { name, data } = json
+        // console.log(`${getTime()}接收|字节数${buffer.length}|${this.playerId || -1}|${str}`)
+        console.log(`${getTime()}接收|字节数${buffer.length}|${this.playerId || -1}|${JSON.stringify(json)}`)
         if (this.server.apiMap.has(name)) {
           try {
             const cb = this.server.apiMap.get(name)
@@ -49,7 +52,8 @@ export default class Connection extends EventEmitter {
           this.msgMap.get(name)?.forEach(cb => cb(data))
         }
       } catch (error) {
-        console.log(`解析失败，${str}不是合法的JSON格式：`, error)
+        // console.log(`解析失败，${str}不是合法的JSON格式：`, error)
+        console.log(error)
       }
     })
   }
@@ -74,7 +78,9 @@ export default class Connection extends EventEmitter {
       name,
       data
     })
-    console.log(`${getTime()}发送|${this.playerId || -1}|${msg}`)
-    this.ws.send(msg)
+    const view = binaryEncode(name, data)
+    const buffer = Buffer.from(view.buffer)
+    console.log(`${getTime()}发送|字节数${buffer.length}|${this.playerId || -1}|${msg}`)
+    this.ws.send(buffer)
   }
 }

apps/server/src/core/index.ts

@@ -1,71 +1,2 @@
-import { EventEmitter } from 'stream';
-import WebSocket, { WebSocketServer } from 'ws';
-import Connection, { ConnectionEventEnum } from './Connection';
-
-export interface IMyServerOptions {
-  port: number
-}
-
-export type IData = Record<string, any>
-
-export interface ICallApiRet {
-  success: boolean;
-  error?: Error;
-  res?: IData
-}
-
-export enum MyServerEventEnum {
-  Connect = 'Connect',
-  DisConnect = 'DisConnect',
-}
-
-export default class MyServer extends EventEmitter {
-  wss?: WebSocketServer
-  port: number
-  connections: Set<Connection> = new Set()
-  apiMap: Map<string, Function> = new Map()
-
-  constructor({ port = 8080 }: Partial<IMyServerOptions>) {
-    super()
-    this.port = port
-  }
-
-  start() {
-    return new Promise((resolve, reject) => {
-      this.wss = new WebSocketServer({ port: this.port });
-      this.wss.on('connection', this.handleConnect.bind(this));
-
-      this.wss.on("error", (e) => {
-        reject(e)
-      })
-
-      this.wss.on("close", () => {
-        console.log("MyServer 服务关闭");
-      })
-
-      this.wss.on("listening", () => {
-        resolve(true)
-      })
-    })
-
-  }
-
-  handleConnect(ws: WebSocket) {
-    //初始化
-    const connection = new Connection(this, ws)
-
-    //向外告知有人来了
-    this.connections.add(connection)
-    this.emit(MyServerEventEnum.Connect, connection)
-
-    //向外告知有人走了
-    connection.on(ConnectionEventEnum.Close, (code: number, reason: string) => {
-      this.connections.delete(connection)
-      this.emit(MyServerEventEnum.DisConnect, connection, code, reason)
-    })
-  }
-
-  setApi(apiName: string, cb: Function) {
-    this.apiMap.set(apiName, cb)
-  }
-}
+export * from './MyServer'
+export * from './Connection'

apps/server/src/index.ts

@@ -1,7 +1,6 @@
-import MyServer, { MyServerEventEnum } from './Core';
+import { Connection, MyServer, MyServerEventEnum } from './Core';
 import PlayerManager from './Biz/PlayerManager';
 import RoomManager from './Biz/RoomManager';
-import Connection from './Core/Connection';
 import { getTime, symlinkCommon } from './Utils';
 import { ApiMsgEnum, IApiGameStartReq, IApiGameStartRes, IApiPlayerJoinReq, IApiPlayerJoinRes, IApiPlayerListReq, IApiPlayerListRes, IApiRoomCreateReq, IApiRoomCreateRes, IApiRoomJoinReq, IApiRoomJoinRes, IApiRoomLeaveReq, IApiRoomLeaveRes, IApiRoomListReq, IApiRoomListRes, IModel } from './Common';
 

apps/server/src/utils/index.ts

@@ -1,5 +1,6 @@
 import fs from 'fs-extra'
 import path from 'path'
+import { ApiMsgEnum, InputTypeEnum, strdecode } from '../Common'
 
 export const getTime = () => new Date().toLocaleString().split("├")[0]
 
@@ -34,4 +35,79 @@ export const copyCommon = async () => {
   // copy
   await fs.copy(src, dst)
   console.log('同步成功！')
+}
+
+export const binaryDecode = (buffer: Buffer) => {
+  let index = 0
+  const type = buffer.readUint8(index++)
+
+  if (type === ApiMsgEnum.MsgClientSync) {
+    const inputType = buffer.readUint8(index++)
+    if (inputType === InputTypeEnum.ActorMove) {
+      const id = buffer.readUint8(index++)
+      const directionX = buffer.readFloatBE(index)
+      index += 4
+      const directionY = buffer.readFloatBE(index)
+      index += 4
+      const dt = buffer.readFloatBE(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.ActorMove,
+          id,
+          direction: {
+            x: directionX,
+            y: directionY,
+          },
+          dt
+        }
+      }
+
+      return msg
+    } else if (inputType === InputTypeEnum.WeaponShoot) {
+      const id = buffer.readUint8(index++)
+      const positionX = buffer.readFloatBE(index)
+      index += 4
+      const positionY = buffer.readFloatBE(index)
+      index += 4
+      const directionX = buffer.readFloatBE(index)
+      index += 4
+      const directionY = buffer.readFloatBE(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.WeaponShoot,
+          id,
+          position: {
+            x: positionX,
+            y: positionY,
+          },
+          direction: {
+            x: directionX,
+            y: directionY,
+          },
+        }
+      }
+
+      return msg
+    } else {
+      const dt = buffer.readFloatBE(index)
+      index += 4
+      const msg = {
+        name: ApiMsgEnum.MsgClientSync,
+        data: {
+          type: InputTypeEnum.TimePast,
+          dt,
+        }
+      }
+      return msg
+    }
+  } else {
+    return {
+      name: type,
+      data: JSON.parse(strdecode(new Uint8Array(buffer.slice(1))))
+    }
+  }
 }

test.js

@@ -1,2 +1,30 @@
-const a = new Date()
-console.log(a.toLocaleString().split("├")[0]);
+const msg = JSON.stringify({
+  a: 123,
+  b: true,
+  c: "456"
+})
+
+const strencode = (str) => {
+  let byteArray = [];
+  for (let i = 0; i < str.length; i++) {
+    let charCode = str.charCodeAt(i);
+    if (charCode <= 0x7f) {
+      byteArray.push(charCode);
+    } else if (charCode <= 0x7ff) {
+      byteArray.push(0xc0 | (charCode >> 6), 0x80 | (charCode & 0x3f));
+    } else if (charCode <= 0xffff) {
+      byteArray.push(0xe0 | (charCode >> 12), 0x80 | ((charCode & 0xfc0) >> 6), 0x80 | (charCode & 0x3f));
+    } else {
+      byteArray.push(0xf0 | (charCode >> 18), 0x80 | ((charCode & 0x3f000) >> 12), 0x80 | ((charCode & 0xfc0) >> 6), 0x80 | (charCode & 0x3f));
+    }
+  }
+  return byteArray;
+}
+
+var arr = strencode(msg)
+var buffer = Buffer.from(msg)
+
+console.log(buffer)
+for (let i = 0; i < arr.length; i++) {
+  console.log(buffer[i], arr[i]);
+}