RabbitMQ
组成 Server(broker): 接受客户端连接，实现AMQP消息队列和路由功能的进程。 Virtual Host: 其实是一个虚拟概念，类似于权限控制组，一个Virtual Host里面可以有若干个Exchange和Queue，但是权限控制的最小粒度是Virtual Host Exchange: 接受生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为，例如，在RabbitMQ中，ExchangeType有direct、Fanout和Topic三种，不同类型的Exchange路由的行为是不一样的。 Message Queue：消息队列，用于存储还未被消费者消费的消息。 Message: 由Header和Body组成，Header是由生产者添加的各种属性的集合，包括Message是否被持久化、由哪个Message Queue接受、优先级是多少等。而Body是真正需要传输的APP数据。 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决定。 Connection: 连接，对于RabbitMQ而言，其实就是一个位于客户端和Broker之间的TCP连接。 Channel: 信道，仅仅创建了客户端到Broker之间的连接后，客户端还是不能发送消息的。需要为每一个Connection创建Channel，AMQP协议规定只有通过Channel才能执行AMQP的命令。一个Connection可以包含多个Channel。之所以需要Channel，是因为TCP连接的建立和释放都是十分昂贵的，如果一个客户端每一个线程都需要与Broker交互，如果每一个线程都建立一个TCP连接，暂且不考虑TCP连接是否浪费，就算操作系统也无法承受每秒建立如此多的TCP连接。RabbitMQ建议客户端线程之间不要共用Channel，至少要保证共用Channel的线程发送消息必须是串行的，但是建议尽量共用Connection。 Command: AMQP的命令，客户端通过Command完成与AMQP服务器的交互来实现自身的逻辑。例如在RabbitMQ中，客户端可以通过publish命令发送消息，txSelect开启一个事务，txCommit提交一个事务。 原理 producer发布消息到exchnage，由exchange转发给quenue，consumer者再消费queue 场景 单发单收 单发多收 发布、订阅模式，发送端发送广播消息，多个接收端接收 Routing (按路线发送接收) Topics (按topic发送接收) exchange direct 如果routing_key匹配，消息就被投递到对应队列上 fanout 不处理routing_key，将消息广播到所有绑定的队列上，消息传播最快 topic 将路由键和某模式进行匹配，将不同源头的消息投递到同一个队列上 headers 允许匹配消息的header而非routing_key vhost 持久化 管理 使用rabbitmqctl进行管理 待续…