[源]
http://zhuweisky.cnblogs.com/archive/2006/03/17/351925.html前面的兩篇文章我們已經介紹了Tcp連接池和Tcp連接池管理器,并且引入了ITcpPool接口,這個接口可以將單個連接池和一組連接池統一起來,使它們有相同的外部使用方式。現在我們需要考慮的問題是,當消息分派器分派一個接收到的請求時,如果這個請求需要被FS上的某個功能插件處理,那么消息分派器是如何將這個消息分派到對應的FS上去的?
回顧介紹
消息分派器時畫出的各消息組件聯系圖,我們非常自然的想到,創建一個消息處理器,這個消息處理器將請求消息通過Tcp連接池轉發給對應FS處理。這樣的一個消息處理器稱為“基于Tcp連接池的消息處理器”,它在消息組件聯系圖中的位置如下:
當有一個請求被分派到基于連接池的消息處理器時,它就從Tcp連接池中Rent一個NetworkStream,然后發送請求,并將接收到的回復返回給消息分派器?;谶B接池的消息處理器仍然實現了IDataDealer接口,其借助ITcpPool組件來實現功能。下面給出簡單偽碼,因為整個實現比較復雜(錯誤處理、異常處理、ReRent機制等),代碼比較多,所以就不列出來了,大家只要了解了主要的思想就行了,而這個思想是比較簡單的。
public NetMessage DealRequestMessage(NetMessage reqMsg)
{
/*
1.Rent TcpStream
2.Send Request
3.Recieve Response
4.Return Response
*/
}
最后提一句,我們在上圖的AS和FS中都看到了網絡組件,如果AS也采用Tcp,那么這兩個組件是相同的,也就是說Tcp組件可以很方便的復用。
在FS中,Tcp網絡組件和功能插件之間是通過虛線連接起來的,也就是說網絡組件并不會直接與功能插件交互,它們之間仍然存在這一個紐帶,這就是消息處理器工廠,那么用于管理功能插件的工廠,就叫做“功能插件處理器工廠FunAddinDealerFactory”,這將在下文中介紹。
感謝關注!