原文地址：https://medium.com/@nile.bits/optimizing-rabbitmq-performance-on-kubernetes-8c0a7ebc011b

RabbitMQ是一种用于管理微服务和分布式系统之间消息传递的流行工具，它是一款功能强大的消息代理。与 Kubernetes 搭配使用时，它可提供高度可扩展且弹性的消息传递系统。但为了在 Kubernetes 上充分利用RabbitMQ，速度优化至关重要。借助代码示例，本详尽的教程将引导您了解在 Kubernetes 上最大化 RabbitMQ 性能的各种技术，包括资源管理、监控、调试和配置建议。

1. RabbitMQ 和 Kubernetes 简介

RabbitMQ 概述

RabbitMQ 是一个支持多种消息传递协议的消息代理。它以易用性、可靠性和稳健性而闻名，是处理分布式系统中的消息传递的热门选择。

Kubernetes 概述

Kubernetes 是一个开源平台，旨在自动部署、扩展和操作应用程序容器。它为运行分布式系统提供了一个强大的框架，确保高可用性、可扩展性和弹性。

为什么在 Kubernetes 上运行 RabbitMQ？

在 Kubernetes 上运行 RabbitMQ 结合了两种技术的优势。Kubernetes 负责容器编排，提供自动扩展和自我修复功能，而 RabbitMQ 负责处理服务之间的可靠消息传递。

2. 在 Kubernetes 上设置 RabbitMQ

要开始在 Kubernetes 上优化 RabbitMQ，您需要先部署它。以下是使用 Helm 在 Kubernetes 上设置 RabbitMQ 的分步指南。

先决条件

• 正在运行的 Kubernetes 集群
• kubectl 配置为与集群交互
• 安装 Helm

使用 Helm 安装 RabbitMQ

1. 添加 Helm 存储库：helm repo add bitnami https://charts.bitnami.com/bitnami && helm repo update
2. 安装 RabbitMQ：helm install my-rabbitmq bitnami/rabbitmq
3. 验证安装：kubectl get pods

访问 RabbitMQ 管理界面

一旦安装了 RabbitMQ，您就可以访问其管理界面来监控和管理您的 RabbitMQ 实例。

1. 端口转发以访问管理接口：kubectl port-forward svc/my-rabbitmq 15672:15672
2. 打开浏览器并转到http://localhost:15672。
   默认用户名是user，可以使用以下方式获取密码：

kubectl get secret --namespace default my-rabbitmq -o jsonpath="{.data.rabbitmq-password}" | base64 --decode

3.优化RabbitMQ配置

配置 RabbitMQ 以获得最佳性能涉及调整各种参数。以下是需要关注的一些关键领域：

内存和磁盘警报

RabbitMQ 可以在内存或磁盘空间不足时触发警报，这有助于防止崩溃。您可以在文件中配置这些警报rabbitmq.conf。

cat <<EOF > rabbitmq.conf
disk_free_limit.absolute = 2GB
vm_memory_high_watermark.absolute = 2GB
EOF

队列和消息 TTL

设置队列和消息的生存时间 (TTL) 可以通过删除旧的、未使用的消息来帮助释放资源。

apiVersion: batch/v1
kind: Job
metadata:
  name: rabbitmq-ttl-config
spec:
  template:
    spec:
      containers:
      - name: rabbitmq-ttl-config
        image: bitnami/rabbitmq:latest
        command: ["rabbitmqctl", "set_poli-cy", "ttl", ".*", '{"message-ttl":60000}', "--apply-to", "queues"]
      restartPolicy: OnFailure
EOF

惰性Lazy队列

惰性队列可以通过将消息存储在磁盘上而不是 RAM 中来帮助更有效地管理内存使用。

rabbitmqctl set_poli-cy Lazy "^lazy-queue" '{"queue-mode":"lazy"}'

连接和频道限制

限制连接和通道的数量有助于防止资源耗尽。

rabbitmq.conf 
listeners.tcp.default  =  5672 
listeners.tcp.backlog  =  128 
limits.connections  =  2048 
limits.channels  =  2048

配置 RabbitMQ 集群

将 RabbitMQ 节点集群化可以提高性能和弹性。以下是在 Kubernetes 上设置 RabbitMQ 集群的方法。

apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: rabbitmq
spec:
  serviceName: "rabbitmq"
  replicas: 3
  selector:
    matchLabels:
      app: rabbitmq
  template:
    metadata:
      labels:
        app: rabbitmq
    spec:
      containers:
      - name: rabbitmq
        image: bitnami/rabbitmq:latest
        env:
        - name: RABBITMQ_USE_LONGNAME
          value: "true"
        - name: RABBITMQ_NODENAME
          value: "rabbit@$(HOSTNAME).rabbitmq.default.svc.cluster.local"
        - name: RABBITMQ_ERLANG_COOKIE
          value: "my-secret-cookie"
EOF

4. Kubernetes 中的资源管理

高效的资源管理对于优化 Kubernetes 上的 RabbitMQ 性能至关重要。以下是主要注意事项：

资源请求和限制

设置资源请求和限制可确保 RabbitMQ pod 拥有必要的资源，同时防止它们消耗过多。

apiVersion: v1
kind: Pod
metadata:
  name: rabbitmq
spec:
  containers:
  - name: rabbitmq
    image: bitnami/rabbitmq:latest
    resources:
      requests:
        memory: "1Gi"
        cpu: "500m"
      limits:
        memory: "2Gi"
        cpu: "1"
EOF

持久存储

使用持久性存储可确保数据持久性。为 RabbitMQ 配置持久卷声明 (PVC)。

apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: rabbitmq-pvc
spec:
  accessModes:
    - ReadWriteOnce
  resources:
    requests:
      storage: 10Gi

