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提交一个事务。

用户角色

用户角色分为5中类型：

用户角色可分为五类，超级管理员, 监控者, 策略制定者, 一般管理者以及其余。

超级管理员(administrator)

可登陆治理控制台(启用management plugin的状况下)，可查看所有的信息，并且能够对用户，策略(policy)进行操作。

监控者(monitoring)

可登陆治理控制台(启用management plugin的状况下)，同时能够查看rabbitmq节点的相干信息(过程数，内存应用状况，磁盘应用状况等)

策略制定者(policymaker)

可登陆治理控制台(启用management plugin的状况下), 同时能够对policy进行治理。但无奈查看节点的相干信息

一般管理者(management)

仅可登陆治理控制台(启用management plugin的状况下)，无奈看到节点信息，也无奈对策略进行治理。

其余(none)

无奈登陆治理控制台，通常就是一般的生产者和消费者。

常用命令

节点治理

# 查问节点状态rabbitmqctl status# 进行RabbitMQ利用，然而Erlang虚拟机还是处于运行状态。此命令的执行优先于其余治理操作，比方rabbitmqctl reset。rabbitmqctl stop_ app # 启动RabbitMQ利用。在执行了其余治理操作之后，重新启动之前进行的RabbitMQ利用，比rabbitmqctl reset。rabbitmqctl start_app# 重置RabbitMQ节点，将RabbitMQ节点重置还原到最后状态。包含从原来所在的集群中删除此节点，从治理数据库 中删除所有的配置数据，如己配置的用户、 vhost 等，以及删除所有的长久化音讯。执行 rabbi tmqctl reset 命令前必须进行RabbitMQ 利用。rabbitmqctl reset# 强制将 RabbitMQ 节点重置还原到最后状态。不同于 rabbitmqctl reset 命令， rabbitmqctl force_reset 命令不管以后治理数据库的状态和集群配置是什么，都会无条件地重直节点。它只能在数据库或集群配置己损坏的状况下应用。与 rabbitmqctl reset 命令一样，执行 rabbitmqctl force_reset 命令前必须先进行 RabbitMQ 利用。rabbitmqctl force_reset# 批示RabbitMQ节点轮换日志文件。RabbitMQ节点会将原来的日志文件中的内容追加到"原 始名称+后缀"的日志文件中，而后再将新的日志内容记录到新创建的日志中(与原日志文件同名)。当指标文件不存在时，会从新创立。如果不指定后缀suffix. 则日志文件只是从新关上而不会进行轮换。rabbitmqctl rotate_logs {suffix}# 进行运行RabbitMQ的Erlang虚拟机和RabbitMQ利用。如果RabbitMQ没有胜利敞开，则会返回一个非零值。这个命令和rabbitmqctl stop 不同的是，它不须要指定pid_file而能够阻塞期待指定过程的敞开。rabbitmqctl shutdown# 进行运行RabbitMQ的Erlang虚拟机和RabbitMQ服务利用，其中pid_file是通过rabbitmq-server命令启动RabbitMQ 服务时创立的，默认状况下寄存于mnesia目录中。留神rabbitmq-server -detach 这个带有 -detach后缀的命令来启动 RabbitMQ 服务则不会生成 pid_file 文件。指定pid_file会期待指定过程的完结。rabbitmqctl stop [pid_file]

插件治理

# rabbitmq-plugins [-n node] {command} [command options ...]# 启动插件# rabbitmq-plugins enable [--offline] [--online] {plugin ...}rabbitmq-plugins enable rabbitmq_management# 禁用插件# rabbitmq-plugins disable [--offline] [--online] {plugin ...}rabbitmq-plugins disable  rabbitmq_management# 示意启用参数指定的插件，并且禁用其余所有插件# 没有参数示意禁用所有的插件rabbitmq-plugin set rabbitmq_management# 显示所有的插件，每一行一个rabbitmq-plugins list# 显示所有的插件，并且显示插件的版本号和形容信息rabbitmq-plugins list -v# 显示所有名称含有 "management" 的插件rabbitmq-plugins list -v management# 显示所有显示或者隐式启动的插件rabbitmq-plugins list -e rabbit

对象治理

