当前位置:   article > 正文

rabbitmq 学习 之rabbitctl 命令学习(16)_rabbitmqctl reset

rabbitmqctl reset

官网 https://www.rabbitmq.com/rabbitmqctl.8.html

 

语法

  1. rabbitmqctl [-n {nodename}] [-t timeout] [-q] [-s] [-l]{command} [command options...]

-n  指定操作命令的节点     格式 rabbit@target-hostname    rabbit 是前缀 ,target-hostname 是hostname 

-t 指定操作超时时间 单位秒

-q 指 信息消息会被隐藏

-s 信息消息会被隐藏 和 表头 信息减少

-l  如果指定的节点 配置了longname nodenames 环境变量,则操作的时候必须带上-l 参数,代表使用 longname nodenames

 

rabbitmqctl help 显示内容如下

Commands:

    stop [<pid_file>]

    shutdown

    stop_app

    start_app

    wait <pid_file>

    reset

    force_reset

    rotate_logs <suffix>

    hipe_compile <directory>

 

    join_cluster <clusternode> [--ram]

    cluster_status

    change_cluster_node_type disc | ram

    forget_cluster_node [--offline]

    rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2 ...]

    update_cluster_nodes clusternode

    force_boot

    sync_queue [-p <vhost>] queue

    cancel_sync_queue [-p <vhost>] queue

    purge_queue [-p <vhost>] queue

    set_cluster_name name

 

    add_user <username> <password>

    delete_user <username>

    change_password <username> <newpassword>

    clear_password <username>

    authenticate_user <username> <password>

    set_user_tags <username> <tag> ...

    list_users

 

    add_vhost <vhost>

    delete_vhost <vhost>

    list_vhosts [<vhostinfoitem> ...]

    set_permissions [-p <vhost>] <user> <conf> <write> <read>

    clear_permissions [-p <vhost>] <username>

    list_permissions [-p <vhost>]

    list_user_permissions <username>

 

    set_parameter [-p <vhost>] <component_name> <name> <value>

    clear_parameter [-p <vhost>] <component_name> <key>

    list_parameters [-p <vhost>]

    set_global_parameter <name> <value>

    clear_global_parameter <name>

    list_global_parameters

 

    set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] 

<name> <pattern>  <definition>

    clear_policy [-p <vhost>] <name>

    list_policies [-p <vhost>]

 

    list_queues [-p <vhost>] [--offline|--online|--local] [<queueinfoitem> ...]

    list_exchanges [-p <vhost>] [<exchangeinfoitem> ...]

    list_bindings [-p <vhost>] [<bindinginfoitem> ...]

    list_connections [<connectioninfoitem> ...]

    list_channels [<channelinfoitem> ...]

    list_consumers [-p <vhost>]

    status

    node_health_check

    environment

    report

    eval <expr>

 

    close_connection <connectionpid> <explanation>

    trace_on [-p <vhost>]

    trace_off [-p <vhost>]

    set_vm_memory_high_watermark <fraction>

    set_vm_memory_high_watermark absolute <memory_limit>

    set_disk_free_limit <disk_limit>

    set_disk_free_limit mem_relative <fraction>

    encode [--decode] [<value>] [<passphrase>] [--list-ciphers] [--list-hashes] 

[--cipher <cipher>] [--hash <hash>] [--iterations <iterations>]

    decode [<value>] [<passphrase>][--cipher <cipher>] [--hash <hash>] 

[--iterations <iterations>]

    list_hashes

    list_ciphers

接下来对这些命令做详细说明:

1 用户角色类相关命令介绍

用户角色

rabbitmq用户角色(role)分为五类: 超级管理员(administrator)、监控者(monitor)、决策制定者(policymaker)、普通管理者(management)和其他。

  • administrator 可登录管理控制台(启用management plugin的情况下),查看所有的信息,并且可以对用户、策略(policy)进行操作;
  • monitoring 可登录管理控制台(启用management plugin的情况下),同时可以查看rabbitmq节点的相关信息(进程数、内存使用情况,磁盘使用情况等);
  • policymaker 可以登录管理控制台(启用management plugin的情况下),同时可以对策略(policy)进行操作;
  • management 仅可登录管理控制台(启用management plugin的情况下),无法看到节点信息,也无法对策略进行管理;
  • 其他 无法登录管理控制台,通常就是普通的生产者和消费者。


