客户端心跳回调实现

kbengine/kbengine#369

Author: kbengine

KBEngine.cs

@@ -129,7 +129,8 @@ public struct ServerErr
 		// 所有服务端错误码对应的错误描述
 		public static Dictionary<UInt16, ServerErr> serverErrs = new Dictionary<UInt16, ServerErr>(); 
 
-		private System.DateTime _lastticktime = System.DateTime.Now;
+		private System.DateTime _lastTickTime = System.DateTime.Now;
+		private System.DateTime _lastTickCBTime = System.DateTime.Now;
 		private System.DateTime _lastUpdateToServerTime = System.DateTime.Now;
 
 		// 玩家当前所在空间的id， 以及空间对应的资源
@@ -252,7 +253,8 @@ public virtual void reset()
 			_entityIDAliasIDList.Clear();
 			_bufferedCreateEntityMessage.Clear();
 
-			_lastticktime = System.DateTime.Now;
+			_lastTickTime = System.DateTime.Now;
+			_lastTickCBTime = System.DateTime.Now;
 			_lastUpdateToServerTime = System.DateTime.Now;
 
 			spaceID = 0;
@@ -317,7 +319,18 @@ public void sendTick()
 			if(!loginappMessageImported_ && !baseappMessageImported_)
 				return;
 
-			TimeSpan span = DateTime.Now - _lastticktime; 
+			TimeSpan span = _lastTickCBTime - _lastTickTime
+				
+			// 如果心跳回调接收时间小于心跳发送时间，说明没有收到回调
+			// 此时应该通知客户端掉线了
+			if(span.Seconds < 0)
+			{
+				Dbg.ERROR_MSG("sendTick: Receive  appTick  timeout!");
+				networkInterface.close();
+				return;
+			}
+			
+			span = DateTime.Now - _lastTickTime; 
 
 			// 更新玩家的位置与朝向到服务端
 			updatePlayerToServer();
@@ -352,7 +365,15 @@ public void sendTick()
 				_lastticktime = System.DateTime.Now;
 			}
 		}
-		
+
+		/*
+			服务器心跳回调
+		*/
+		public void Client_onAppActiveTickCB()
+		{
+			_lastTickCBTime = System.DateTime.Now;
+		}
+
 		/*
 			与服务端握手，与任何一个进程连接之后应该第一时间进行握手
 		*/