参考文档：https://www.cnblogs.com/ericli-ericli/p/5917018.html
参考文档：RabbitMQ 实现RPC
MQ的使用场景大概包括解耦，提高峰值处理能力，送达和排序保证，缓冲等。
MQ概述消息队列技术是分布式应用间交换信息的一种技术。
消息队列可驻留在内存或磁盘上,队列存储消息直到它们被应用程序读走。
通过消息队列，应用程序可独立地执行--它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。
MQ主要作用是接受和转发消息。你可以想想在生活中的一种场景：当你把信件的投进邮筒，邮递员肯定最终会将信件送给收件人。我们可以把MQ比作 邮局和邮递员。
MQ和邮局的主要区别是,它不处理消息,但是,它会接受数据、存储消息数据、转发消息。
RabbitMQ术语生产者：
消息发送者，在MQ中被称为生产者（producer），一个发送消息的应用也被叫做生产者，用P表示
生产者“生产”出消息后，最终由谁消费呢？等待接受消息的应用程序，我们称之为消费者（Consuming ），用C表示
消息只能存储在队列（queue ）中。尽管消息在rabbitMQ和应用程序间流通，但是队列却是存在于RabbitMQ内部。
一个队列不受任何限制，它可以存储你想要存储的消息量，它本质上是一个无限的缓冲区。
多个生产者可以向同一个队列发送消息，多个消费者可以尝试从同一个消息队列中接收数据。
一个队列像下面这样（上面是它的队列名称）
生产者、消费者、中间件不必在一台机器上，实际应用中也是绝大多数不在一起的。我们可以用一张图表示RabbitMQ的构造：
注：此图片摘自于百度百科RabbitMQ。
(RPC) Remote Procedure Call Protocol 远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。
在一个大型的公司，系统由大大小小的服务构成，不同的团队维护不同的代码，部署在不同的机器。但是在做开发时候往往要用到其它团队的方法，因为已经有了实现。但是这些服务部署不同的机器上，想要调用就需要网络通信，这些代码繁琐且复杂，一不小心就会写的很低效。RPC协议定义了规划，其它的公司都给出了不同的实现。比如微软的wcf，以及现在火热的WebApi。
在RabbitMQ中RPC的实现也是很简单高效的，现在我们的客户端、服务端都是消息发布者与消息接收者。
首先客户端通过RPC向服务端发出请求
我这里有一堆东西需要你给我处理一下，correlation_id：这是我的请求标识，erply_to：你处理完过后把结果返回到这个队列中。
服务端拿到了请求，开始处理并返回
correlation_id：这是你的请求标识 ，原封不动的给你。 这时候客户端用自己的correlation_id与服务端返回的id进行对比。是我的，就接收。
在我们发布消息的时候，会调用channel对象的BasicPublish方法，这个方法中有一个IBasicProperties的参数basicProperties。
在这对象中，有一个ReplyTo属性，我们可以将生产者监听的消息队列名称存放在里面。当消费者程序接收到这条消息的时候，就可以在Receive事件的ea对象中获取ReplyTo属性的值
var props = channel.CreateBasicProperties(); props.ReplyTo = replyQueueName; var messageBytes = Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes);