“Rabbitmq常用命令”的版本间的差异
跳到导航
跳到搜索
(未显示同一用户的13个中间版本) | |||
第13行: | 第13行: | ||
<pre> | <pre> | ||
− | #为 vhost hello 开启镜像 | + | #为 vhost hello 开启镜像 ,策略名称名为 mirror4_hello |
rabbitmqctl set_policy -p hello mirror4_hello "^" '{"ha-mode":"all"}' | rabbitmqctl set_policy -p hello mirror4_hello "^" '{"ha-mode":"all"}' | ||
Setting policy "mirror4_hello" for pattern "^" to "{\"ha-mode\":\"all\"}" with priority "0" | Setting policy "mirror4_hello" for pattern "^" to "{\"ha-mode\":\"all\"}" with priority "0" | ||
第47行: | 第47行: | ||
https://www.rabbitmq.com/rabbitmqctl.8.html | https://www.rabbitmq.com/rabbitmqctl.8.html | ||
+ | |||
+ | 注意 看人家有加 HAProxy 代理服务器 | ||
+ | [https://www.yisu.com/zixun/115327.html RabbitMQ集群架构模式及搭建Rabbitmq-Mirror镜像集群] | ||
= * Rabbitmq 用户角色及权限控制= | = * Rabbitmq 用户角色及权限控制= | ||
第112行: | 第115行: | ||
rabbitmqctl list_users</pre> | rabbitmqctl list_users</pre> | ||
+ | |||
+ | =v host= | ||
+ | <pre> | ||
+ | Virtual Hosts管理 | ||
+ | |||
+ | 删除的 点击进去 详情下面就是删除了 | ||
+ | |||
+ | </pre> | ||
=运维常用命令= | =运维常用命令= | ||
第121行: | 第132行: | ||
+ | </pre> | ||
+ | ==rabbitmqadmin 命令汇总:== | ||
+ | <pre> | ||
+ | |||
+ | 命令 解释 | ||
+ | rabbitmqadmin list users 查看所有用户 User | ||
+ | rabbitmqadmin list users name 查看所有用户名 Username | ||
+ | rabbitmqadmin list users tags 查看所有用户角色 | ||
+ | rabbitmqadmin list vhosts 查看所有虚拟主机 | ||
+ | rabbitmqadmin list connections 查看所有连接 | ||
+ | rabbitmqadmin list exchanges 查看所有路由 Exchange | ||
+ | rabbitmqadmin list bindings 查看所有路由与队列的关系绑定 Binding | ||
+ | rabbitmqadmin list permissions 查看所有角色的权限 Permission | ||
+ | rabbitmqadmin list channels 查看所有通道 Channel | ||
+ | rabbitmqadmin list consumers 查看所有消费者 Consumer | ||
+ | rabbitmqadmin list queues 查看所有消息队列 Queue | ||
+ | rabbitmqadmin list nodes 查看所有节点 Node | ||
+ | rabbitmqadmin show overview 概览 Overview | ||
+ | rabbitmqadmin list bindings source destination_type destination properties_key 查看所有路由与队列的关系绑定的详细信息 Binding | ||
+ | rabbitmqadmin declare queue name=test durable=true 定义一个队列queue,durable=true代表持久化打开。 | ||
+ | rabbitmqadmin declare exchange name=my.fanout type=fanout 定义一个Fanout路由 | ||
+ | rabbitmqadmin declare exchange name=my.direct type=direct 定义一个Direct路由 | ||
+ | rabbitmqadmin declare exchange name=my.topic type=topic 定义一个Topic路由 | ||
+ | rabbitmqadmin declare binding source=my.fanout destination=test routing_key=first 定义 binding | ||
+ | rabbitmqadmin publish routing_key=test payload="hello world" 发布一条消息 | ||
+ | rabbitmqadmin publish routing_key=my.test exchange=my.topic payload="hello world" 使用路由转发消息 | ||
+ | rabbitmqadmin get queue=test requeue=true 查看消息,不消费 | ||
+ | rabbitmqadmin get queue=test requeue=false 查看消息,并消费 | ||
+ | rabbitmqadmin purge queue name=test 删除队列中的所有消息 清空队列 | ||
+ | rabbitmqadmin delete queue name=hello 删除消息队列 Queue | ||
+ | rabbitmqadmin delete user name=test 删除用户 User | ||
+ | rabbitmqadmin delete exchange name=test 删除路由器 Exchange | ||
+ | rabbitmqadmin delete binding source='kk' destination_type=queue destination=test properties_key=test 删除路由器与消息队列的关系绑定 Binding | ||
+ | rabbitmqadmin -f raw_json list users raw_json 格式化输出 | ||
+ | rabbitmqadmin -f long list users 格式化输出 | ||
+ | rabbitmqadmin -f pretty_json list users pretty_json 格式化输出 | ||
+ | rabbitmqadmin -f kvp list users 格式化输出 | ||
+ | rabbitmqadmin -f tsv list users 格式化输出 | ||
+ | rabbitmqadmin -f table list users table 格式化输出 | ||
+ | rabbitmqadmin -f bash list users bash 格式化输出 | ||
</pre> | </pre> | ||
==NOTE== | ==NOTE== | ||
注意 运维 例如查看队列 是用 rabbitmqadmin ,rabbitmqadmin --username=admin --password=333 list queues 不是 rabbitmqctl list_queues 早上 同桌也说是这个 ,搞半天 还以为集群坏了呢 还看什么日志 | 注意 运维 例如查看队列 是用 rabbitmqadmin ,rabbitmqadmin --username=admin --password=333 list queues 不是 rabbitmqctl list_queues 早上 同桌也说是这个 ,搞半天 还以为集群坏了呢 还看什么日志 | ||
+ | [https://blog.csdn.net/heirenyagao112/article/details/113527184 rabbitmqctl 命令行操作命令] | ||
+ | [https://blog.csdn.net/liao0801_123/article/details/91524878?spm=1001.2101.3001.6650.1&utm_medium=distribute.pc_relevant.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1.pc_relevant_antiscanv2&depth_1-utm_source=distribute.pc_relevant.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1.pc_relevant_antiscanv2&utm_relevant_index=2 通过rabbitMQ的管理命令rabbitmqctl, 创建queue和exchange并绑定路由] | ||
=RabbitMQ 概念:= | =RabbitMQ 概念:= | ||
第138行: | 第191行: | ||
Channel 消息通道,在客户端的每个连接里,可建立多个 channel,每个 channel 代表一个会话任务 | Channel 消息通道,在客户端的每个连接里,可建立多个 channel,每个 channel 代表一个会话任务 | ||
</pre> | </pre> | ||
+ | =other= | ||
+ | [https://blog.csdn.net/weixin_33705053/article/details/88008866 RabbitMQ实战:界面管理和监控] | ||
+ | |||
+ | [https://blog.csdn.net/jinixin/article/details/84038616 「消息队列」RabbitMQ监控与管理] | ||
+ | |||
=查看 RabbitMQ日志= | =查看 RabbitMQ日志= | ||
第143行: | 第201行: | ||
[https://blog.csdn.net/weixin_33716941/article/details/90324587 学会查看 RabbitMQ日志] | [https://blog.csdn.net/weixin_33716941/article/details/90324587 学会查看 RabbitMQ日志] | ||
+ | |||
+ | =troubleshooting= | ||
+ | |||
+ | rabbitmq web 清空 queue 报错 Access refused. - access to | ||
+ | |||
+ | 原来有个 vhost没添加到 admin用户里面呢 添加一下就行了 | ||
+ | https://blog.csdn.net/Dearbb1/article/details/84455591 | ||
=* see alse= | =* see alse= | ||
[https://blog.csdn.net/zyz511919766/article/details/42292655 RabbitMQ用户角色及权限控制] | [https://blog.csdn.net/zyz511919766/article/details/42292655 RabbitMQ用户角色及权限控制] | ||
+ | [https://blog.csdn.net/chenshourui/article/details/81203770 rabbitmq学习笔记2 : 添加用户和virtual hosts] | ||
+ | |||
+ | |||
+ | [https://www.cnblogs.com/xishuai/p/rabbitmq-cli-rabbitmqadmin.html RabbitMQ CLI 管理工具 rabbitmqadmin(管理和监控)] | ||
+ | |||
+ | |||
+ | [https://www.rabbitmq.com/management-cli.html Management Command Line Tool官网] | ||
+ | |||
+ | [https://www.jianshu.com/p/8414cd70bef1 05_RabbitMQ 的CLI管理工具 rabbitmqadmin] | ||
− | |||
[[category:ops]] | [[category:ops]] |
2022年11月25日 (五) 02:20的最新版本
目录
创建vhost
#创建 lxtx_hello vhost rabbitmqctl add_vhost /hello 为用户设置virtual host 权限 用户为admin: rabbitmqctl set_permissions -p /hello admin '.*' '.*' '.*' rabbitmqctl delete_vhost /hello
开启镜像模式
#为 vhost hello 开启镜像 ,策略名称名为 mirror4_hello rabbitmqctl set_policy -p hello mirror4_hello "^" '{"ha-mode":"all"}' Setting policy "mirror4_hello" for pattern "^" to "{\"ha-mode\":\"all\"}" with priority "0" #默认vhost rabbitmqctl set_policy mirror4_newcailuw "^" '{"ha-mode":"all"}' #书面一点的解说 #这行命令在vhost名称为hello创建了一个策略,策略名称为mirror4_hello ,策略模式为 all 即复制到所有节点,包含新增节点,策略正则表达式为 “^” 表示所有匹配所有队列名称 参数 ha-mode:策略键 1.all 队列镜像在群集中的所有节点上。当新节点添加到群集时,队列将镜像到该节点 2.exactly 集群中的队列实例数。 3.nodes 队列镜像到节点名称中列出的节点。 ha-sync-mode:队列同步 1.manual手动<默认模式>.新的队列镜像将不会收到现有的消息,它只会接收新的消息。 2.automatic自动同步.当一个新镜像加入时,队列会自动同步。队列同步是一个阻塞操作。 作者:全能程序猿 链接:https://www.jianshu.com/p/f81d62a8de02 来源:简书 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
https://www.rabbitmq.com/parameters.html
https://www.rabbitmq.com/rabbitmqctl.8.html
注意 看人家有加 HAProxy 代理服务器 RabbitMQ集群架构模式及搭建Rabbitmq-Mirror镜像集群
* Rabbitmq 用户角色及权限控制
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使用情况 查看真正的关于所有virtual hosts的全局的统计信息 administrator policymaker和monitoring可以做的任何事外加: 创建和删除virtual hosts 查看、创建和删除users 查看创建和删除permissions 关闭其他用户的connections
Note
administrator一定能看到 cluster信息,manager不行 monitoring 也可以
* 创建用户
** 新增用户admin,密码1234 rabbitmqctl add_user admin 1234 ** 也可以使用rabbitmqctl命令更改密码 rabbitmqctl change_password admin adm ** 将admin加入到管理员组 赋予其management角色: rabbitmqctl set_user_tags admin administrator ** 查看用户列表 rabbitmqctl list_users
v host
Virtual Hosts管理 删除的 点击进去 详情下面就是删除了
运维常用命令
rabbitmqadmin
一般情况下,我们会使用 rabbitmq_management 插件,通过 Web UI 的方式来监控和操作 RabbitMQ(端口 15672),但有时候命令的方式会更加方便一些,RabbitMQ 提供了 CLI 管理工具 rabbitmqadmin ,其实就是基于 RabbitMQ 的 HTTP API,用 Python 写的一个脚本。
rabbitmqadmin 命令汇总:
命令 解释 rabbitmqadmin list users 查看所有用户 User rabbitmqadmin list users name 查看所有用户名 Username rabbitmqadmin list users tags 查看所有用户角色 rabbitmqadmin list vhosts 查看所有虚拟主机 rabbitmqadmin list connections 查看所有连接 rabbitmqadmin list exchanges 查看所有路由 Exchange rabbitmqadmin list bindings 查看所有路由与队列的关系绑定 Binding rabbitmqadmin list permissions 查看所有角色的权限 Permission rabbitmqadmin list channels 查看所有通道 Channel rabbitmqadmin list consumers 查看所有消费者 Consumer rabbitmqadmin list queues 查看所有消息队列 Queue rabbitmqadmin list nodes 查看所有节点 Node rabbitmqadmin show overview 概览 Overview rabbitmqadmin list bindings source destination_type destination properties_key 查看所有路由与队列的关系绑定的详细信息 Binding rabbitmqadmin declare queue name=test durable=true 定义一个队列queue,durable=true代表持久化打开。 rabbitmqadmin declare exchange name=my.fanout type=fanout 定义一个Fanout路由 rabbitmqadmin declare exchange name=my.direct type=direct 定义一个Direct路由 rabbitmqadmin declare exchange name=my.topic type=topic 定义一个Topic路由 rabbitmqadmin declare binding source=my.fanout destination=test routing_key=first 定义 binding rabbitmqadmin publish routing_key=test payload="hello world" 发布一条消息 rabbitmqadmin publish routing_key=my.test exchange=my.topic payload="hello world" 使用路由转发消息 rabbitmqadmin get queue=test requeue=true 查看消息,不消费 rabbitmqadmin get queue=test requeue=false 查看消息,并消费 rabbitmqadmin purge queue name=test 删除队列中的所有消息 清空队列 rabbitmqadmin delete queue name=hello 删除消息队列 Queue rabbitmqadmin delete user name=test 删除用户 User rabbitmqadmin delete exchange name=test 删除路由器 Exchange rabbitmqadmin delete binding source='kk' destination_type=queue destination=test properties_key=test 删除路由器与消息队列的关系绑定 Binding rabbitmqadmin -f raw_json list users raw_json 格式化输出 rabbitmqadmin -f long list users 格式化输出 rabbitmqadmin -f pretty_json list users pretty_json 格式化输出 rabbitmqadmin -f kvp list users 格式化输出 rabbitmqadmin -f tsv list users 格式化输出 rabbitmqadmin -f table list users table 格式化输出 rabbitmqadmin -f bash list users bash 格式化输出
NOTE
注意 运维 例如查看队列 是用 rabbitmqadmin ,rabbitmqadmin --username=admin --password=333 list queues 不是 rabbitmqctl list_queues 早上 同桌也说是这个 ,搞半天 还以为集群坏了呢 还看什么日志
rabbitmqctl 命令行操作命令 通过rabbitMQ的管理命令rabbitmqctl, 创建queue和exchange并绑定路由
RabbitMQ 概念:
概念 详解 Exchange 消息交换机,它指定消息按什么规则,路由到哪个队列 Queue 消息队列,每个消息都会被投入到一个或多个队列 Binding 绑定,它的作用就是把 exchange 和 queue 按照路由规则绑定起来 Routing Key 路由关键字,exchange 根据这个关键字进行消息投递 Vhost 虚拟主机,可以开设多个 vhost,用作不同用户的权限分离 Producer 消息生产者,就是投递消息的程序 Consumer 消息消费者,就是接受消息的程序 Channel 消息通道,在客户端的每个连接里,可建立多个 channel,每个 channel 代表一个会话任务
other
查看 RabbitMQ日志
troubleshooting
rabbitmq web 清空 queue 报错 Access refused. - access to
原来有个 vhost没添加到 admin用户里面呢 添加一下就行了 https://blog.csdn.net/Dearbb1/article/details/84455591
* see alse
rabbitmq学习笔记2 : 添加用户和virtual hosts
RabbitMQ CLI 管理工具 rabbitmqadmin(管理和监控)