? ? ??ESB全稱Enterprise Service Bus，即企業服務總線。它是傳統中間件技術與XML、Web服務等技術結合的產物。

?ESB的出現改變了傳統的軟件架構，能夠提供比傳統中間件產品更為便宜的解決方式。同一時候它還能夠消除不同應用之間的技術差異，讓不同的應用server協調運作，實現了不同服務之間的通信與整合。

? 看吧，ESB的功能是如此強大。

在java中經常使用的是Mule ESB。而到了.Net，Shuttle ESB作為一種新生的ESB正在慢慢的被人們所接受。以下通過一個實例解說Shuttle ESB的創建過程及推送原理。

? 1.我們須要引入Shuttle ESB相關的類庫-Shuttle.Core.Data、Shuttle.Core.Domain、Shuttle.Core.Host、Shuttle.Core.Infranstructure、Shuttle.ESB.Core、Shuttle.ESB.Msmq、Shuttle.ESB.SqlServer。為了保證版本號統一，我們能夠在VS中安裝NuGet插件下載Shuttle ESB須要的類庫；

? 2.在Pub端加入Shuttle ESB配置文件app.config，Shuttle ESB通過配置文件讀取數據庫內容。獲得須要推送數據的Sub端工作隊列Uri及Sub端能夠接受的消息類型，配置內容例如以下：

<?xml version="1.0"?> <configuration><configSections><section name="serviceBus" type="Shuttle.ESB.Core.ServiceBusSection, Shuttle.ESB.Core"/><section name="sqlServer" type="Shuttle.ESB.SqlServer.SqlServerSection, Shuttle.ESB.SqlServer"/></configSections><appSettings><add key="SubscriptionManagerSecured" value="false"/></appSettings><connectionStrings><clear/><add name="SubscriptionConnection" connectionString="Uid=sa;Pwd=123456;Initial Catalog=shuttle;Data Source=172.22.51.180;Connect Timeout=900" providerName="System.Data.SqlClient"/></connectionStrings><sqlServer subscriptionManagerConnectionStringName="SubscriptionConnection"/> <serviceBus><inboxworkQueueUri="msmq://./pubsub-publish-inbox-work"deferredQueueUri="msmq://./pubsub-publish-inbox-deferred"errorQueueUri="msmq://./shuttle-pubsub-error"/></serviceBus> <startup><supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/></startup> </configuration>? ? ? ??3.在Pub端啟一個Bus。用于推送數據： //連接數據庫new ConnectionStringService().Approve();//配置信息subscriptionManager = SubscriptionManager.Default();//創建 消息通道bus = ServiceBus.Create(c => c.SubscriptionManager(subscriptionManager)).Start();Console.WriteLine();ColoredConsole.WriteLine(ConsoleColor.Green, "Server bus started. Press CTRL+C to stop.");? ? ? ? ?Bus創建完畢后。通過bus.Publish方法完畢向Sub端的消息推送。

? 4.在Sub端加入Shuttle ESB配置文件app.config，Shuttle ESB通過配置文件向數據庫寫入當前Sub端能夠接收的消息類型及當前工作隊列的Uri。

Pub端通過Sub端寫入到數據庫的消息類型和工作隊列Uri推斷是否向某一Sub端發送某種類型的數據，Sub端的配置文件例如以下：

<?xml version="1.0"?

> <configuration> <configSections> <section name="serviceBus" type="Shuttle.ESB.Core.ServiceBusSection, Shuttle.ESB.Core"/> </configSections> <connectionStrings> <clear/> <add name="Subscription" connectionString="Uid=sa;Pwd=123456;Initial Catalog=shuttle;Data Source=172.22.51.180;Connect Timeout=900" providerName="System.Data.SqlClient"/> </connectionStrings> <serviceBus> <inbox workQueueUri="msmq://./pubsub-subscriber1-inbox-work" errorQueueUri="msmq://./shuttle-pubsub-error"/> </serviceBus> <startup><supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/></startup> </configuration>

? ? 5.在Sub端啟一個Bus用于接收Pub端推送的數據。 //連接數據庫new ConnectionStringService().Approve();//配置信息subscriptionManager = SubscriptionManager.Default();/** 配置接收消息的類型：* 風報警解除、雨報警解除、雪報警解除、異物報警解除、地震報警解除* * 遠程實驗三個實體*/subscriptionManager.Subscribe(new[] { typeof(WindInfoAlarmEntity).FullName, typeof(RainInfoAlarmEntity).FullName, typeof(SnowInfoAlarmEntity).FullName,typeof(FreignMatterAlarmEntity).FullName,typeof(EarthquakeAlarmEntity).FullName,typeof(String).FullName});//創建 消息通道bus = ServiceBus.Create(c => c.SubscriptionManager(subscriptionManager)).Start();Console.WriteLine();ColoredConsole.WriteLine(ConsoleColor.Green, "Server bus started. Press CTRL+C to stop.");? ? ? ??在Bus中說明，當前Sub端能夠處理的數據類型，比方WindInfoAlarmEntity類型、String類型。

? 6.在Sub端建立相應的handler，通過泛型限制接收不同類型的數據推送。處理String類型的handler例如以下：

using System; using System.Collections.Generic; using System.Linq; using System.Text; using Shuttle.ESB.Core; using Shuttle.Core.Infrastructure; using ICT.MainFramework.ViewEntity; using ICT.RCS.Server.ESB; namespace PublishSubscribe.Subscriber1 {public class WindRainSnowStrHandler : IMessageHandler<String>{public void ProcessMessage(HandlerContext<String> context){string strType = context.Message.Split('#')[0].ToString();//ESB接收處理消息MessageTransfer.transferDataToEntity(MainServerForm.bus, context.Message);}public bool IsReusable{get { return true; }}} } ? ? ? ? ?為了解決離線數據推送。Shuttle ESB用MSMQ作為消息隊列。將待處理的消息緩存到MSMQ中。
? 到此Shuttle ESB的Pub端和Sub端創建完成，執行效果為Pub端通過bus公布一個消息后，局域網內已經在數據庫的工作隊列Uri中注冊過，且符合對應消息類型的Sub端均能夠接收到Pub端公布的消息，觀察者模式的完美運用。

? Shuttle ESB的原理明確了。Mule ESB、JBoss ESB也就一看就懂。

? 希望我的解說能幫助大家進一步認識Shuttle ESB。 ?

總結

以上是生活随笔為你收集整理的Shuttle ESB实现消息推送的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。