码迷,mamicode.com
首页 > 其他好文 > 详细

OpenStack消息队列AMQP基础知识

时间:2014-08-25 17:06:54      阅读:223      评论:0      收藏:0      [点我收藏+]

标签:openstack

AMQP模型

bubuko.com,布布扣

AMQP中有几个重要的概念

Producer: 消息发送者. 负责创建消息, 填充消息内容(比如 routing key), 并发送消息到 Exchange

Exchange: 从Producer接受消息, 根据Bindings中的配置, 把消息分派到对应的Queue中

Bindings:  描述了Exchange和Queue之间的关系. Exchange 根据消息内容 (routing key), 和Binding配置来决定把消息分派到哪个Queue中

Queue: 存储消息, 并把消息传递给最终的 Consumer

Consumer: 消息的实际使用者. 一个Consumer可以订阅多个Queue, 来接受Queue中的消息


Exchange 类型

AMQP Exchange又可以分为以下几个类型:

  • Direct Exchange

bubuko.com,布布扣

Direct 类似于我们生活中的快递, 填写对方的地址, 邮局会根据唯一地址, 来投递邮件

1) [Producer] 在消息体中, 填写 Routing key
2) [Exchange] 根据Routing key, 在 Binding 中查找和Routing key绑定的 Queue
3) [Exchange] 发送消息到Queue

  • Topic Exchange

bubuko.com,布布扣

Topic Exchange 和Direct Exchange比较类似, 但是Topic Exchange支持模糊匹配 (#, * 等等)

Topic 类似于我们生活中的报刊订阅. 使用关键字"体育"订阅杂志后, 邮局会把"体育周刊" 和"体育日报" 都发送给你

1) [Producer] 在消息体中, 填写 Routing key
2) [Exchange] 根据Routing key, 在 Binding 中, 通过模糊匹配, 查找和Routing key绑定的 Queue
3) [Exchange] 发送消息到Queue

  • Fanout Exchange

bubuko.com,布布扣

Fanout Exchange 不需要任何 Routing key
Fanout 类似于我们生活中的广播. 任何人无需订阅, 都可以收听到
Fanout Exchange 接收到消息之后, 会把消息发送给所有绑定的Queue中

OpenStack消息队列AMQP基础知识

标签:openstack

原文地址:http://blog.csdn.net/zhaoeryi/article/details/38820911

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!