注意,rabbitmqctl 管理 RabbitMQ 的内部用户数据库,所有其他后台需要认证的用户对于rabbitmqctl将不可见。

  1. rabbitmqctl add_user {username} {password}
  2. # {username} 表示用户名; {password}表示用户密码
  3. # 该命令将创建一个 non-administrative 用户
  4. rabbitmqctl delete_user {username}
  5. # 表示删除一个用户,该命令将指示RabbitMQ broker去删除指定的用户
  6. rabbitmqctl change_password {username} {newpassword}
  7. # 表示修改指定的用户的密码
  8. rabbitmqctl clear_password {username}
  9. # 表示清除指定用户的密码
  10. # 执行此操作后的用户,将不能用密码登录,但是可能通过已经配置的SASL EXTERNAL的方式登录。
  11. rabbitmqctl authenticate_user {username} {password}
  12. # 表示指引RabbitMQ broker认证该用户和密码 是否正确
  13. rabbitmqctl set_user_tags {username} {tag ...}
  14. # 表示设置用户的角色,{tag}可以是零个,一个,或者是多个。并且已经存在的tag也将会被移除。
  15. # rabbitmqctl set_user_tags tonyg administrator 该命令表示指示RabbitMQ broker确保用户tonyg为一个管理员角色。
  16. # 上述命令在用户通过AMQP方式登录时,不会有任何影响;但是如果通过其他方式,例如管理插件方式登录时,就可以去管理用户、vhost 和权限。
  17. rabbitmqctl list_users
  18. # 表示列出所有用户名信息

2 访问控制 

用户有了用户名和密码 还需要操作vhost 的权限 才能真正使用,

以下是操作 添加删除  vhost , 把vhost 的读写配置 权限开放给某个用户,或者从某个用户收回。查看vhost 下的 用户和权限列表

  1. rabbitmqctl add_vhost {vhost}
  2. # {vhost} 表示待创建的虚拟主机项的名称
  3. rabbitmqctl delete_vhost {vhost}
  4. # 表示删除一个vhost。删除一个vhost将会删除该vhost的所有exchange、queue、binding、用户权限、参数和策略。
  5. rabbitmqctl list_vhosts {vhostinfoitem ...}
  6. # 表示列出所有的vhost。其中 {vhostinfoitem} 表示要展示的vhost的字段信息,展示的结果将按照 {vhostinfoitem} 指定的字段顺序展示。这些字段包括: name(名称) 和 tracing (是否为此vhost启动跟踪)。
  7. # 如果没有指定具体的字段项,那么将展示vhost的名称。
  8. 例如rabbitmqctl list_vhosts {name,tracing} 将展示所有vhost 的nname和是否追踪日志 字段
  9. rabbitmqctl set_permissions [-p vhost] {user} {conf} {write} {read}
  10. # 表示设置用户权限。 {vhost} 表示待授权用户访问的vhost名称,默认为 "/"; {user} 表示待授权反问特定vhost的用户名称; {conf}表示待授权用户的配置权限,是一个匹配资源名称的正则表达式; {write} 表示待授权用户的写权限,是一个匹配资源名称的正则表达式; {read}表示待授权用户的读权限,是一个资源名称的正则表达式。
  11. # rabbitmqctl set_permissions -p myvhost tonyg "^tonyg-.*" ".*" ".*"
  12. # 例如上面例子,表示授权给用户 "tonyg" 在vhost为 `myvhost` 下有资源名称以 "tonyg-" 开头的 配置权限;所有资源的写权限和读权限。
  13. rabbitmqctl clear_permissions [-p vhost] {username}
  14. # 表示设置用户拒绝访问指定指定的vhost,vhost默认值为 "/"
  15. rabbitmqctl list_permissions [-p vhost]
  16. # 表示列出具有权限访问指定vhost的所有用户、对vhost中的资源具有的操作权限。默认vhost为 "/"
  17. # 注意,空字符串表示没有任何权限。
  18. rabbitmqctl list_user_permissions {username}
  19. # 表示列出指定用户的权限vhost,和在该vhost上的资源可操作权限。

