var bus = BusCreator.CreateBus((cfg, host) => 

 { 

     cfg.ReceiveEndpoint(host, RabbitMqConstants.GreetingEventSubscriberAQueue, e => 

     { 

         e.Consumer<GreetingEventConsumer>(); 

     }); 

 }); 

  

 bus.Start(); 

定义GreetingEventConsumer：

public class GreetingEventConsumer:IConsumer<Greeting.Message.GreetingEvent> 
 { 
     public async Task Consume(ConsumeContext<Greeting.Message.GreetingEvent> context) 
     { 
         await Console.Out.WriteLineAsync($"receive greeting event: id {context.Message.Id}"); 
     } 
 } 

这一代码跟Masstransit.RabbitMQ.GreetingServer接收一个敕令几乎一模一样，独一的差别在于：

在Send/Receive模式中Client起重要获得对方(Server)的终结点(endpoint)，直接向该终结点发送敕令。Server方监听本身的终结抱病花费敕令。

而Publish/Subscribe模式中Client publish一个事宜，SubscriberA在自己的终结点(endpointA)监听事宜，SubscriberB在本身的终结点(endpointB)监听事宜。

3、根据膳绫擎的分析再定义一个Masstransit.RabbitMQ.GreetingEvent.SubscriberB

4、将4个控制台应用法度榜样跑起来看看

六、实现RPC模式

停止酉：本篇文┞仿分析了若何应用Masstransit来抽象营业，避免直接运器具体的消息队列，当然本文提到的浩瀚办事总线机制，如“重试、熔断等”并没有在该文中出现，须要大年夜家进一步去懂得该项目。

这一模式在Masstransit中被称作Request/Response模式，经由过程IRequestClient<IRequest, IResponse> 接口来实现相干操作。一个相干的例子在官方的github。

2、创建办事总线，发送一个敕令：

经由过程对Masstransit的一些试用和NServiceBus的比较，Masstransit在实际项目中很轻易上手并且免费，各类API定义的也异常清楚，然则官方的文档有点过于简单，实际应用中还须要去做深刻的研究。作为.NET平台下为数不多的ESB开源产品，其存眷程度照样不敷，等待大年夜家为开源项目做出供献。

作者：Richie Zhang 来源：http://www.cnblogs.com/richieyang/

【编辑推荐】

1. Facebook“天网筹划” Internet.org背后的机密
2. MIT 提出Network Dissection框架，全主动窥测神经收集练习的黑箱
3. 推荐体系重要算法总结及Youtube深度进修推荐算法实例概括
4. Java开辟操作体系内核：实现过程的优先级切换
5. 手把手教你搭建PHP版RabbitMQ消息队列开辟情况及Demo实践

【义务编辑：张子龙 TEL：（010）68476606】

　　推荐阅读

　　CVPR 2017论文解读：特征金字塔网络FPN

论文：Feature Pyramid Networks for Object Detection论文地址：https://arxiv.org/abs/1612.03144这里介绍的文┞仿是来自 Facebook 的特点金字塔收集 Feature Pyramid Networks(FPN)。F>>>详细阅读

本文标题：如何优雅的使用RabbitMQ

地址：http://www.17bianji.com/lsqh/36412.html

 1/2    1