rabbitMQ的基本概念和常用操作命令

rabbitMQ的基本术语

虽然，这些术语被无数文章介绍过，但为了扫盲，我还是想要啰嗦以下》》》

1.Server(broker): 接受客户端连接，实现AMQP消息队列和路由功能的进程。

2.Virtual Host:其实是一个虚拟概念，类似于权限控制组，一个Virtual Host里面可以有若干个Exchange和Queue，但是权限控制的最小粒度是Virtual Host。

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

4.Message Queue：消息队列，用于存储还未被消费者消费的消息。

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

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决定。

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

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

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

 

2. 基本操作

AMQP操作到RabbitMQ的权限的映射关系：

AMQP命令 配置 写 读

exchange.declare exchange

exchange.delete exchange

queue.declare queue

queue.delete queue

basic.publish exchane

queue.bind queue

basicconsume queue

basic.get queue

queue.purge queue

 

每一条访问控制条目由以下四部分组成：

• 被授予访问权限的用户
• 权限控制应用的vhost
• 需要授予的读/写/配置权限的组合
• 权限范围---权限是仅应用于客户端的队列/交换器呢，还是仅应用于服务器端命名的交换器/队列呢，或者两者兼顾。

访问控制条目是不跨越vhost的。举例来说，如果你想要给用户test在vhost demo1和vhost demo2上赋予相同的权限，那么你将必需创建两条控制条目。

 

rabbitmqctl add_user username password

这是创建用户的命令，如下：

 

查看用户的命令：

RabbitMQ的用户角色分类：

none、management、policymaker、monitoring、administrator。

RabbitMQ各类角色描述：

 

• none不能访问 management plugin
• management用户可以通过AMQP做的任何事外加：列出自己可以通过AMQP登入的virtual hosts ，查看自己的virtual hosts中的queues, exchanges 和 bindings，查看和关闭自己的channels 和 connections，查看有关自己的virtual hosts的“全局”的统计信息，包含其他用户在这些virtual hosts中的活动
• policymaker management可以做的任何事外加：查看、创建和删除自己的virtual hosts所属的policies和parameters
• monitoring management可以做的任何事外加：列出所有virtual hosts，包括他们不能登录的virtual hosts,查看其他用户的connections和channels,查看节点级别的数据如:clustering和memory使用情况.
• administrator policymaker和monitoring可以做的任何事外加:创建和删除virtual hosts,查看、创建和删除users,查看创建和删除permissions,关闭其他用户的connections、查看真正的关于所有virtual hosts的全局的统计信息

手动创建访问控制条目的例子：

$./rabbitmqctl set_permissions -p testUser demoVhost ".*" ".*" ".*"

 

列出绑定：

使用下面命令可以列出消费者数量和内存：

 

list_queues 默认列出了队列名称和消息数目：

列出交换器：默认只列出交换器名称和类型