update

.gitignore

@@ -158,3 +158,5 @@ Thumbs.db
 #//////////////////////////
 
 .vscode/
+
+apps/client/assets/Scripts/Common

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

@@ -4,7 +4,7 @@ import { ApiMsgEnum, EntityTypeEnum, IActor, InputTypeEnum, IVec2 } from '../../
 import { EntityStateEnum } from '../../Enum';
 import DataManager from '../../Global/DataManager';
 import NetworkManager from '../../Global/NetworkManager';
-import { rad2Angle } from '../../Utils';
+import { rad2Angle, toFixed } from '../../Utils';
 import { WeaponManager } from '../Weapon/WeaponManager';
 import { PlayerStateMachine } from './ActorStateMachine';
 const { ccclass } = _decorator;
@@ -61,13 +61,15 @@ export class ActorManager extends EntityManager implements IActor {
 
         const { x, y } = DataManager.Instance.jm.input
         NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
+            input: {
                 type: InputTypeEnum.ActorMove,
                 id: this.id,
                 direction: {
-                x,
+                    x: toFixed(x),
-                y
+                    y: toFixed(y),
                 },
-            dt
+                dt: toFixed(dt)
+            }
         })
     }
 

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

@@ -5,6 +5,7 @@ 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
 
@@ -61,16 +62,18 @@ 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: pointStagePos.x,
+          x: toFixed(pointStagePos.x),
-        y: pointStagePos.y
+          y: toFixed(pointStagePos.y),
         },
         direction: {
-        x: directionVec2.x,
+          x: toFixed(directionVec2.x),
-        y: directionVec2.y
+          y: toFixed(directionVec2.y),
         },
+      }
     })
   }
 }

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

