up

Author: kbengine

KBEngine.cs

@@ -174,6 +174,7 @@ void installEvents()
 			Event.registerIn("createAccount", this, "createAccount");
 			Event.registerIn("login", this, "login");
 			Event.registerIn("relogin_baseapp", this, "relogin_baseapp");
+			Event.registerIn("_closeNetwork", this, "_closeNetwork");
 		}
 
 		public KBEngineArgs getInitArgs()
@@ -265,14 +266,14 @@ public static bool validEmail(string strEmail)
 		*/
 		public virtual void process()
 		{
+			// 处理网络
+			_networkInterface.process();
+			
 			// 处理外层抛入的事件
 			Event.processInEvents();
 
 			// 向服务端发送心跳以及同步角色信息到服务端
 			sendTick();
-			
-			// 处理网络
-			_networkInterface.process();
 		}
 
 		/*
@@ -287,6 +288,11 @@ public Entity player()
 			return null;
 		}
 
+		public void _closeNetwork(NetworkInterface networkInterface)
+		{
+			networkInterface.close();
+		}
+		
 		/*
 			向服务端发送心跳以及同步角色信息到服务端
 		*/

NetworkInterface.cs

@@ -188,9 +188,8 @@ public bool send(byte[] datas)
 
         public void process()
         {
-        	// 避免close后一些消息没有得到处理，将这里屏蔽
-        	// if(!valid())
-        	//	return;
+        	if(!valid())
+        		return;
 
         	if(_packetReceiver != null)
         		_packetReceiver.process();

PacketReceiver.cs

@@ -119,7 +119,7 @@ public void startRecv()
 			catch (Exception e) 
 			{
 				Dbg.ERROR_MSG("PacketReceiver::startRecv(): call ReceiveAsync() is err: " + e.ToString());
-				_networkInterface.close();
+				Event.fireIn("_closeNetwork", new object[]{_networkInterface});
 			}
 		}
 
@@ -151,7 +151,7 @@ private static void _onRecv(IAsyncResult ar)
 		        	if (bytesRead == 0) 
 		        	{
 		        		Dbg.WARNING_MSG(string.Format("PacketReceiver::_processRecved(): disconnect!"));
-		        		state.networkInterface().close();
+		        		Event.fireIn("_closeNetwork", new object[]{state.networkInterface()});
 		        		return;
 		        	}
 		        	else
@@ -163,7 +163,7 @@ private static void _onRecv(IAsyncResult ar)
 			catch (Exception e) 
 			{
 				Dbg.ERROR_MSG(string.Format("PacketReceiver::_processRecved(): is error({0})!", e.ToString()));
-				state.networkInterface().close();
+				Event.fireIn("_closeNetwork", new object[]{state.networkInterface()});
 			}
 		}
 	}

PacketSender.cs

@@ -118,7 +118,7 @@ void _startSend()
 			catch (Exception e) 
 			{
 				Dbg.ERROR_MSG("PacketSender::startSend(): is err: " + e.ToString());
-				_networkInterface.close();
+				Event.fireIn("_closeNetwork", new object[]{_networkInterface});
 			}
 		}
 
@@ -155,7 +155,7 @@ private static void _onSent(IAsyncResult ar)
 			catch (Exception e) 
 			{
 				Dbg.ERROR_MSG(string.Format("PacketSender::_processSent(): is error({0})!", e.ToString()));
-				state.networkInterface().close();
+				Event.fireIn("_closeNetwork", new object[]{state.networkInterface()});
 				Interlocked.Exchange(ref state._sending, 0);
 			}
 		}