增加代码主页文件

README

@@ -1,4 +1,19 @@
-c++ lib: sudo aptitude install git-core screen cmake build-essential pkg-config libboost1.54-all-dev libprotobuf-dev protobuf-compiler
+ET框架：一个Unity客户端和分布式游戏服务器框架
+
+01.客户端服务端共用代码
+02.服务器使用组件设计，一切皆是组件
+03.单APP设计，各种服务器都是一个同样的App，在启动时根据命令行的AppType，不同的服务器挂载不同的逻辑组件，挂载不同的消息handler，挂载不同的配置
+04.跨平台设计，既可以在windows上跑，也可以在linux上跑，windows用vs开发方便单步调试
+05.框架支持不停服重新加载逻辑dll，也就是服务器热更新
+06.一行配置即可将所有种类服务器集中到一个进程中，开发时，只需要启动一个进程，不用再启动一堆的服务进程
+07.及其方便检查CPU占用和内存泄漏检查，vs自带分析工具，不用再为性能和内存泄漏检查而烦恼
+08.提供及其方便的网络rpc调用，使用async await语法的异步rpc
+09.使用NLog库，打log及其方便，开发时，可以将所有服务器log打到一个文件中，再也不用一个个文件搜索log了
+10.统一使用Mongodb的bson做序列化，消息和配置文件全部都是bson或者json，并且以后使用mongodb做数据库，再也不用做格式转换了。
+11.提供rsync同步工具，可以windows上开发测试完之后，一键同步代码到linux，linux一键编译运行
+12.提供命令行配置工具，配置分布式服务器及其简单
+
+linux工具安装命令: sudo aptitude install git-core screen cmake build-essential pkg-config
 
 Email: egametang@gmail.com
 QQ   : 80081771

Unity/Assets/Scripts/Component/NetworkComponent.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Net.Sockets;
 using Base;
 
 namespace Model
@@ -12,6 +13,20 @@ namespace Model
 		private readonly Dictionary<long, Session> sessions = new Dictionary<long, Session>();
 		private readonly Dictionary<string, Session> adressSessions = new Dictionary<string, Session>();
 
+		private event Action<Session> removeCallback;
+
+		public event Action<Session> RemoveCallback
+		{
+			add
+			{
+				this.removeCallback += value;
+			}
+			remove
+			{
+				this.removeCallback -= value;
+			}
+		}
+
 		protected void Awake(NetworkProtocol protocol)
 		{
 			switch (protocol)
@@ -62,6 +77,12 @@ namespace Model
 		}
 
 		private void Add(Session session)
+		{
+			this.sessions.Add(session.Id, session);
+			this.AddToAddressDict(session);
+		}
+
+		private void AddToAddressDict(Session session)
 		{
 			Session s;
 			if (this.adressSessions.TryGetValue(session.RemoteAddress, out s))
@@ -69,7 +90,6 @@ namespace Model
 				this.Remove(s.Id);
 				Log.Warning($"session 地址冲突, 可能是客户端断开, 服务器还没检测到!: {session.RemoteAddress}");
 			}
-			this.sessions.Add(session.Id, session);
 			this.adressSessions.Add(session.RemoteAddress, session);
 		}
 
@@ -80,6 +100,7 @@ namespace Model
 			{
 				return;
 			}
+			removeCallback.Invoke(session);
 			this.sessions.Remove(id);
 			this.adressSessions.Remove(session.RemoteAddress);
 			session.Dispose();
@@ -92,6 +113,9 @@ namespace Model
 			return session;
 		}
 
+		/// <summary>
+		/// 从地址缓存中取Session,如果没有则创建一个新的Session,并且保存到地址缓存中
+		/// </summary>
 		public Session Get(string address)
 		{
 			Session session;
@@ -100,14 +124,22 @@ namespace Model
 				return session;
 			}
 
+			session = this.GetNew(address);
+			this.AddToAddressDict(session);
+			return session;
+		}
+
+		/// <summary>
+		/// 创建一个新Session,不保存到地址缓存中
+		/// </summary>
+		public Session GetNew(string address)
+		{
 			string[] ss = address.Split(':');
 			int port = int.Parse(ss[1]);
 			string host = ss[0];
 			AChannel channel = this.Service.ConnectChannel(host, port);
-			session = new Session(channel);
+			Session session = new Session(channel);
 			channel.ErrorCallback += (c, e) => { this.Remove(session.Id); };
-			this.Add(session);
-
 			return session;
 		}
 

Unity/Assets/Scripts/Entity/Session.cs

@@ -226,8 +226,8 @@ namespace Model
 			}
 
 			base.Dispose();
-
-			channel.Dispose();
+			
+			this.channel.Dispose();
 		}
 	}
 }