RabbitMQ研究（五）管理RabbitMQ

你的名字 2022-04-23 07:22 269阅读 0赞

## 多租户与权限 ##

每个RabbitMQ创建消息服务器，可以使用vhost虚拟主机，每个vhost之间相互独立，互不影响。

*  建立vhost1  
    `rabbitmqctl add_vhost vhost1`
 *  删除vhost1  
    `rabbitmqctl delete_vhost vhost1`  
    删除一个vhost会删除下面所有的队列、交换器、绑定关系、用户权限等全部下属信息
 *  查看vhost列表  
    `rabbitmqctl list_vhosts`

权限全部以vhost为单位，创建一个用户，用户会被指派到至少一个vhost

*  赋权  
    `rabbitmqctl set_permissions [-p vhost] {user} {conf} {write} {read}`  
    vhost：授予用户访问权限的vhost名称，可以设置为默认值，即vhost为`/`  
    user：可以访问指定vhost的用户名  
    conf：一个用于匹配用户在哪些资源上拥有可配置权限的正则表达式  
    write：一个用于匹配用户在哪些资源上拥有可写权限的正则表达式  
    read：一个用于匹配用户在哪些资源上拥有可读权限的正则表达式

授予root用户可访问虚拟主机vhost1，并在资源上具备可配置、可写、可读权限  
`rabbitmqctl set_permissions -p vhost1 root ".*" ".*" ".*"`  
授予root用户可访问虚拟主机vhost2，在以`queue`开头的资源上具备可配置权限，并在所有资源上有用可写、可读权限  
`rabbitmqctl set_permissions -p vhost2 root "^queue.*" ".*" ".*"`

*  清除权限  
    `rabbitmqctl clear_permissions -p vhos1 root`
 *  列举权限  
    `rabbitmqctl list_permissions [-p vhost]`  
    `rabbitmqctl list_user_permissions {username}`

$ rabbitmqctl list_permissions -p vhost1
    Listing permissions in vhost "vhost1"
    root  .*  .* .*
    $ rabbitmqctl list_user_permissions root
    Listing permissions for user "root"
    /     .*  .* .*
    vhost1 .* .* .*

## 用户管理 ##

*  创建用户  
    `rabbitmqctl add_user username pass`  
    例子表示添加一个用户名是username，密码是pass的用户
 *  修改用户密码  
    `rabbitmqctl change_password username newpass`  
    表示修改用户username的密码为newpass
 *  清除密码  
    `rabbitmqctl clear_password username`  
    表示清除用户username的密码，无密码或者密码为空
 *  验证用户密码  
    `rabbitmqctl authenticate_user username pass`  
    表示验证用户密码，如果成功会提示`Success`
 *  删除用户  
    `rabbitmqctl delete_user username`  
    表示删除用户username
 *  列出用户列表  
    `rabbitmqctl list_users`  
    此处结果需要讲解一下，用户的角色分为五种：  
    none：无任何角色。新创建的用户默认的时候是none  
    managent：可以访问Web管理页面  
    policymaker：包含managent的所有权限  
    monitoring：包含management的所有权限，并可以看到所有的连接、信道、节点信息  
    administrator：包含monitoring的所有权限，并且可以管理用户、虚拟主机、权限、策略、参数，代表最高权限
 *  设置角色  
    `rabbitmqctl set_user_tags username monitoring`  
    给用户username设置为monitoring角色

## Web管理 ##

RabbitMQ有个Web插件来界面化管理

$ rabbitmq-plugins enable rabbitmq_management
    The fol1owing plugins have been enabled:
    amqp_client
    cowlib
    cowboy
    rabbitmq_web_dispatch
    rabbitmq_management_agent
    rabbitmq_management
    Applying p1ugin configuration to rabbit@node1... started 6 plugins .

启动成功可以，可以通过界面化的方式直接管理

## 应用和集群管理 ##

**应用管理**

