天天看點

分享一個分布式消息總線,基于.NET Socket Tcp的釋出-訂閱架構,附代碼下載下傳一、分布式消息總線二、基于Socket的實作三、實作一個簡單的例子四、驗證效果五、源代碼下載下傳六、問題回報

     在很多MIS項目之中都有這樣的需求,需要一個及時、高效的的通知機制,即比如當使用者A完成了任務X,就需要立即告知使用者B任務X已經完成,在通常的情況下,開發人中都是在使用者B所使用的程式之中寫資料庫輪循代碼,這樣就會産品一個很嚴重的兩個問題,第一個問題是延遲,輪循機制要定時執行,必須會引起延遲,第二個問題是資料庫壓力過大,當進行高頻度的輪循會生産大量的資料庫查詢,并且如果有大量的使用者進行輪循,那資料庫的壓力就更大了。

     那麼在這個時間,就需要一套能支援釋出-訂閱模式的分布式消息總線,那這個問題就可以很好的解決了,比如采用一些成熟的消息總線進行實作,比如MSMQ或者采用比如開源的NServiceBus的釋出訂閱機制就可以實作處理這種需求,其系統結構就會變成如下所示:

分享一個分布式消息總線,基于.NET Socket Tcp的釋出-訂閱架構,附代碼下載下傳一、分布式消息總線二、基于Socket的實作三、實作一個簡單的例子四、驗證效果五、源代碼下載下傳六、問題回報

    本分布式消息總線,目前廣泛的被應用于分布式緩存的更新通知,當在N百台客戶短在使用緩存的過程之中,某個操作修改了緩存的資料,必須會導緻其他終端緩存的失效,那麼使用基于Socket的分布式消息總線之後,我們可以做了修改了即可實時通知,做到緩存資料保持最新,再比如醫療應用之中的危急值管理,當發現檢驗、檢查危急值之後,需要及時通知病區啟動聲光報警系統等,提醒醫護從業人員及相關上司做出相應的措施,再比如應用于異構系統整合,當檢驗系統做出檢驗報告,通過消息總線進行釋出,HIS系統則即時會收到檢驗報告資料而實作系統的整合。

     目前能夠實作釋出訂閱模式的開源産品非常之多,為什麼還要制造輪子呢,其主要原因有以下幾點

     1)像NServiceBus這種東西基于MSMQ,在大量的釋出者-訂閱者的情況下性能不佳。

     2)此類東西太過于龐大、不易使用和配置。

     3)學習成本過高。

     那為什麼要使用Socket技術進行實作呢,其主要原因是有以下幾點:

     1)使用高效的Socket通信技術,高效、支援更多的用戶端。

     2)使用簡單,不需要定義太多額外的東西,隻需要定義主題和消息即可使用。

     目前本釋出訂閱架構并直接內建于AgileEAS.NET SOA Socket通信架構之中并且随其一并釋出,下面簡單介紹一下其API:

在本架構之中定義了一個消息總線接口IMessageBus:

    IMessageBus就基于Socket釋出訂閱消息總線的靈魂接口,也是基唯一的釋出者調用者功能入口,也就是說不管你是釋出者還是訂閱者都需要調用這個接口,如果你是釋出者請調用IMessageBus接口的Publish方法向消息總線釋出消息,如果是你訂閱者請通過IMessageBus的訂閱方法進行訂閱,當你訂閱了某個主題之後,有釋出者釋出該主題的消息,你即可以收到消息并調用訂閱回調函數進行處理。

     現在我們開始一個簡單的應用消息總線的例子,本例子代碼解決方案由下圖4個項目組成:

分享一個分布式消息總線,基于.NET Socket Tcp的釋出-訂閱架構,附代碼下載下傳一、分布式消息總線二、基于Socket的實作三、實作一個簡單的例子四、驗證效果五、源代碼下載下傳六、問題回報

     其中:Demo.Messages項目定義釋出者、訂閱者所使用的消息對象和消息主題。

                Demo.Publisher項目為釋出者代碼。

                Demo.Subscriber項目為訂閱者代碼。

                Demo.Server項目為服務端代碼。

     在Demo.Messages項目之中,我們定義了一個消息Message:

     消息Message很簡單,隻有一個屬性ID,同時 還需要定義一個消息主題:

     我們定義了一個消息主題為“示範消息”。

     在Demo.Publisher項目之中,沒有太多額外的代碼,隻有在Program.cs寫了以下簡單的調用代碼:

     從IOC容器擷取一個消息總線IMessageBus對象,并調用Publish函數釋出消息”bus.Publish(Demo.Messages.Topics.DEMO_TOPIC, m);“。

     當然了,使用了IOC容器,就離來開配置檔案了,其App.config檔案内容如下:

     在Demo.Subscriber項目之中,使用與Demo.Publisher一模一樣的配置檔案,其Program.cs代碼如下:

     其中代碼bus.Subscribe(new Program(), "Subscriber1", Demo.Messages.Topics.DEMO_TOPIC, MessageNotify);:完成把消息訂閱到MessageNotify通知函數之中。

     在Demo.Server項目之中,啟動伺服器并且開始接收訂閱和釋出:

     到此為止,所有代碼均已完成,是不是很簡單,接下來,我們跑起來驗證一下效果。

     我們在編譯輸入目錄Publish下先啟動Demo.Server.exe,再啟動兩個Demo.Subscriber.exe,再啟動一個Demo.Publisher.exe,在Demo.Publisher.exe控制台按Enter鍵:

分享一個分布式消息總線,基于.NET Socket Tcp的釋出-訂閱架構,附代碼下載下傳一、分布式消息總線二、基于Socket的實作三、實作一個簡單的例子四、驗證效果五、源代碼下載下傳六、問題回報

OK,搞定。

     麻煩大家在通過視訊進行學習的時候能及時把問題回報給樓主,或者有什麼需要改進的一些建議都請向樓主直接回報,以下是聯系方式:

樓主QQ:47920381,AgileEAS.NET

QQ群:113723486(AgileEAS SOA 平台)/上限1000人

199463175(AgileEAS SOA 交流)/上限1000人

120661978(AgileEAS.NET 平台交流)/上限1000人

郵件:[email protected],[email protected],

電話:18629261335。