3RabbitMQ的一些特性(例如联合插件)是被动态的、集群范围内的参数控制。有两类参数:基于vhost的参数和全局参数。
一个属于vhost的参数由三部分组成: 组件名称,参数名称和值。其中组件名称和名称是字符串,值是一个Erlang项。
一个全局参数由两部分组成: 参数名称和值。其中名称是字符串,值是一个Erlang项。
参数可以被设置,删除,列出。参数的具体设置方法如下:

  1. rabbitmqctl set_parameter [-p vhost] {component_name} {name} {value}
  2. # 设置参数,{component_name}表示待设置参数的组件名称,{name} 表示待设置的参数名称,{value}表示待设置的参数值,是一个JSON项,在多数shell中,你很有可能要应用该值
  3. # rabbitmqctl set_parameter federation local_username '"guest"'
  4. # 上述例子,表示设置默认vhost即 "/" 的 federation 组件的参数 local_username 的值设置为JSON项 "guest"
  5. rabbitmqctl clear_parameter [-p vhost] {component_name} {key}
  6. # 表示清理一个参数,{component_name}表示待清理的组件名称,{key}表示待清理的参数名称
  7. # rabbitmqctl clear_parameter federation local_username
  8. # 上述例子表示清理默认vhost上的组件 federation 的参数 local_username
  9. rabbitmqctl list_parameters [-p vhost]
  10. # 表示列举出指定的vhost上的所有参数
  11. rabbitmqctl set_global_parameter {name} {value}
  12. # 设置一个全局运行时的变量,有些类似于 set_parameter ,但是此 key-value 对并不绑定于vhost。
  13. # rabbitmqctl set_global_parameter mqtt_default_vhosts '{"O=client,CN=guest":"/"}'
  14. # 上述例子,设置一个全局运行时的参数 mqtt_default_vhosts 的值为一个JSON项, {"O=client,CN=guest":"/"}
  15. rabbitmqctl clear_global_parameter {name}
  16. # 清除一个全局运行时参数,类似于 clear_parameter,但是此 key-value 对并不绑定于vhost。
  17. # rabbitmqctl clear_global_parameter mqtt_default_vhosts
  18. # 上述例子,清除一个全局运行时参数 mqtt_default_vhosts
  19. rabbitmqctl list_global_parameters
  20. # 列出所有的全局运行时参数,类似于 list_parameters,但是该命令不绑定于任何vhost

 4 有一类特殊的parameter 叫做policy 用于在集群范围内,控制和修改队列和交换器的行为。适用于给定固定虚拟机,并由名称,模式,定义和可选优先级组成。可以设置,清除和列出策略。

  1. rabbitmqctl set_policy [-p vhost] [--priority priority] [--apply-to apply-to] {name} {pattern} {definition}
  2. # {name} 表示策略名称;
  3. # {pattern} 表示当匹配到给定资源的正则表达式,使的该策略得以应用;
  4. # {definition} 表示策略的定义,作为一个JSON项,在多数shell中,你很可能需要去应用它
  5. # {priority} 表示策略的优先级的整数,数据越大表示优先级越高,默认值为0
  6. # {apply_to} 表示策略应该应用的类型: queues/exchange/all,默认值是 all
  7. rabbitmqctl clear_policy [-p vhost] {name}
  8. # 表示清理一个策略。 {name} 表示待清理的策略名称
  9. rabbitmqctl list_policies [-p vhost]
  10. # 表示列举出给定的vhost的所有策略信息
  11. 操作符策略 见 https://www.rabbitmq.com/parameters.html

5 rabbitmq 应用管理

  1. rabbitmqctl stop [{pid_file}]
  2. # 表示stop 在RabbitMQ服务器上运行的一个Erlang 节点,可以指定某一个 *pid_file*,表示会等待这个指定的程序结束
  3. rabbitmqctl shutdown
  4. # 表示终止RabbitMQ 服务器上的Erlang进程,如果终止失败,会返回非零数字
  5. rabbitmqctl stop_app
  6. # 表示终止RabbitMQ的应用,但是Erlang节点还在运行。该命令典型的运行在一些需要RabbitMQ应用被停止的管理行为之前,例如 reset
  7. rabbitmqctl start_app
  8. # 表示启动RabbitMQ的应用。该命令典型的运行在一些需要RabbitMQ应用被停止的管理行为之后,例如 reset
  9. rabbitmqctl wait {pid_file}
  10. # 表示等待RabbitMQ应用启动。该命令会等待指定的pid file被创建,也就是启动的进程对应的pid保存在这个文件中,然后RabbitMQ应用在这个进程中启动。如果该进程终止,没有启动RabbitMQ应用,就会返回错误。
  11. # 合适的pid file是有rabbitmq-server 脚本创建的,默认保存在 Mnesia 目录下,可以通过修改 RABBITMQ_PID_FILE 环境变量来修改
  12. # 例如 rabbitmqctl wait /var/run/rabbitmq/pid
  13. rabbitmqctl reset
  14. # 表示设置RabbitMQ节点为原始状态。会从该节点所属的cluster中都删除,从管理数据库中删除所有数据,例如配置的用户和vhost,还会删除所有的持久消息。
  15. # 要想reset和force_reset操作执行成功,RabbitMQ应用需要处于停止状态,即执行过 stop_app
  16. rabbitmqctl force_reset
  17. # 表示强制性地设置RabbitMQ节点为原始状态。它和reset的区别在于,可以忽略目前管理数据库的状态和cluster的配置,无条件的reset
  18. # 该方法的使用,应当用在当数据库或者cluster配置损坏的情况下作为最后的方法。
  19. rabbitmqctl rotate_logs {suffix}
  20. # 表示将日志文件的内容追加到新的日志文件中去,这个新的日志文件的文件名是原有的日志文件名加上命令中的 suffix,并且恢复日志到原来位置的新文件中。
  21. # 注意:如果新文件原先不存在,那么会新建一个;如果suffix为空,那么不会发生日志转移,只是重新打开了一次日志文件而已。
  22. rabbitmqctl hipe_compile {directory}
  23. # 表示在指定的目录下执行HiPE编译和缓存结果文件 .beam-files
  24. # 如果需要父目录会被创建。并且在编译之前,该目录下的所有 .beam-files会被自动删除。
  25. # 使用预编译的文件,你应该设置 RABBITMQ_SERVER_CODE_PATH 环境变量为 hipe_compile 调用指定的目录。

