跳到主要内容

用于 kubectl 的 RabbitMQ 集群操作符插件

安装用于 kubectl 的 RabbitMQ 集群操作符插件可以更轻松地将 RabbitMQ 集群 Kubernetes 操作符 安装到任何 Kubernetes 实例中，因为每个插件命令都会自动执行与 Kubernetes API 和 RabbitMQ 集群操作符的许多交互。该插件还包括用于 RabbitMQ 集群常见工作流程的多个命令。

要了解更多关于使用 RabbitMQ 集群操作符以及如何部署其管理的自定义资源对象的信息，请参阅使用 RabbitMQ 集群操作符信息。

安装用于 kubectl 的 RabbitMQ 集群操作符插件之前​

确保您已安装以下工具

  • Krew 是 kubectl 命令行工具的插件管理器。
  • kubectl

安装 krew 后，验证安装

kubectl krew

安装集群操作符 kubectl 插件​

当 krew 设置完成后，您现在可以安装 RabbitMQ 集群操作符插件。

kubectl krew install rabbitmq

要验证插件是否已安装，请获取可用命令的列表

kubectl rabbitmq help
# USAGE:
#   Install RabbitMQ Cluster Operator (optionally provide image to use a relocated image or a specific version)
#     kubectl rabbitmq install-cluster-operator [IMAGE]
# [...]

使用集群操作符 kubectl 插件​

创建 RabbitMQ 集群​

kubectl rabbitmq create INSTANCE

之前的命令创建了一个 RabbitMQ 集群，其中只配置了集群名称的一些基本配置。

获取 RabbitMQ 集群​

kubectl rabbitmq get INSTANCE

显示与命名 RabbitMQ 集群关联的所有 Kubernetes 资源，包括 pod、configmap、statefulset、service 和 secret。

NAME                     READY   STATUS    RESTARTS   AGE
pod/hello-rmq-server-0   0/1     Pending   0          5h31m

NAME                               DATA   AGE
configmap/hello-rmq-plugins-conf   1      5h31m
configmap/hello-rmq-server-conf    2      5h31m

NAME                                READY   AGE
statefulset.apps/hello-rmq-server   0/1     5h31m

NAME                      TYPE        CLUSTER-IP     EXTERNAL-IP   PORT(S)              AGE
service/hello-rmq         ClusterIP   10.100.156.4   none        5672/TCP,15672/TCP   5h31m
service/hello-rmq-nodes   ClusterIP   None           none        4369/TCP,25672/TCP   5h31m

NAME                             TYPE     DATA   AGE
secret/hello-rmq-default-user    Opaque   3      5h31m
secret/hello-rmq-erlang-cookie   Opaque   1      5h31m

列出所有 RabbitMQ 集群​

kubectl rabbitmq list

之前的命令列出了 RabbitMQ 集群操作符在目标 Kubernetes 实例上部署的所有 RabbitMQ 集群。

删除 RabbitMQ 集群​

kubectl rabbitmq delete INSTANCE

之前的命令删除一个 RabbitMQ 集群或多个 RabbitMQ 集群。删除多个 RabbitMQ 集群时，请提供以空格分隔的列表。

kubectl rabbitmq delete rmq1 rmq2 rmq3

打印 RabbitMQ 集群的默认用户密钥​

kubectl rabbitmq secrets INSTANCE

之前的命令列出命名 RabbitMQ 集群的默认用户密钥。

打开 RabbitMQ 管理 UI​

kubectl rabbitmq manage INSTANCE

之前的命令在浏览器中打开 RabbitMQ 管理 UI。

设置所有 RabbitMQ 节点的日志级别以进行调试​

kubectl rabbitmq debug INSTANCE

之前的命令将所有节点的日志级别设置为 debug。有关 RabbitMQ 日志记录的详细信息，请参阅日志记录信息。

追踪日志​

kubectl rabbitmq tail INSTANCE

运行之前的命令后，您将在控制台上看到远程 RabbitMQ 节点的所有日志输出。请注意，要运行之前的命令，您必须安装 tail 插件。

通过运行以下命令安装 tail 插件

kubectl krew install tail

观察 RabbitMQ 集群上的节点​

kubectl rabbitmq observe INSTANCE INDEX

之前的命令为给定节点打开 rabbitmq-diagnostics 观察者界面。

开启所有功能标志​

kubectl rabbitmq enable-all-feature-flags INSTANCE

之前的命令使用 rabbitmqctl 激活或开启所有可能的功能标志。

暂停 RabbitMQ 集群上的协调​

kubectl rabbitmq pause-reconciliation INSTANCE

之前的命令将标签 “rabbitmq.com/pauseReconciliation=true” 添加到目标 RabbitMQ 集群。该标签阻止操作符监视和更新实例。

恢复 RabbitMQ 集群上的协调​

kubectl rabbitmq resume-reconciliation INSTANCE

之前的命令指示操作符恢复 RabbitMQ 集群的协调。

列出已暂停协调的实例​

kubectl rabbitmq [list pause reconciliation instances](list-pause-reconciliation-instances) INSTANCE

之前的命令列出所有未被操作符协调的实例。

性能测试​

kubectl rabbitmq perf-test INSTANCE --rate 100

之前的命令针对实例运行 perf-test。您可以在此处传递任意数量的性能测试参数。

要监控 PerfTest，请添加以下 ServiceMonitor

  apiVersion: monitoring.coreos.com/v1
  kind: ServiceMonitor
  metadata:
    name: kubectl-perf-test
  spec:
    endpoints:
    - interval: 15s
      targetPort: 8080
    selector:
      matchLabels:
        app: perf-test

请在 GitHub 上提交关于 RabbitMQ 集群操作符的反馈和功能请求。

© . All rights reserved.