客户端心跳回调实现

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,13 +319,24 @@ public void sendTick()
 			if(!loginappMessageImported_ && !baseappMessageImported_)
 				return;
 
-			TimeSpan span = DateTime.Now - _lastticktime; 
+			TimeSpan span = DateTime.Now - _lastTickTime;
 
 			// 更新玩家的位置与朝向到服务端
 			updatePlayerToServer();
 
 			if(span.Seconds > 15)
 			{
+				span = _lastTickCBTime - _lastTickTime;
+				
+				// 如果心跳回调接收时间小于心跳发送时间，说明没有收到回调
+				// 此时应该通知客户端掉线了
+				if(span.Seconds < 0)
+				{
+					Dbg.ERROR_MSG("sendTick: Receive appTick timeout!");
+					_networkInterface.close();
+					return;
+				}
+
 				Message Loginapp_onClientActiveTickMsg = null;
 				Message Baseapp_onClientActiveTickMsg = null;
 
@@ -349,10 +362,18 @@ public void sendTick()
 					}
 				}
 
-				_lastticktime = System.DateTime.Now;
+				_lastTickTime = System.DateTime.Now;
 			}
 		}
-		
+
+		/*
+			服务器心跳回调
+		*/
+		public void Client_onAppActiveTickCB()
+		{
+			_lastTickCBTime = System.DateTime.Now;
+		}
+
 		/*
 			与服务端握手，与任何一个进程连接之后应该第一时间进行握手
 		*/

MessageReader.cs

@@ -63,6 +63,22 @@ public void process(byte[] datas, MessageLengthEx offset, MessageLengthEx length
 							state = READ_STATE.READ_STATE_MSGLEN;
 							expectSize = 2;
 						}
+						else if(msg.msglen == 0)
+						{
+							// 如果是0个参数的消息，那么没有后续内容可读了，处理本条消息并且直接跳到下一条消息
+							#if UNITY_EDITOR
+							Dbg.profileStart(msg.name);
+							#endif
+
+							msg.handleMessage(stream);
+
+							#if UNITY_EDITOR
+							Dbg.profileEnd(msg.name);
+							#endif
+
+							state = READ_STATE.READ_STATE_MSGID;
+							expectSize = 2;
+						}
 						else
 						{
 							expectSize = (MessageLengthEx)msg.msglen;