@@ -22,6 +22,10 @@ export default class NetworkManager extends Singleton {
 
   connect() {
     return new Promise((resolve, reject) => {
+      if (this.isConnected) {
+        resolve(true)
+        return
+      }
       this.ws = new WebSocket(`ws://localhost:${this.port}`)
       this.ws.onopen = () => {
         console.log("ws onopen")

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

@@ -7,7 +7,8 @@ import { PrefabPathEnum, TexturePathEnum } from '../Enum';
 import NetworkManager from '../Global/NetworkManager';
 import ObjectPoolManager from '../Global/ObjectPoolManager';
 import { BulletManager } from '../Entity/Bullet/BulletManager';
-import { EntityTypeEnum, InputTypeEnum } from '../Common';
+import { ApiMsgEnum, EntityTypeEnum, IMsgServerSync, InputTypeEnum } from '../Common';
+import { toFixed } from '../Utils';
 
 const { ccclass } = _decorator;
 
@@ -26,6 +27,7 @@ export class BattleManager extends Component {
         await this.loadRes()
         this.initScene()
         await this.connectServer()
+        NetworkManager.Instance.listenMsg(ApiMsgEnum.MsgServerSync, this.handleSync);
         this.isInited = true
     }
 
@@ -84,6 +86,12 @@ export class BattleManager extends Component {
         map.setParent(this.stage)
     }
 
+    handleSync({ inputs }: IMsgServerSync) {
+        for (const input of inputs) {
+            DataManager.Instance.applyInput(input)
+        }
+    }
+
     update(dt: number) {
         if (!this.isInited) {
             return
@@ -108,9 +116,11 @@ export class BattleManager extends Component {
     }
 
     tickGlobal(dt: number) {
-        DataManager.Instance.applyInput({
+        NetworkManager.Instance.sendMsg(ApiMsgEnum.MsgClientSync, {
+            input: {
                 type: InputTypeEnum.TimePast,
-            dt
+                dt: toFixed(dt),
+            }
         })
     }
 

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

@@ -9,3 +9,4 @@ 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

apps/server/src/Common/Msg.ts

@@ -1,5 +1,5 @@
 import { IPlayer, IRoom } from "./Model"
-import { IState } from "./State"
+import { IClientInput, IState } from "./State"
 
 export interface IMsgPlayerList {
   list: Array<IPlayer>
@@ -21,3 +21,11 @@ export interface IMsgGameStart {
 export interface IMsgGameStart {
   state: IState
 }
+
+export interface IMsgClientSync {
+  input: IClientInput
+}
+
+export interface IMsgServerSync {
+  inputs: Array<IClientInput>
+}

apps/server/src/biz/Room.ts

@@ -1,4 +1,4 @@
-import { ApiMsgEnum, EntityTypeEnum, IState } from '../Common'
+import { ApiMsgEnum, EntityTypeEnum, IClientInput, IState } from '../Common'
 import type Player from './Player'
 import PlayerManager from './PlayerManager'
 import RoomManager from './RoomManager'
@@ -11,7 +11,7 @@ export default class Room {
     this.id = rid
   }
 
-  private inputs = []
+  private inputs: Array<IClientInput> = []
 
   join(uid: number) {
     const player = PlayerManager.Instance.getPlayerById(uid)
@@ -69,12 +69,26 @@ export default class Room {
       })
     }
     this.listenPlayer()
+    setInterval(() => {
+      this.syncInput()
+    }, 300)
   }
 
   listenPlayer() {
     for (const player of this.players) {
-      player.connection.listenMsg(ApiMsgEnum.MsgClientSync, () => { }
+      player.connection.listenMsg(ApiMsgEnum.MsgClientSync, ({ input }) => {
-      )
+        this.inputs.push(input)
+      })
+    }
+  }
+
+  syncInput() {
+    const inputs = this.inputs
+    this.inputs = []
+    for (const player of this.players) {
+      player.connection.sendMsg(ApiMsgEnum.MsgServerSync, {
+        inputs
+      })
     }
   }
 }

apps/server/src/common/index.ts

@@ -1,6 +1,6 @@
 import { IApiGameStartReq, IApiGameStartRes, IApiPlayerJoinReq, IApiPlayerJoinRes, IApiPlayerListReq, IApiPlayerListRes, IApiRoomCreateReq, IApiRoomCreateRes, IApiRoomJoinReq, IApiRoomJoinRes, IApiRoomLeaveReq, IApiRoomLeaveRes, IApiRoomListReq, IApiRoomListRes } from './Api'
 import { ApiMsgEnum } from './Enum'
-import { IMsgGameStart, IMsgPlayerList, IMsgRoom, IMsgRoomList } from './Msg'
+import { IMsgClientSync, IMsgGameStart, IMsgPlayerList, IMsgRoom, IMsgRoomList, IMsgServerSync } from './Msg'
 import { IClientInput } from './State'
 export * from './Api'
 export * from './Msg'
@@ -44,8 +44,8 @@ export interface IModel {
     [ApiMsgEnum.MsgRoomList]: IMsgRoomList,
     [ApiMsgEnum.MsgRoom]: IMsgRoom,
     [ApiMsgEnum.MsgGameStart]: IMsgGameStart,
-    [ApiMsgEnum.MsgClientSync]: IClientInput,
+    [ApiMsgEnum.MsgClientSync]: IMsgClientSync,
-    [ApiMsgEnum.MsgServerSync]: IMsgGameStart,
+    [ApiMsgEnum.MsgServerSync]: IMsgServerSync,
   }
 }
 

apps/server/src/core/Connection.ts

@@ -54,7 +54,7 @@ export default class Connection extends EventEmitter {
     })
   }
 
-  listenMsg(name: string, cb: Function) {
+  listenMsg<T extends keyof IModel['msg']>(name: T, cb: (args: IModel['msg'][T]) => void) {
     if (this.msgMap.has(name)) {
       this.msgMap.get(name)?.push(cb)
     } else {
@@ -62,7 +62,7 @@ export default class Connection extends EventEmitter {
     }
   }
 
-  unlistenMsg(name: string, cb: Function) {
+  unlistenMsg<T extends keyof IModel['msg']>(name: T, cb: (args: IModel['msg'][T]) => void) {
     if (this.msgMap.has(name)) {
       const index = this.msgMap.get(name)?.indexOf(cb) || -1
       index > -1 && this.msgMap.get(name)?.splice(index, 1)