6 集群管理

  1. rabbitmqctl join_cluster {clusternode} [--ram]
  2. # 表示结合到指定的集群,如果有参数 --ram 表示作为RAM节点结合到该集群中。
  3. # 该命令指令本节结合到指定的集群中,在结合之前,该节点需要reset,所以在使用时,需要格外注意。为了成功运行本命令,必须要停止RabbitMQ应用,例如 stop_app
  4. # 集群节点有两种类型: disc 和 RAM。disc类型,复制数据在RAM和disc上,在节点失效的情况下,提供了冗余保证,也能从一些全局事件中恢复,例如所有节点失效。RAM类型,只复制数据在RAM上,主要表现在伸缩性上,特别是在管理资源(例如:增加删除队列,交换器,或者绑定)上表现突出。
  5. # 一个集群必须至少含有一个disc节点,当通常都多余一个。通过该命令时,默认是设置为disc节点,如果需创建RAM节点,需要指定参数 --ram
  6. # 执行此命令之后,在该节点上启动的RabbitMQ应用,在该节点挂掉之后,会尝试连接节点所在集群中的其他节点。
  7. # 为了离开集群,可以 reset 该节点,也可以使用命令 forget_cluster_node 远程删除节点
  8. rabbitmqctl cluster_status
  9. # 表示显示通过节点类型聚合在一起的集群中的所有节点,还有目前正在运行的节点
  10. rabbitmqctl change_cluster_node_type {disc|ram}
  11. # 表示改变集群节点的类型。该操作的正确执行,必定会停止该节点。并且在调整一个node为ram类型时,该节点不能为该集群的唯一node
  12. rabbitmqctl forget_cluster_node [--offline]
  13. # 表示远程移除一个集群节点。要删除的节点必须脱机,如果没有脱机,需要使用 --offline 参数。当使用 --offline 参数时,rabbitmqctl不会去连接节点,而是暂时变成节点,以便进行变更。这在节点不能正常启动时非常有用。在这种情况下,节点会成为集群元数据的规范来源(例如哪些队列存在)。因此如果可以的话,应该使用此命令在最新的节点上关闭。
  14. # --offline 参数使节点从脱机节点上移除。使用场景主要是在所有节点脱机,且最后一个节点无法联机时,从而防止整个集群启动。在其他情况不应该使用,否则会导致不一致。
  15. # 例如 rabbitmqctl -n hare@mcnulty forget_cluster_node rabbit@stringer
  16. # 上述命令将从节点 hare@mcnulty 中移除节点 rabbit@stringer
  17. rabbitmqctl rename_cluster_node {oldnode1} {newnode1} [oldnode2] [newnode2...]
  18. # 表示在本地数据库上修改集群节点名称。该命令让rabbitmqctl暂时成为一个节点来做出做变更。因此,本地的待修改的集群节点一定要完全停止,其他节点可以是online或者offline
  19. rabbitmqctl update_cluster_nodes {clusternode}
  20. # 表示指示已经集群的节点在唤醒时联系 {clusternode} 进行集群。这与 join_cluster 命令不同,因为它不加入任何集群,它是检查节点是否已经在具有 {clusternode} 的集群中。
  21. # 该命令的需求,是在当一个节点offline时,修改了集群节点的情形下。例如:节点A和B聚群,节点A offline了,节点C和B集群,并且B节点离开了该集群,那么当节点A起来的时候,A会尝试连接B,但是由于B节点已经不在该集群中,所以会失败。
  22. # 通过 update_cluster_nodes -n A C 将会解决上述问题。
  23. rabbitmqctl force_boot
  24. # 表示强制确保节点启动,即使该节点并不是最后down的。
  25. # 一般情况下,当你同时shut down了RabbitMQ集群时,第一个重启的节点应该是最后一个down掉的,因为它可能已经看到了其他节点发生的事情。但是有时候这并不可能:例如当整个集群lose power,那么该集群的所有节点会认为他们不是最后一个关闭的。
  26. # 如果最后down的节点永久的lost,那么应该优先使用 rabbitmqctl forget_cluster_node --offline ,因为这将确保在丢失节点上的镜像队列得到优先处理。
  27. rabbitmqctl sync_queue [-p vhost] {queue}
  28. # {queue} 表示待同步的队列名称
  29. # 指引含有异步slaves的镜像队列去同步自身。当队列执行同步化时,其将会被锁定(指所有publishers发送出去的和consumers获取到的队列都会被锁定)。为了成功执行此命令,队列必须要被镜像。
  30. # 注意,排除消息的异步队列将最终被同步化,此命令主要运用于未被排除完全消息的队列。
  31. rabbitmqctl cancel_sync_queue [-p vhost] {queue}
  32. # 指引一个正在同步的镜像队列停止此操作。
  33. rabbitmqctl purge_queue [-p vhost] {queue}
  34. # {queue} 表示待清空消息的队列名称
  35. # 该命令表示清空队列(即删除队列中的所有消息)
  36. rabbitmqctl set_cluster_name {name}
  37. # 设置集群的名称。在连接中,集群的名称被声明在客户端上,被同盟和插件用来记录一个消息所在的位置。集群的名称默认来自于集群中第一个节点的主机名,但是可以被修改。

 

