訂閱消息組件由 redis 改為 rabbitmq

剛開始測試 dapr 時為了圖省事，使用了 pubsub.redis，現在准備上生產環境，改用支持消息持久化的 pubsub.rabbitmq。

之前使用的 pubsub.redis 資源清單如下

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
  namespace: production
spec:
  type: pubsub.redis
  version: v1
  metadata:
    - name: redisHost
      value: redis-master.production.svc.cluster.local:6379
    - name: redisPassword
      secretKeyRef:
        name: redis
        key: redis-password

用 helm 安裝 rabbitmq，使用 chart 的是 bitnami/rabbitmq

$ helm repo add bitnami https://charts.bitnami.com/bitnami
$ helm install rabbitmq bitnami/rabbitmq

Persistent volume 是通過 kubernets dynamic volume provisioning 動態創建，StorageClass 用的是阿里雲 nas。

apiVersion: storage.k8s.io/v1
kind: StorageClass
metadata:
  name: sc-nas-production-pvs
  annotations:
    storageclass.kubernetes.io/is-default-class: "true"
mountOptions:
  - nolock,tcp,noresvport
  - vers=3
parameters:
  volumeAs: subpath
  server: xxxxxx.cn-hangzhou.extreme.nas.aliyuncs.com:/production/k8s-pvs/
provisioner: nasplugin.csi.alibabacloud.com
reclaimPolicy: Retain

pubsub.rabbitmq 的資源清單如下

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
  namespace: production
spec:
  type: pubsub.rabbitmq
  version: v1
  metadata:
    - name: host
      value: "amqp://user:[e-mail]:5672"
    - name: durable
      value: true

需要注意的是 host 參數部分，user:password 是連接 rabbitmq 的用戶名與密碼， 用 bitnami/rabbitmq chart 創建的 rabbitmq 默認用戶名就是 user，密碼在 secret 中，可以通過下面的命令獲取

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

Apply 上面的 rabbitmq-pubsub.yaml，發布/訂閱消息組件就變成 rabbitmq，不用改1行應用代碼，dapr 的優勢立馬體現。