*  `rabbitmqctl stop`  
    关闭RabbitMQ，如果创建的时候使用`rabbitmq-server -detach`启动不会生成pid\_file，否则需要指定pid\_file来关闭
 *  `rabbitmqctl shutdown`  
    关闭RabbitMQ，不同点在于这个不需要指定pid\_file而可以阻塞等待指定进程的关闭
 *  `rabbitmqctl stop_app`  
    关闭RabbitMQ，但是Erlang虚拟机还是处于运行状态
 *  `rabbitmqctl start_app`  
    启动RabbitMQ应用

**集群管理**  
`rabbitmqctl join_cluster {cluster_node} [--ram]`  
将节点加入指定集群中，在这个命令执行前需要停止RabbitMQ应用并重置节点

`rabbitmqctl cluster_status`  
查看集群的状态

`rabbitmqctl change_cluster_node_type {disc|ram}`  
修改集群节点的类型，这个命令执行前需要停止RabbitMQ应用

`rabbitmqctl forget_cluster_node [--offline]`  
将节点从集群中删除，允许离线执行

`rabbitmqctl update_cluster_nodes {clusternode}`  
更新集群节点

`rabbitmqctl sync_queue [-p vhost] {queue}`  
指示未同步队列queue的slave镜像可以同步到master镜像的内容，在同步过程中，这个队列的生产者和消费者会被阻塞，直到同步完成

`rabbitmqctl cancel_sync_queue [-p vhost] {queue}`  
取消队列queue同步镜像

`rabbitmqctl set_cluster_name {name}`  
设置集群名称

`rabbitmqctl node_headlth_check`  
对节点健康检查

## 服务端状态 ##

可以通过`list_queues`、`list_exchanges`、`list_bindings`、`list_consumers`等来查看服务端的状态，主要是分别针对队列、交换器、绑定关系、消费者等

**list\_queues**

`rabbitmqctl list_queues [-p vhost] [queue_item]`  
命令会返回队列的详细信息，分别按参数返回，类似表字段一样的概念，而queue\_item就是多个字段，注意这个queue\_item是表示下面列表中的任何值：

*  name：队列名称
 *  durable：队列是否持久化
 *  auto\_delete：队列是否自动删除
 *  arguments：队列的参数
 *  policy：应用到队列上的策略名称
 *  pid：队列关联的Erlang进程的ID
 *  owner\_pid：处理排他队列连接的Erlang进程ID。如果此队列时非排他的，此值将为空。
 *  exclusive：队列是否是排他的
 *  exclusive\_consumer\_pid：订阅到此排他队列的消费者香港的进程ID
 *  exclusive\_consumer\_tag：订阅到此排他队列的消费者的consumerTag。
 *  massages\_ready：准备发送给客户端的消息个数
 *  messages\_unacknowledged：发送给客户端但未应答的消息个数
 *  messages：准备发送给客户端和未应答消息的总和
 *  message\_ready\_ram：驻留在内存中message\_ready的消息个数
 *  messages\_unacknowledged\_ram：驻留在内存中messages\_unacknowledged的消息个数
 *  messages\_ram：驻留在内存中的消息总数
 *  messages\_persistent：队列中持久化的消息个数，对于非持久化的队列来说个数就是0
 *  messages\_bytes：队列中的所有消息的大小总和。
 *  messages\_bytes\_ready：准备发送给客户端的消息的大小总和
 *  messages\_bytes\_unacknowledged：发送给客户端但尚未应答的消息的大小总和
 *  messages\_bytes\_ram：驻留在内存中的messages\_bytes
 *  messages\_bytes\_persistent：队列中持久化的messages\_bytes
 *  disk\_reads：从队列启动开始，从磁盘中读取该队列的消息总次数
 *  disk\_writes：从队列启动开始，向磁盘队列写入的总次数
 *  consumer：消费者数目
 *  consumer\_utilisation：队列中的消息能够立刻投递给消费者的比例，介于0到1之间
 *  memory：Erlang进程消耗的内存字节数
 *  slave\_pids：如果队列时镜像的，列出所有的slave镜像的pid
 *  synchronised\_slave\_pids：如果队列时镜像的，列出所有已经同步的slave镜像
 *  state：队列状态。正常是running，如果队列正常同步数据可能会有`{syncing,MsgCount}`的状态，如果节点掉线，则队列显示为down

例子如：

