- 1、本文档共15页,可阅读全部内容。
- 2、原创力文档(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
- 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
查看更多
参考资料--mastransit探究初步繁体
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
?
如果使用的消息隊列不提供訂閱
您可能关注的文档
最近下载
- 备战2023年高考语文一轮复习考点微专题(新高考地区专用)考向28 诗歌鉴赏之语言(含详解).docx VIP
- 飞机交易平台及飞机拆解项目可行性研究报告.doc
- 视听语言PPT全套教学课件.pptx
- 健康评估-河南大学-中国大学MOOC慕课答案.pdf
- 初中音乐人音版《七年级上册青年友谊圆舞曲》课件_1.ppt
- 基于Java的小区物业管理系统的设计与实现.docx VIP
- 普通话课件(完整版)教学文案.ppt
- 【清风语文精品课件】2021高中语文《静女》优质课一等奖.pptx
- 某区南1#矿石泊位升级10万吨级散货泊位工程环境影响报告书.pdf
- 2024高中语文教师课程标准考试模拟试卷及参考答案.docx VIP
文档评论(0)