rabbitmq简介

一、AMQP

    AMQP协议是一个高级抽象层消息通讯协议，RabbitMQ是AMQP协议的实现。它主要包括如下组件：

1.1 Server(broker)

    接受客户端链接，实现AMQP消息队列和路由功能的进程。

1.2 Virtual Host

    实际上是一个虚拟概念，相似于权限控制组，一个Virtual Host里面能够有若干个Exchange和Queue，可是权限控制的最小粒度是Virtual Host。

1.3 Exchange

    接受生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为，例如，在RabbitMQ中，ExchangeType有direct、Fanout和Topic三种，不一样类型的Exchange路由的行为是不同的。

1.3.1 direct

    若是 routing key 匹配, 那么Message就会被传递到相应的queue中。其实在queue建立时，它会自动的以queue的名字做为routing key来绑定那个exchange。

1.3.2 fanout

    会向响应的queue广播。

1.3.3 topic

    对key进行模式匹配，好比ab*能够传递到全部ab*的queue。

1.4 Message Queue

    消息队列，用于存储还未被消费者消费的消息。

1.5 Message

    由Header和Body组成，Header是由生产者添加的各类属性的集合，包括Message是否被持久化、由哪一个Message Queue接受、优先级是多少等。而Body是真正须要传输的APP数据。

1.6 Binding

    Binding联系了Exchange与Message Queue。Exchange在与多个Message Queue发生Binding后会生成一张路由表，路由表中存储着Message Queue所需消息的限制条件即Binding Key。当Exchange收到Message时会解析其Header获得Routing Key，Exchange根据Routing Key与Exchange Type将Message路由到Message Queue。Binding Key由Consumer在Binding Exchange与Message Queue时指定，而Routing Key由Producer发送Message时指定，二者的匹配方式由Exchange Type决定。 

1.7 Connection

    链接，对于RabbitMQ而言，其实就是一个位于客户端和Broker之间的TCP链接。

1.8 Channel

    信道，仅仅建立了客户端到Broker之间的链接后，客户端仍是不能发送消息的。须要为每个Connection建立Channel，AMQP协议规定只有经过Channel才能执行AMQP的命令。一个Connection能够包含多个Channel。之因此须要Channel，是由于TCP链接的创建和释放都是十分昂贵的，若是一个客户端每个线程都须要与Broker交互，若是每个线程都创建一个TCP链接，暂且不考虑TCP链接是否浪费，就算操做系统也没法承受每秒创建如此多的TCP链接。RabbitMQ建议客户端线程之间不要共用Channel，至少要保证共用Channel的线程发送消息必须是串行的，可是建议尽可能共用Connection。

    为何使用Channel，而不是直接使用Connection（TCP链接）？

    对于OS来讲，创建和关闭TCP链接是有代价的，频繁的创建关闭TCP链接对于系统的性能有很大的影响，并且TCP的链接数也有限制，这也限制了系统处理高并发的能力。可是，在TCP链接中创建Channel是没有上述代价的。对于Producer或者Consumer来讲，能够并发的使用多个Channel进行Publish或者Receive。

1.9 Command

    AMQP的命令，客户端经过Command完成与AMQP服务器的交互来实现自身的逻辑。例如在RabbitMQ中，客户端能够经过publish命令发送消息，txSelect开启一个事务，txCommit提交一个事务。

二、系统架构

•  生产者将message发送到exchange。
• exchange接受message以后，负责将其路由到具体的队列中。
• Bindings负责链接exchange和队列(queue)。
• message到达队列(queue)，而后等待被message接收端处理。
• 消费者处理message。