Nova如何应用AMQP（RPC）详解--以RabbitMQ为例

<h1 id="%E6%88%91%E7%9A%84%E5%8D%9A%E5%AE%A2%EF%BC%9Ahttp%3A%2F%2Fwww.sskywatcher.com%2Fblog%2F">我的博客：<a href="http://www.sskywatcher.com/blog/">http://www.sskywatcher.com/blog/</a></h1>
<h1 id="%E7%BF%BB%E8%AF%91%E8%87%AAopenstack%E5%AE%98%E7%BD%91%E6%96%87%E7%AB%A0%EF%BC%8C%E8%8B%B1%E6%96%87%E5%8E%9F%E6%96%87%EF%BC%9Ahttps%3A%2F%2Fdocs.openstack.org%2Fnova%2Flatest%2Freference%2Frpc.html">翻译自openstack官网文章，英文原文：<a href="https://docs.openstack.org/nova/latest/reference/rpc.html">https://docs.openstack.org/nova/latest/reference/rpc.html</a></h1>
目录
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#%E7%AE%80%E8%BF%B0">简述</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Nova%20RPC%20%E5%AF%BC%E8%A7%88">Nova RPC 导览</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Topic%20Publisher">Topic Publisher</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Direct%20Consumer">Direct Consumer</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Topic%20Consumer">Topic Consumer</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Direct%20Publisher">Direct Publisher</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Topic%20Exchange">Topic Exchange</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Direct%20Exchange">Direct Exchange</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Queue%20Element">Queue Element</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#RPC%20Call%E8%B0%83%E7%94%A8%E6%B5%81%E7%A8%8B%E8%AF%A6%E8%A7%A3">RPC Call调用流程详解</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#RPC%20Cast%E8%B0%83%E7%94%A8%E6%B5%81%E7%A8%8B%E8%AF%A6%E8%A7%A3">RPC Cast调用流程详解</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#AMQP%20Broker%20%E7%9A%84%E8%B4%9F%E8%BD%BD">AMQP Broker 的负载</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#API%20%E8%B0%83%E7%94%A8%E7%9A%84%E5%90%9E%E5%90%90%E9%87%8F">API 调用的吞吐量</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#Workers%E7%9A%84%E6%80%BB%E4%B8%AA%E6%95%B0">Workers的总个数</a>
<a href="https://blog.csdn.net/bestjie01/article/details/83317081#%E4%BD%BF%E7%94%A8RabbitMQ%20%E7%9A%84%E4%B8%80%E4%BA%9B%E5%8F%82%E6%95%B0%E8%A7%A3%E9%87%8A">使用RabbitMQ 的一些参数解释</a>
<hr id="hr-toc">
<hr>
<h2 id="%E7%AE%80%E8%BF%B0">简述</h2>
<hr>
AMQP 是OpenStack云管平台选用的消息队列系统。（默认是 RabbitMQ）,位于任意两个Nova组件之间的AMQP broker允许他们以一个松耦合的方式进行通信。更严谨地说，Nova组件之间使用远程过程调用（Remote Procedure Calls ，下文中直接以RPC 简称)互相通信；这是基于publish/subscribe范例构建的，使用该模式能获得以下有利之处：
<ul><li>客户端与服务端解耦；</li><li>异步调用(一个客户端发起的远程调用并不要求服务端同时工作).</li><li>对远程调用的的随机负载均衡(架设有多个服务端处于线上且正常工作, 单向的调用可以被透明的传递至第一个可用的服务端。</li></ul>
Nova使用了direct、fanout以及topic-based三种类型的exchanges. 下图展示了其基本结构：
<div style="text-align:center;">
<figure class="image">
 <a href="https://docs.openstack.org/nova/latest/_images/rpc-arch.png"><img alt="../_images/rpc-arch.png" src="https://beijingoptbbs.oss-cn-beijing.aliyuncs.com/cs/5606289-e34aed902014b036a50cb7c26a3c7dbe.png"></a>
 <figcaption>
图1 NOVA中使用RPC的结构
 </figcaption>
</figure>
</div>
Nova 通过提供一个适配器的类来实现了基于AMQP的RPC (包括请求-回复型调用和单向调用，代表性的别名是<code>rpc.call</code>和 <code>rpc.cast</code>) ，这个类包括marshaling and unmarshaling of messages 到一个函数调用中。每一个Nova服务 (比如Compute, Scheduler等等) 都会在初始化的时候创建2个