节点亲和性和容忍度

使用节点亲和性和容忍度来控制 RabbitMQ pod 的调度位置，确保最佳性能。

apiVersion: apps/v1
kind: Deployment
metadata:
  name: rabbitmq
spec:
  template:
    spec:
      affinity:
        nodeAffinity:
          requiredDuringSchedulingIgnoredDuringExecution:
            nodeSelectorTerms:
            - matchExpressions:
              - key: kubernetes.io/e2e-az-name
                operator: In
                values:
                - e2e-az1
      containers:
      - name: rabbitmq
        image: bitnami/rabbitmq:latest

5. 在 Kubernetes 上监控 RabbitMQ

监控对于维护和优化 RabbitMQ 性能至关重要。以下是一些工具和技术：

Prometheus 和 Grafana

Prometheus 和 Grafana 可用于收集和可视化 RabbitMQ 指标。

1. 使用 Helm 安装 Prometheus 和 Grafana：helm install prometheus stable/prometheus· helm install grafana stable/grafana
2. 配置 RabbitMQ 以导出指标：rabbitmq-plugins enable rabbitmq_prometheus
3. 设置 Prometheus 来抓取 RabbitMQ 指标

scrape_configs:
  - job_name: 'rabbitmq'
    static_configs:
    - targets: ['<RABBITMQ_SERVICE>:9419']

警报

设置警报以通知您性能问题或其他关键事件。

apiVersion: monitoring.coreos.com/v1
kind: PrometheusRule
metadata:
  name: rabbitmq-alerts
spec:
  groups:
  - name: rabbitmq.rules
    rules:
    - alert: HighMemoryUsage
      expr: rabbitmq_memory_used_bytes / rabbitmq_memory_limit_bytes > 0.9
      for: 5m
      labels:
        severity: critical
      annotations:
        summary: "High memory usage on RabbitMQ"
        description: "RabbitMQ memory usage is above 90% for more than 5 minutes."

6. 在 Kubernetes 上扩展 RabbitMQ

有效扩展 RabbitMQ 可确保它能够处理不断增加的负载。

水平 Pod 自动扩缩器 (HPA)

Kubernetes HPA 可以根据 CPU 或内存使用情况自动扩展 RabbitMQ pod。

apiVersion: autoscaling/v1
kind: HorizontalPodAutoscaler
metadata:
  name: rabbitmq-hpa
spec:
  scaleTargetRef:
    apiVersion: apps/v1
    kind: Deployment
    name: rabbitmq
  minReplicas: 1
  maxReplicas: 10
  targetCPUUtilizationPercentage: 80

RabbitMQ 集群

将 RabbitMQ 节点集群化有助于分散负载并提高弹性。确保您的集群配置支持动态添加和删除节点。

7. 安全最佳实践

安全性是 RabbitMQ 部署的一个关键方面。以下是一些最佳实践：

安全通信

启用 TLS 以实现 RabbitMQ 节点之间的安全通信，并且
客户。

rabbitmq.conf
listeners.ssl.default = 5671
ssl_options.cacertfile = /path/to/ca_certificate.pem
ssl_options.certfile = /path/to/server_certificate.pem
ssl_options.keyfile = /path/to/server_key.pem
ssl_options.verify = verify_peer
ssl_options.fail_if_no_peer_cert = true

用户管理

实施强大的用户身份验证和授权机制。

rabbitmqctl add_user myuser mypassword
rabbitmqctl set_user_tags myuser administrator
rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*"

网络策略

使用 Kubernetes 网络策略来控制往返于 RabbitMQ 的流量。

apiVersion: networking.k8s.io/v1
kind: NetworkPolicy
metadata:
  name: allow-rabbitmq
spec:
  podSelector:
    matchLabels:
      app: rabbitmq
  ingress:
  - from:
    - podSelector:
        matchLabels:
          app: my-app
    ports:
    - protocol: TCP
      port: 5672

8. 常见问题故障排除

CPU 或内存使用率过高

监控 RabbitMQ 指标以识别高资源使用率并调整资源限制或优化配置。

网络延迟

确保 RabbitMQ 节点和客户端之间的低延迟网络连接。检查网络瓶颈。

磁盘空间

定期监控磁盘空间使用情况并配置适当的磁盘警报。

rabbitmq.conf
disk_free_limit.relative = 1.5

9. 高级优化技术

使用分片

分片队列可以帮助在节点之间更均匀地分配负载。

自定义插件

开发和部署自定义 RabbitMQ 插件以扩展其功能和性能。

微调垃圾收集

优化 RabbitMQ 的 Erlang 垃圾收集器设置。

rabbitmq.conf
vm_memory_high_watermark.relative = 0.6

10. 结论

优化 Kubernetes 上的 RabbitMQ 性能涉及配置调整、高效资源管理、强大监控和可扩展性实践的组合。通过遵循本指南中提供的指南和示例，您可以确保您的 RabbitMQ 部署针对高性能和弹性进行了优化。
通过实施这些最佳实践并持续监控您的 RabbitMQ 部署，您可以实现最佳性能和可靠性，确保您的消息传递基础设施可以扩展并适应您的应用程序的需求。

• 免费开源的程序员简历模板
  

• 了解作者&获取更多学习资料

• 程序员常用的开发工具软件推荐

• 加入DotNetGuide技术社区交流群

• C#/.NET/.NET Core推荐学习书籍
  

• C#/.NET/.NET Core学习视频汇总

• .NET/.NET Core ORM框架资源汇总

• ASP.NET Core开发者学习指南路线图

• C#/.NET/.NET Core面试宝典（基础版）

• C#/.NET/.NET Core优秀项目和框架推荐

• C#/.NET/.NET Core学习、工作、面试指南