RabbitMQ总结概念

AMQP:一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计

http://www.diggerplus.org/archives/3110

AMQP中有四个概念非常重要:

　　1.虚拟主机(vritual host)

　　2.交换机(exchange)

　　3.队列(queue)

　　4.绑定(binding)

虚拟主机&＃xff08; virtual host &＃xff09;&＃xff1a;一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢&＃xff1f; RabbitMQ 当中&＃xff0c;用户只能在虚拟主机的粒度进行权限控制。因此&＃xff0c;如果需要禁止 A 组访问 B 组的交换机 / 队列 / 绑定&＃xff0c;必须为 A 和 B 分别创建一个虚拟主机。每一个 RabbitMQ 服务器都有一个默认的虚拟主机 “/” 

队列&＃xff08; Queue &＃xff09;&＃xff1a;由消费者建立的&＃xff0c;是 messages 的终点&＃xff0c;可以理解成装消息的容器。消息一直存在队列里&＃xff0c;直到有客户端或者称为 Consumer 消费者连接到这个队列并将 message 取走为止。队列可以有多个。

交换机&＃xff08; Exchange &＃xff09;&＃xff1a;可以理解成具有路由表的路由程序。每个消息都有一个路由键&＃xff08; routing key &＃xff09;&＃xff0c;就是一个简单的字符串。交换机中有一系列的绑定&＃xff08; binding &＃xff09;&＃xff0c;即路由规则&＃xff08; routes &＃xff09;。交换机可以有多个。多个队列可以和同一个交换机绑定&＃xff0c;同时多个交换机也可以和同一个队列绑定。&＃xff08;多对多的关系&＃xff09;

　　三种交换机:

　　　　1.   Fanout Exchange &＃xff08;不处理路由键&＃xff09;&＃xff1a;一个发送到交换机上的消息都会被转发到与该交换机绑定的所有队列上。 Fanout 交换机发消息是最快的

　　　　2.   Direct Exchange &＃xff08;处理路由键&＃xff09;&＃xff1a;如果一个队列绑定到该交换机上&＃xff0c;并且当前要求路由键为 X &＃xff0c;只有路由键是 X 的消息才会被这个队列转发。

　　　　3.   Topic Exchange &＃xff08;将路由键和某模式进行匹配&＃xff0c;可以理解成模糊处理&＃xff09;&＃xff1a;路由键的词由 “.” 隔开&＃xff0c;符号 “#” 表示匹配 0 个或多个词&＃xff0c;符号 “*” 表示匹配不多不少一个词。

　　　　因此 “  audit.#  ” 能够匹配到 “  audit.irs.corporate  ” &＃xff0c;但是 “  audit.*  ” 只会匹配到 “  audit.irs  ”

持久化:队列和交换机有一个创建时指定的标志durable,具有这个标志的队列和交换机会在重启之后重新建立,它不表示说在队列当中的消息会在重启后恢复

当你将消息发布到交换机的时候&＃xff0c;可以指定一个标志“Delivery Mode”&＃xff08;投递模式&＃xff09;。根据你使用的AMQP的库不同&＃xff0c;指定这个标志的方法可能不太一样。简单的说&＃xff0c;就是将 Delivery Mode设置成2&＃xff0c;也就是持久的即可。一般的AMQP库都是将Delivery Mode设置成1&＃xff0c;也就是非持久的。所以要持久化消息的步骤如下&＃xff1a;

1.   将交换机设成 durable 。

2.   将队列设成 durable 。

3.   将消息的 Delivery Mode 设置成 2 。

绑定&＃xff08; Bindings &＃xff09;如何持久化&＃xff1f;我们无法在创建绑定的时候设置成 durable 。没问题&＃xff0c;如果绑定了一个 durable 的队列和一个 durable 的交换机&＃xff0c; RabbitMQ 会自动保留这个绑定。类似的&＃xff0c;如果删除了某个队列或交换机&＃xff08;无论是不是 durable &＃xff09;&＃xff0c;依赖它的绑定都会自动删除。

注意两点&＃xff1a;

1.   RabbitMQ 不允许绑定一个非坚固&＃xff08; non-durable &＃xff09;的交换机和一个 durable 的队列。反之亦然。要想成功必须队列和交换机都是 durable 的。

2.   一旦创建了队列和交换机&＃xff0c;就不能修改其标志了。例如&＃xff0c;如果创建了一个 non-durable 的队列&＃xff0c;然后想把它改变成 durable 的&＃xff0c;唯一的办法就是删除这个队列然后重现创建。因此&＃xff0c;最好仔细检查创建的标志。

消息队列&＃xff08;MQ&＃xff09;使用过程

转载:http://www.tuicool.com/articles/6BRzMji

几个概念说明&＃xff1a;

1.  Broker&＃xff1a;简单来说就是消息队列服务器实体。

2.  Exchange&＃xff1a;消息交换机&＃xff0c;它指定消息按什么规则&＃xff0c;路由到哪个队列。

3.  Queue&＃xff1a;消息队列载体&＃xff0c;每个消息都会被投入到一个或多个队列。

4.  Binding&＃xff1a;绑定&＃xff0c;它的作用就是把exchange和queue按照路由规则绑定起来。

5.  Routing Key&＃xff1a;路由关键字&＃xff0c;exchange根据这个关键字进行消息投递。

6.  vhost&＃xff1a;虚拟主机&＃xff0c;一个broker里可以开设多个vhost&＃xff0c;用作不同用户的权限分离。

7.  producer&＃xff1a;消息生产者&＃xff0c;就是投递消息的程序。

8.  consumer&＃xff1a;消息消费者&＃xff0c;就是接受消息的程序。

9.  channel&＃xff1a;消息通道&＃xff0c;在客户端的每个连接里&＃xff0c;可建立多个channel&＃xff0c;每个channel代表一个会话任务。

消息队列的使用过程大概如下&＃xff1a;

1.  客户端连接到消息队列服务器&＃xff0c;打开一个channel。

2.  客户端声明一个exchange&＃xff0c;并设置相关属性。

3.  客户端声明一个queue&＃xff0c;并设置相关属性。

4.  客户端使用routing key&＃xff0c;在exchange和queue之间建立好绑定关系。

5.  客户端投递消息到exchange。

6.  exchange接收到消息后&＃xff0c;就根据消息的key和已经设置的binding&＃xff0c;进行消息路由&＃xff0c;将消息投递到一个或多个队列里。

rabbitMQ的优点&＃xff08;适用范围&＃xff09;

1.        基于erlang语言开发具有高可用高并发的优点&＃xff0c;适合集群服务器。

2.        健壮、稳定、易用、跨平台、支持多种语言、文档齐全。

3.        有消息确认机制和持久化机制&＃xff0c;可靠性高。

4.        开源