openstack从零开始(2)——基础知识openstack中消息通信

AMQP

openstack选用AMQP协议，使得组件之间可以在低耦合的情况下通讯，通常选用rabbitmq作为消息中间件。

以nova为例

nova内部的组件都是用RPC的方式互相调用的，而openstack中的RPC是基于AMQP之上完成的。有两种模式：pc.call(发送request并等待接收response)、rpc.cast(只发送请求，不care之后发生了什么)。我们可以定义两种角色：消息发送者（Invoker）和消息接收者（Worker）。nova-api可以看做是一个消息发送者，nova-compute可以看做是一个消息接收者，nova-api可以给nova-compute发送消息，然后nova-compute根据接收到的消息进行相应的处理工作。

RPC CALL

Topic Publisher发送消息给MQ（消息中间件）

MQ中的exchange派送消息至相应的queue，相应的Worker取出来进行消费。

Worker消费完成后，用一个Direct Publisher把response发给MQ（消息中间件）

MQ中的exchange派送消息至相应的queue，由Direct Comsumer传递给Invoker

RPC CAST

Topic Publisher发送消息给MQ（消息中间件）

MQ中的exchange派送消息至相应的queue，相应的Worker取出来进行消费。