2 {
3 RentStreamResultRentTcpStream( int poolTypeKey, int serviceKey, out NetworkStreamstream, out int serverID); // poolTypeKey表示某個城市，serviceKey表示某項服務
4 void GiveBackTcpStream( int streamHashCode, int serverID); // 將tcp連接規還給連接池
5 void SetStreamDamaged( int streamHashCode, int serverID); // poolKey如果不易保存，則此處簡單的傳-1即可
6
7 event CallBackCountChangedActiveConnectionCountChanged;
8 event CallBackPoolStateChangedPoolStateChanged;
9 }
10
RentTcpStream 方法中的 serviceKey 參數反映了這樣一個事實：與一個 AS 相連的多個 FS 中，每個 FS 加載的功能插件可以是不一樣的。
比如，上圖中的
3
個
FS
中只有
FS1
加載了前面介紹的“天氣預測服務”插件，那么當一個“天氣預測服務”請求到達
AS
時，
AS
就只能從與
FS1
之間的連接池中
Rent
一個
Tcp
連接，而不是從
FS2
或
FS3
。
RentTcpStream
方法的
out
參數
serverID
表明了這條連接是指向哪個
FS
的。
接下來考慮這樣一個問題，當一個請求到來，這個請求可以被
FS1
、
FS2
、
FS3
處理，那么ITcpPoolsManager
到底返回哪個連接池中的連接了？答案是負載最小的那個
FS
上的連接。
這是怎么做到的了？其實很簡單。每個
FS
都定時（比如一秒一次）地把自己的負載（
CPU
利用率和內存利用率）通知給
AS
，通知給
AS
的方式可以有多種，比如
.Net Remoting
。
ESFramework
中有一個稱為連接池調度器
ITcpPoolScheduler
的東東，它記錄了每個
FS
實時的負載。這樣當一個請求到來時，連接池管理器ITcpPoolsManager會要求連接池調度器從眾多的
FS
中選出一個“滿足條件”且負載最小的
FS
。這里的“滿足條件”主要指的是對應的
FS
上有能處理該請求的功能插件。實現這種調度需要的支持的各個相互協作的組件的聯系圖大致如下：
圖中 I ServerPerfo rmanceMonitor 是用于監控本地服務器性能的組件，它可以定時發布本服務器的性能數據（主要是 CPU 利用率和內存利用率），其定義如下：
2 {
3 void Start();
4 void Stop();
5
6 int RefreshSpanSecs{ get ; set ;}
7
8 event CBackServerPerformanceServerPerformanceDataRefreshed;
9 }
11
12 public delegate void CBackServerPerformance(ServerPerformanceperformance);
13 public class ServerPerformance
14 {
15 public float CpuUsagePercent;
16 public float MemoryUsagePercent;
17 }
連接池調度器
ITcpPoolScheduler
的定義如下：
2 {
3 // 以下方法屬性僅僅由多連接池管理者調用
4 int GetNextTcpPool( int poolTypeKey); // 返回的是某連接池的服務端點的serverID，如果沒有可用的返回-1
5 int GetNextTcpPool( int poolTypeKey, int serviceKey);
6
7 void Initialize();
8 void Dispose(); // 還原到未初始化的狀態
9 void SetServerState( int serverID, bool activated);
10 void AddServer( int serverID);
11 void RemoveServer( int serverID);
12
13
14 // 以下方法屬性由外部指定或調用
15 void SetPerformance( int serverID, float cpuUsage, float memUsage);
16 ITcpPoolHelperTcpPoolHelper{ set ;}
17 }
為了使負載均衡的效果更好， ITcpPoolScheduler 可以實現的非常復雜，比如進行歷史記錄統計、分析、預測等。 ESFramework 給出了默認實現 TcpPoolScheduler 。
在組件聯系圖中還有一個IPoolEndPointsDisplayer
組件，它用于在
UI
上顯示每個功能服務器的詳細信息和性能數據。
2 {
3 void RegisterFs( int serverID, string serverName,IPEndPointipe, int exceptCount);
4 void UnRegisterFs( int serverID);
5 void SetFsState( int serverID, bool activated);
6 void SetActiveCount( int serverID, int activeCount);
7 void UpdateFsPerformance( int serverID, float cpuUsage, float memUsage);
8 void Clear();
9 }
FS
管理器管理連接上本
AS
的每個功能服務器，這將在后文中講到。
除了
ITcpPool
接口，連接池管理器還實現了
ITcpPoolsManager
接口：
2 {
3 string TcpPoolSchedulerTypeString{ set ;} // "ESFramework.Network.TcpPool.TcpPoolScheduler,ESFramework"
4 ArrayListPoolEndPointList{ set ;} // 連接池的服務端PoolEndPointInfo列表
5 int ReconnectSpan{ get ; set ;} // 分鐘
6
7 void Initialize(); // 初次建立連接池
8 void Dispose(); // 還原到沒有初始化的狀態
9 void AddPool(PoolEndPointInfoinfo);
10 void RemovePool( int serverID);
11
12 void DisposePoolConnections( int serverID); // 編號為serverID的服務器已停止，所以釋放對應的Pool，但是不刪除池，仍然定時重連
13 void ReconnectPool( int serverID); // 曾停止的服務器已啟動完畢，所以可以重連了
14
15 /// <summary>
16 /// 可直接使用ESFramework.Network.TcpPool.PoolEndPointsDisplayer
17 /// </summary>
18 IPoolEndPointsDisplayerPoolEndPointsDisplayer{ set ;}
19
20 // 由ITcpPoolScheduler使用
21 void SetPerformance( int serverID, float cpuUsage, float memUsage);
22 ITcpPoolHelperTcpPoolHelper{ set ;} // 可由ESFramework.Architecture.LBS.FourTier.FsManager提供
23 }
AddPool 方法和 RemovePool 方法表明可以動態的添加 / 移除 Tcp 連接池。注意接口中的 SetPerformance 方法，這個方法將被 FS 管理器調用，用于把從 Remoting 接收到的 FS 的性能數據通知給 ITcpPoolsManager ，然后 ITcpPoolsManager 再把這些數據提交給 ITcpPoolScheduler 記錄，當需要進行調度的時候， ITcpPoolScheduler 從這些記錄中進行分析計算并找到負載最小的 FS 。 TcpPoolSchedulerTypeString 屬性用于向連接池管理器提供調度者的實際類型，管理器將會通過反射創建調度者的實例。
還有一個需要設置的屬性
ITcpPoolHelper
：
2 {
3 bool ContainsService( int serverID, int serviceKey);
4 bool ServerIsTheType( int serverID, int destType);
5 bool ServerIsCompatible( int serverID, int destType, int serviceKey);
6 string GetServerNameByID( int serverID);
7 }
由于這個接口提供了每個功能服務器詳細信息，所以這個接口的實現可以直接由前面提到的
FS
管理器順帶實現。
ITcpPoolsManager
是一個比較復雜的組件，它需要涉及到多個組件的協作。所以如果看完這篇文章，仍然還有些不清楚的地方，是很正常的。在后面系列文章的繼續講述中，這些不清晰的地方會慢慢撥開迷霧。
感謝關注！
上篇文章：
ESFramework介紹之（10）－－ Tcp連接池
轉到：
ESFramework 可復用的通信框架（序）
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
