参考资料--mastransit探究初步繁体.doc

MassTransit 探究初步 1.??背景 作为SOA基礎設施，企業服務總線(ESB)是一個具有高分布性、事件驅動服務的SOA架構,是當前企業集成的主流框架。 2.??簡介 網站：// ? MassTransit (MT) is a framework forcreating distributed applications on the .Net platform. MT provides the abilityto subscribe to messages by type and then connect different processing nodesthough message subscriptions building a cohesive mesh of services. ? 主要特性： l? Bus architecture l? Sagas l? Exception management l? Transactions l? Serialization l? Headers l? Consumer lifecycle l? Built on top of Rabbit Mq l? IOC support ? 授權： 基於Apache 2.0，可以使用在任何環境中。 3.??架構 MassTransit在消息隊列（MQ）之上構建了消息總線機制，封裝了對消息隊列的操作，以及其它的組件，比如序列化、日志、Saga、持久化等。 ? 下圖为傳入消息處理管道模型： ? 4.??整體分析 MassTransit的目標是作为消息機制的抽象框架，因此，它本身並不具體實現MQ，而是通過集成其它MQ產品來作为其通信層。目前官方已集成的MQ產品有MSMQ、RabbitMQ。其它非官方補充了ActiveMQ。 MassTransit在MQ之上添加了Sagas、多線程、異常處理、事務、序列化、消息頭（Header）、消息使用者生命周期管理、路由、Rx（Reactive Extension 反應式擴展）集成、NHibernate集成、調試、跟蹤、日志輸出、加密、定時服務等。 5.??特性分析 5.1.? 聲明式配置 MassTransit本身使用了許多優秀的設計，比如對MSMQ、RabbitMQ的使用，通過在Bus構造配置中調用UseMSMQ()或UseRabbitMQ()來聲明式的决定。 5.2.? 通過擴展方法隱藏具體實現 通過分析源碼，可以發現UseXXX函數是通過定義在MassTransit.Transports.MSMQ.dll和MassTransit.Transports.RabbitMq.dll中的擴展方法實現的，這样當用戶引用相應的DLL時，方法調用才會開放给用戶。即用戶選擇具體使用哪種Transport時，是通過引用相應的DLL來决定的。DLL引用入項目後，具體MQ產品特定的配置，函數等方法也附加到了基類對象中。這样可以避免在基類中定義大量子類特定接口 MassTransit所有擴展組件均是采用這種方法，比如日志(Logging)組件。 6.??入門 首先需要定義消息： public class YourMessage { public string Text { get; set; } } 消息總線的創建可以通過Bus類靜態方法Initialize進行，傳入相應的配置方法，如下所示： ? Bus.Initialize(sbc = { sbc.UseMsmq(); sbc.VerifyMsmqConfiguration(); sbc.UseMulticastSubscriptionClient(); sbc.ReceiveFrom(msmq://localhost/test); sbc.Subscribe(subs = { subs.HandlerYourMessage(msg = Console.WriteLine(From bus 1: + msg.Text)); }); }); 初始化好Bus之後，就可以調用Publish方法發布消息了： Bus.Instance.Publish(new YourMessage { Text = Hi }); 在初始化中，通過sbc.Subscribe函數注冊了一個Handler，其作用是在控制台中輸出消息文本。 創建一個控制台應用程序，在main函數中完成初始化和發布，可以在隨後的輸出中看到消息文本。 7.??高級功能使用 7.1.? Subscription Service 参考：?//en/latest/overview/subscriptions.html ? 如果使用的消息隊列不提供訂閱