RabbitMQ 基础
RabbitMQ: (MQ --->message Queue)
RabbitMQ 是一个遵循AMQP协议的消息中间件,它从生产者接受消息并传递给消费者(是生产者-消费者模型的一种),produce往消息队列中不断写入消息,而consumer 端则可以读取或者是是订阅队列中的消息,在这个执行过程中,根据路由规则就行路由、缓冲路由和持久化。
框架图:
其中:
Producer :生产者
Consumer: 消费者
Queue: 消息队列,提供了FIFO的处理机制,具有缓存消息的能力。rabbitmq中,队列消息可以设置为持久化,临时或者自动删除。
- 设置为持久化的队列,queue中的消息会在server本地硬盘存储一份,防止系统crash,数据丢失
- 设置为临时队列,queue中的数据在系统重启之后就会丢失
- 设置为自动删除的队列,当不存在用户连接到server,队列中的数据会被自动删除
Exchange: 提供消息路由策略,rabbitmq中,producer不是通过信道直接将消息发送给queue,而是先发送给Exchange。一个Exchange可以和多个Queue进行绑定,producer在传递消息的时候,会传递一个ROUTING_KEY,Exchange会根据这个ROUTING_KEY按照特定的路由算法,将消息路由给指定的queue。和Queue一样,Exchange也可设置为持久化,临时或者自动删除。
Exchange有4种类型:生产者(P)、Exchange(X)、消费者(C1与C2)、红色代表消息队列
direct(默认): 直接交换器,工作方式类似于单播,Exchange会将消息发送完全匹配ROUTING_KEY的Queue
fanout: 广播是式交换器,不管消息的ROUTING_KEY设置为什么,Exchange都会将消息转发给所有绑定的Queue。
topic:主题交换器,工作方式类似于组播,Exchange会将消息转发和ROUTING_KEY匹配模式相同的所有队列,比如,ROUTING_KEY为user.stock的Message会转发给绑定匹配模式为 * .stock,user.stock, * . * 和#.user.stock.#的队列。( * 表是匹配一个任意词组,#表示匹配0个或多个词组)
headers: 消息体的header匹配(ignore)
Vhost(virtual host) :
在rabbitmq server上可以创建多个虚拟的message broker,又叫做virtual hosts (vhosts)。每一个vhost本质上是一个mini-rabbitmq server,分别管理各自的exchange,和bindings。vhost相当于物理的server,可以为不同app提供边界隔离,使得应用安全的运行在不同的vhost实例上,相互之间不会干扰。producer和consumer连接rabbit server需要指定一个vhost。
基础信息:
1.消息队列好处:
1)可以异步处理请求
2)对应用进行解耦
3)可以消解流量削峰
4)对日子进行处理
5)等.....