AMQP模型
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
Direct 类似于我们生活中的快递, 填写对方的地址, 邮局会根据唯一地址, 来投递邮件
1) [Producer] 在消息体中, 填写 Routing key
2) [Exchange] 根据Routing key, 在 Binding 中查找和Routing key绑定的 Queue
3) [Exchange] 发送消息到Queue
- Topic Exchange
Topic Exchange 和Direct Exchange比较类似, 但是Topic Exchange支持模糊匹配 (#, * 等等)
Topic 类似于我们生活中的报刊订阅. 使用关键字"体育"订阅杂志后, 邮局会把"体育周刊" 和"体育日报" 都发送给你
1) [Producer] 在消息体中, 填写 Routing key
2) [Exchange] 根据Routing key, 在 Binding 中, 通过模糊匹配, 查找和Routing key绑定的 Queue
3) [Exchange] 发送消息到Queue
- Fanout Exchange
Fanout Exchange 不需要任何 Routing key
Fanout 类似于我们生活中的广播. 任何人无需订阅, 都可以收听到
Fanout Exchange 接收到消息之后, 会把消息发送给所有绑定的Queue中