$ rabbitmqctl list_queues name durable auto_delte arguments -q
    queue1 true false []
    queue2 true false []

类似我们查询数据库一样，显示哪些字段的用法

**list\_exchanges**  
`rabbitmqctl list_exchanges [-p vhost] [exchangeitem]`  
列举交换器的信息，exchangeitem如下

*  name：交换器的名称
 *  type：交换器的类型
 *  durable：是否持久化
 *  auto\_delete：是否自动删除
 *  internal：是否内置
 *  arguments：其他一些结构化参数
 *  policy：应用到交换器的策略名称

**list\_bingdings**  
`rabbitmqctl list_bindings [-p vhost] [bindinginfoitem]`  
返回绑定关系的详情，bindinginfoitem如下：

*  source\_name：绑定消息来源的名称
 *  source\_kind：绑定消息来源的类别
 *  destination\_name：绑定消息目的地的名称
 *  destination\_kind：绑定消息目的地的种类
 *  routing\_key：绑定的路由键
 *  arguments：绑定的参数

**list\_connections**  
`rabbitmqctl list_connections [conninfoitem]`  
返回连接的统计信息，conninfoitem如下：

*  pid：进程ID
 *  name：连接的名称
 *  port：服务器的端口
 *  host：返回DNS的主机名称，或者IP地址
 *  peer\_port：服务器对端端口。当一个客户端与服务器连接时，这个客户端的端口就是peer\_port
 *  peer\_host：对端主机名称
 *  ssl：是否启动SSL
 *  ssl\_protocol：SSL协议
 *  ssl\_key\_exchange：SSL密钥交换算法，如RSA
 *  ssl\_cipher：SSL加密算法
 *  ssl\_hash：SSL哈希算法
 *  peer\_cert\_subject：对端的SSL证书的主题
 *  peer\_cert\_validity：对端证书的有效期
 *  state：连接状态
 *  channels：信道个数
 *  protocol：AMQP的协议，当前是\{0,9,1\}或者\{0,8,0\}
 *  user：与连接相关的用户名
 *  vhost：与连接相关的vhost名称
 *  timeout：连接超时的心跳间隔，单位为秒
 *  frame\_max：最大传输的大小，单位是B
 *  channel\_max：此信道的最大数量。如果值为0，表示无线，一般客户端会将0变成65535
 *  client\_prpperties：连接期间的信息属性
 *  recv\_oct：收到的字节数
 *  recv\_cnt：收到的数据包个数
 *  send\_oct：发送的字节数
 *  send\_cnt：发送的数据包个数
 *  send\_pend：发送队列大小
 *  connected\_at：连接建立的时间戳

**list\_channels**  
`rabbitmqctl list_channels [channelinfoitem]`  
返回信道信息，channelinfoitem参数如下说明：

*  pid：进程ID
 *  connection：连接进程ID
 *  name：信道名称
 *  number：信道的序号
 *  user：用户名称
 *  vhost：虚拟主机
 *  transactional：信道是否处于事务模式
 *  confirm：信道是否属于publish confirm模式
 *  consumer\_count：信道中的消费者个数
 *  messages\_unacknowledged：已投递但是未被ack的消息个数
 *  messages\_uncommitted：已接收但是未提交事务的消息个数
 *  acks\_uncommitted：已ack收到但是未提交事务的消息个数
 *  messages\_unconfirmed：已发送但是未确认的消息个数
 *  perfetch\_count：新消费者的Qos个数限制
 *  global\_prefetch\_count：整个信道Qos个数限制，0表示无上限

**list\_consumers**  
列举消费者信息，每行表示已订阅队列的名称、相关信道的进程ID、consumerTag、是否需要消费端确认等

## HTTP API接口管理 ##

RabbitMQ提供了API接口的方式来调用管理，此处稍微列举一部分，比较少用到。

`/api/queues/vhost/name`  
这里可以通过RESTFUL的方式，GET/PUT/DELETE/POST四种来CURD队列信息

`/api/exchanges/vhost/name`  
同上，主要是交换器的管理

`/api/exchanges/vhost/name/publish`  
向指定的交换器发送一条信息

`/api/vhost/name`  
管理vhost