# name：列举出所有虚拟机，tracing：示意是否应用了 RabbitMQ 的 trace 性能rabbitmqctl list_vhosts [name,tracing]# 查看交换器rabbitmqctl list_exchanges [-p vhost] [exchangeinfoitem ...]# 查看绑定关系的细节rabbitmqctl list_bindings [-p vhost] [bindinginfoitem ...]# 查看已申明的队列rabbitmqctl list_queues [-p vhost] [queueinfoitem ...] # 返回 TCP!IP连贯的统计信息。rabbìtmqctl lìst_connectìons [connectìonìnfoìtem ...]# 返回以后所有信道的信息。rabbitmqctl list_channels [channelinfoitem ...]# 列举消费者信息 每行将显示由制表符分隔的己订阅队列的名称、相干信道的过程标识、consumerTag、是否须要生产端确认 prefetch_count 及参数列表这些信息。rabbitmqctl list_consumers [-p vhost]# 创立一个新的 vhost ，大括号里的参 数示意 vhost 的名称。rabbitmqctl add vhost {vhostName}# 删除一个vhost，同时也会删除其下所有的队列、交换器、绑定关系、 用户权限、参数和策略等信息。rabbitmqctl delete_vhost {vhostName}# RabbitMQ 中的授予权限是指在 vhost 级别对用户而言的权限授予。rabbitmqctl set permissions [-p vhostName] {userName} {conf} {write} {read} # 对RabbitMQ 节点进行健康检查,确认利用是否失常运行、list_queues list_channels 是否可能失常返回等。rabbitmqctl node_health_check# 显示每个运行程序环境中每个变量的名称和值。rabbitmqctl environment# 为所有服务器状态生成一个服务器状态报告，井将输入重定向到一个文件：rabbitmqctl report > report.txtrabbitmqctl report# 显示 Broker 的状态，比方以后 Erlang 节点上运行的应用程序、RabbitMQ/Erlang的版本信息、os 的名称、内 存及文件描述符等统计信息。rabbitmqctl status# 策略管理# 策略查看rabbitmqctl list_policies [-p <vhost>]# 策略设置rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern>  <definition># 策略革除rabbitmqctl clear_policy [-p <vhost>] <name>

集群治理

# 显示集群的状态rabbitmqctl cluster_status # 将节点退出指定集群中。在这个命令执行前须要进行 RabbitMQ利用井重置节点。rabbitmqctl joio_cluster {cluster_node} [--ram] # 批改集群节点的类型。在这个命令执行前须要进行 RabbitMQ利用。rabbitmqctl change_cluster_node_type {disclram}# 将节点从集群中删除，容许离线执行。rabbitmqctl forget_cluster_node [--offiine] # 来查看那些slaves曾经实现同步：rabbitmqctl list_queues {queue_name} {slave_pids} synchronised_slave_pids# 手动的形式同步一个queue：rabbitmqctl sync_queue {queue_name}# 勾销某个queue的同步性能：rabbitmqctl cancel_sync_queue {queue_name}

用户治理

# 查看用户列表rabbitmqctl list_users# 删除用户rabbitmqctl delete_user {username}# 革除用户明码rabbitmqctl clear_password {username}# 批改明码rabbitmqctl change_password {username} {newPassword}# 验证用户rabbitmqctl authentiçate_user {username} {passWord}# 新增用户rabbitmqctl add_user {username} {password}# 给用户受权rabbitmqctl set_user_tags {username} {roles}# 分明用户对某个虚拟机的权限。rabbitmqctl clear_permissions [-p vhostName] {username}# 用来显示虚拟主机上的权限。rabbitmqctl list_permissions [-p vhost] # 用来显示用户在已调配虚拟机上的权限。rabbitmqctl list_user_permissions {username}

命令实战

用户操作

# 能够创立管理员用户，负责整个MQ的运维rabbitmqctl add_user admin adminpasspord# 赋予其administrator角色rabbitmqctl set_user_tags admin administrator# 创立RabbitMQ监控用户，负责整个MQ的监控rabbitmqctl add_user  user_monitoring  passwd_monitor  # 赋予其monitoring角色rabbitmqctl set_user_tags user_monitoring monitoring