7 服务器状态和服务器上的实体查询

服务状态查询语句,询问服务之后,将返回tab分隔的一组列项结果。一些查询语句(例如 list_queues, list_exchanges, list_bindings, list_consumers)接受一个可选的vhost参数。该参数(如果存在),必须在查询之后立即指定。

  1. rabbitmqctl list_queues [-p vhost] [[--offline] | [--online] | [--local]] [queueinfoitem ...]
  2. # 返回队列的详细信息。如果 "-p" 标志不存在,那么将返回默认虚拟主机的队列详细信息。"-p" 可以用来覆盖默认vhost。可以使用一下互斥选项之一,通过其状态或者位置过滤显示的队列。
  3. # [--offline] 表示仅仅列出当前不可用的持久队列(更具体地说,他们的主节点不是)
  4. # [--online] 表示列出当前可用的队列(他们的主节点是)
  5. # [--local] 表示仅仅列出那些主程序在当前节点上的队列
  6. # queueinfoitem参数用于指示要包括在结果中的哪些队列信息项。结果中的列顺序将与参数的顺序相匹配。queueinfoitem可以从以下列表中获取任何值:
  7. # name 表示队列的名称
  8. # durable 表示服务器重启之后,队列是否存活
  9. # auto_delete 表示不再使用的队列是否自动被删除
  10. # arguments 表示队列的参数
  11. # policy 表示应用在队列中的策略名称
  12. # pid 表示和队列相关联的Erlang进程的ID
  13. # owner_pid 表示作为队列的排他所有者的连接的Erlang进程的ID,如果队列是非排他,则为空
  14. # exclusive 表示队列是否是排他的,有 owner_pid 返回 True,否则返回 False
  15. # exclusive_consumer_pid 表示排他消费者订阅该队列的频道的Erlang进程的ID,如果没有独家消费者,则为空
  16. # exclusive_consumer_tag 表示订阅该队列的排他消费者的消费tag。如果没有排他消费者,则为空
  17. # messages_ready 表示准备被发送到客户端的消息数量
  18. # messages_unacknowledged 表示已经被发送到客户端但是还没有被确认的消息数量
  19. # messages 表示准备发送和没有被确认的消息数量总和(队列深度)
  20. # messages_ready_ram 表示驻留在 ram 里的 messages_ready 的消息数量
  21. # messages_unacknowledged_ram 表示驻留在 ram 里的 messages_unacknowledged 的消息数量
  22. # messages_ram 表示驻留在 ram 里的消息总数
  23. # messages_persistent 表示队列中持久消息的总数(对于临时队列,总是为0)
  24. # message_bytes 表示在队列中所有消息body的大小,这并不包括消息属性(包括header)或者任何开销
  25. # message_bytes_ready 表示类似于 messge_bytes 但仅仅计算那些将发送到客户端的消息
  26. # message_bytes_unacknowledged 表示类似于 message_bytes 但仅仅计算那些已经发送到客户还没有确认的消息
  27. # message_bytes_ram 表示类似于 message_bytes 但仅仅计算那些驻留在ram中的消息
  28. # message_bytes_persistent 表示类似于 message_bytes 但仅仅计算那些持久消息
  29. # head_message_timestamp 表示队列中第一个消息的时间戳属性(如果存在)。只有处在 paged-in 状态的消息才存在时间戳。
  30. # disk_reads 表示该队列自start起,从磁盘读取消息的次数总和
  31. # disk_writes 表示该队列自start起,被写入磁盘消息的次数总和
  32. # consumers 表示consumer的数量
  33. # consumer_utilisation 表示队列能够立即将消息传递给消费者的时间分数(0.0 ~ 1.0之间),如果消费者受到网络拥塞或者预取计数的限制,该值可能小于1.0
  34. # memory 表示和该队列相关联的Erlang进程消耗的内存字节数,包括stack/heap/内部数据结构
  35. # slave_pids 表示该队列目前的slave的ID号(如果该队列被镜像的话)
  36. # synchronised_slave_pids 表示如果队列被镜像,给出与主队列同步的当前slave的ID号,即可以从主队列接管而不丢失消息的slave的ID
  37. # state 表示队列的状态,一般是 "running"; 如果队列正在同步,也可能是 "{syncing, MsgCount}"; 如果队列所处的节点当前down了,队列显示的状态为 "down"
  38. # 如果没有指定queueinfoitem,那么将显示队列的名称(name)和深度(messages)
  39. rabbitmqctl list_exchanges [-p vhost] [exchangeinfoitem ...]
  40. # 返回交换器的详细信息。如果 "-p" 标志不存在,那么将返回默认虚拟主机的交换器详细信息。"-p" 可以用来覆盖默认vhost。
  41. # exchangeinfoitem参数用于指示要包括在结果中的哪些交换器信息项。结果中的列顺序将与参数的顺序相匹配。exchangeinfoitem可以从以下列表中获取任何值:
  42. # name 表示交换器的名称
  43. # type 表示交换器类型(例如: direct/topic/fanout/headers)
  44. # durable 表示服务器重启之后,交换器是否存活
  45. # auto_delete 表示交换器不再使用时,是否被自动删除
  46. # internal 表示交换器是否是内部的,例如不能被客户端直接发布
  47. # arguments 表示交换器的参数
  48. # policy 表示引用在该交换器上的策略名称
  49. # 如果没有指定任何 exchangeinfoitem,那么该命令将显示交换器的名称(name)和类型(type)
  50. rabbitmqctl list_bindings [-p vhost] [bindinginfoitem ...]
  51. # 返回绑定的详细信息。如果 "-p" 标志不存在,那么将返回默认虚拟主机的绑定详细信息。"-p" 可以用来覆盖默认vhost。
  52. # bindinginfoitem参数用于指示要包括在结果中的哪些绑定信息项。结果中的列顺序将与参数的顺序相匹配。bindinginfoitem可以从以下列表中获取任何值:
  53. # source_name 表示绑定附加到的消息源的名称
  54. # source_kind 表示绑定附加到的消息源的类型,目前通常交换器
  55. # destination_name 表示附加绑定到的消息目的地的名称
  56. # destination_kind 表示附加绑定到的消息目的地的类型
  57. # routing_key 表示绑定的routing key
  58. # arguments 表示绑定的参数
  59. # 如果没有指定任何的 bindinginfoitem ,那么将展示上述所有的参数
  60. # rabbitmqctl list_bindings -p /myvhost exchange_name queue_name
  61. # 上述命令,表示展示在 /myvhost 虚拟主机中的绑定的exchange名称和queue名称
  62. rabbitmqctl list_connections [connectioninfoitem ...]
  63. # 返回TCP/IP连接统计信息
  64. # connectioninfoitem 参数用于指示要包括在结果中的哪些连接信息项,结果中的列顺序将与参数的顺序相匹配。connectioninfoitem可以从以下列表中获取任何值:
  65. # pid 表示与该connection相关联的Erlang进程的id号
  66. # name 表示该连接的可读性名称
  67. # port 表示服务端口
  68. # host 表示通过反向DNS获取的服务器主机名,如果反向DNS失败或未启用,则为其IP地址
  69. # peer_port 表示对等端口
  70. # peer_host 表示通过反向DNS获取的对等主机名,如果反向DNS失败或未启用,则为其IP地址
  71. # ssl 表示该连接是否使用SSL保护的bool值
  72. # ssl_protocal 表示SSL协议(例如: tlsv1)
  73. # ssl_key_exchange 表示SSL关键交换器算法(例如: rsa)
  74. # ssl_cipher 表示SSL密码算法(例如: aes_256_cbc)
  75. # ssl_hash 表示SSL哈希函数(例如: sha)
  76. # peer_cert_issuer 表示对等体的SSL证书的颁发者,以RFC4514形式出现
  77. # peer_cert_validity 表示对等体的SSL证书的有效期限
  78. # state 表示连接状态(例如: starting/tuning/opening/running/flow/blocking/blocked/closing/closed)
  79. # channels 表示正在使用连接的通道数量
  80. # protocol 表示正在使用的AMQP的版本号。注意,如果一个客户端需要一个AMQP 0-9 连接,我们将其作为 AMQP 0-9-1
  81. # auth_mechanism 表示使用SASL认证机制,如PLAN
  82. # user 表示和该连接相关联的用户名
  83. # vhost 表示vhost名称
  84. # timeout 表示连接超时/协商心跳间隔,单位为秒
  85. # frame_max 表示最大的frame大小(byte)
  86. # channel_max 表示该连接上通道的最大数量
  87. # client_properties 表示在连接建立期间,有客户端传送的消息属性
  88. # recv_oct 表示接受到的八位字节
  89. # recv_cnt 表示接受到的包
  90. # send_oct 表示发送的八位字节
  91. # send_cnt 表示发送的包
  92. # send_pend 表示发送的队列大小
  93. # connected_at 表示该连接被建立的日期和时间的时间戳格式
  94. # 如果没有指定任何connectioninfoitem,那么将展示:user/peer_host/peer_port/流量控制和内存块状态之后的时间
  95. rabbitmqctl list_channels [channelinfoitem ...]
  96. # 返回所有当前的通道的信息,通道即一个执行大多数AMQP命令的逻辑容器。这包括由普通AMQP连接的一部分通道、由各种插件和其他扩展程序创建的通道。
  97. # channelinfoitem 参数用于指示要包括在结果中的哪些连接信息项,结果中的列顺序将与参数的顺序相匹配。channelinfoitem 可以从以下列表中获取任何值:
  98. # pid 表示与该连接相关联的Erlang程序的ID号
  99. # connection 表示与通道所属连接相关联的Erlang进程的ID号
  100. # name 表示通道的可读性名称
  101. # number 表示通道的号码,在连接中唯一表示它
  102. # user 表示和该通道相关联的用户名
  103. # vhost 表示通道操作所在的vhost
  104. # transactional 表示通道是否处于事务模式,返回 true,否则返回 false
  105. # confirm 表示通道是否处于确认模式,返回 true, 否则返回 false
  106. # consumer_count 表示通过通道检索消息的逻辑AMQP消费者数量
  107. # messages_unacknowledged 表示通过通道发送过但还没收到反馈的消息的数量
  108. # messages_uncommitted 表示尚未提交的事务中接受的消息数
  109. # acks_uncommitted 表示尚未提交的事务中接受的确认数
  110. # messages_unconfirmed 表示尚未确认已发布的消息数量。在不处于确认模式中的通道上,该值为0
  111. # prefetch_count 表示新消费者的QoS预取限制,如果没有限制则为0
  112. # global_prefetch_count 表示整个通道的QoS预取限制,如果没有限制则为0
  113. # 如果没有指定任何 channelinfoitem 项,那么将展示 pid/user/consumer_count/messages_unacknowledged
  114. rabbitmqctl list_consumers [-p vhost]
  115. # 列出消费者,例如对一个队列的消息流的订阅者。每一行用tab字符分隔:
  116. # 订阅的队列名称、创建和管理订阅的通道id、在通道中唯一标识订阅的消费者tag、消息传输到订阅者之后是否需要确认的bool值、代表预取限制的整数(0表示none)、订阅者的其他参数
  117. rabbitmqctl status
  118. # 展示broker的状态信息,例如在当前Erlang节点上正在运行的应用、RabbitMQ和Erlang版本号、OS名称、内存和文件描述统计信息
  119. rabbitmqctl node_health_check
  120. # RabbitMQ节点的健康检查,验证 Rabbit 应用正在运行,list_queues和list_channels返回,警告没有被设置
  121. # rabbitmqctl node_health_check -n rabbit@stringer
  122. # 上述例子,表示对RabbitMQ节点进行健康检查
  123. rabbitmqctl environment
  124. # 在每个正在运行的应用程序的应用程序环境中,显示每个变量的名称和值
  125. rabbitmqctl report
  126. # 生成服务器状态报告,其中包括用于支持目的的所有服务器状态信息的并置。当伴随支持请求时,输出应该被重定向到一个文件
  127. # rabbitmqctl report > server_report.txt
  128. rabbitmqctl eval {expr}
  129. # 评估一个任务Erlang表达式
  130. # rabbitmqctl eval 'node().'
  131. # 上述例子,将返回 rabbitmqctl 已经连接的节点名称
  132. rabbitmqctl set_vhost_limits -p vhost {}
  133. 设置虚拟机的最大连接数和最大队列数 -1代表无限大
  134. 示例 rabbitmqctl set_vhost_limits -p qa_env '{"max-connections": 64}'
  135. rabbitmqctl set_vhost_limits -p qa_env '{"max-queues": 256}'
  136. rabbitmqctl clear_vhost_limits -p vhost
  137. 清除虚拟机限制
  138. rabbitmqctl list_vhost_limits [-p vhost]
  139. 查看vhost 限制

8其他命令

  1. rabbitmqctl close_connection {connectionpid} {explanation}
  2. # {connectionpid} 表示待关闭连接的Erlang进程的ID号
  3. # {explanation} 表示解释字符串
  4. # 指引broker去关闭与ID为 {connectionid} Erlang进程相关联的连接,作为AMQP连接关闭协议的一部分,它也会向连接的客户端传递 {explanation} 字符串
  5. # rabbitmqctl close_connection "<rabbit@tanto.4262.0>" "go away"
  6. # 上述例子,表示关闭与ID号为 "<rabbit@tanto.4262.0>" 的Erlang进程相关联的连接,并向连接的客户端传输解释性语句 "go away"
  7. rabbitmqctl trace_on [-p vhost]
  8. # vhost 表示要启动跟踪的虚拟机名称
  9. # 开始跟踪。注意,跟踪状态不是持久的,如果服务重启,它将恢复为关闭
  10. rabbitmqctl trace_off [-p vhost]
  11. # 停止跟踪
  12. rabbitmqctl set_vm_memory_high_watermark {fraction}
  13. # {fraction} 触发流量控制的新内存阈值分数,大于或等于0的浮点数
  14. rabbitmqctl set_vm_memory_high_watermark absolute {memory_limit}
  15. # {memory_limit} 触发流量控制的新内存限制,以字节表示,大于或等于0的整数或作为具有存储单元(例如: 512M或者1G),可用的单位有:
  16. k/kiB: kibibytes(2^10字节); M/MiB: mebibytes(2^20字节); G/GiB: gibibytes(2^30字节)
  17. kB: kilobytes(10^3); MB: megabytes(10^6); GB: gigabytes(10^9)
  18. rabbitmqctl set_disk_free_limit {disk_limit}
  19. # {disk_limit} 下限为字节整数或具有存储单元的字符串(参见 vm_memory_high_watermark 命令),例如: 512M或1G,一旦可用磁盘空间达到限制,将会设置磁盘告警
  20. rabbitmqctl set_disk_free_limit mem_relative {fraction}
  21. # {fraction} 相对于可用RAM的限制,为非负的浮点数。低于1.0的值可能是危险的,应小心使用。
  22. rabbitmqctl encode [--decode] [value] [passphrase] [--list-ciphers] [--list-hashes] [--cipher cipher] [--hash hash] [--iterations iteraions]
  23. # [--decode] 表示解密输入值的标志位。
  24. 例如: rabbitmqctl encode --decode '{encrypted,'<<"...">>}' mypassphrase
  25. # [value] [passphrase] 表示加密和解密的值、密码。
  26. 例如: rabbitmqctl encode '<<"guest">>' mypassphrase
  27. 例如: rabbitmqctl encode --decode '{encrypted,'<<"...">>}' mypassphrase
  28. # [--list-ciphers] 表示列出支持的密码标志位
  29. 例如: rabbitmqctl encode --list-ciphers
  30. # [--list-hashes] 表示列出支持的哈希算法标志位
  31. 例如: rabbitmqctl encode --list-hashes
  32. # [--cipher cipher] [--hash hash] [--iterations iterations] 表示用于指定加密设置的选项,它们可以独立使用
  33. 例如: rabbitmqctl encode --cipher blowfish_cfb64 --hash sha256 --iterations 1000 '<<"guest">>' mypassphrase

 

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/IT小白/article/detail/126881
推荐阅读
相关标签
  

闽ICP备14008679号