The documentation you are viewing is for Dapr v1.1 which is an older version of Dapr. For up-to-date documentation, see the latest version.

Redis Streams

关于Redis Streams pubsub组件的详细文档

配置

要设置Redis Streams pubsub，请创建一个类型为pubsub.redis的组件。 请参阅本指南，了解如何创建和应用 pubsub 配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: redis-pubsub
  namespace: default
spec:
  type: pubsub.redis
  version: v1
  metadata:
  - name: redisHost
    value: localhost:6379
  - name: redisPassword
    value: "KeFg23!"
  - name: consumerID
    value: "myGroup"
  - name: enableTLS
    value: "false"

元数据字段规范

字段 必填 详情 示例
redisHost Y Redis的连接地址 localhost:6379, redis-master.default.svc.cluster.local:6379
redisPassword Y Redis的密码 无默认值 可以用secretKeyRef来引用密钥。 "", "KeFg23!"
consumerID N 消费组 ID "mygroup"
enableTLS N 如果Redis实例支持使用公共证书的TLS，可以配置为启用或禁用。 默认值为 "false" "true", "false"
redeliverInterval N 检查待处理消息到重发的间隔。 默认为 "60s". "0" 禁用重发。 "30s"
processingTimeout N 在尝试重新发送消息之前必须等待的时间。 默认为 "15s"。 "0" 禁用重发。 "30s"
queueDepth N 用于处理的消息队列的大小。 默认值为 "100". "1000"
并发（Concurrency） N 正在处理消息的并发工作线程数。 默认值为 "10". "15"

创建Redis实例

Dapr可以使用任何Redis实例，无论是容器化的，运行在本地开发机器上的，或者是托管的云服务，前提是Redis的版本是5.0.0或更高。


Dapr CLI将自动为你创建和设置一个Redis Streams实例。 当你执行dapr init时，Redis实例将通过Docker安装，组件文件将在默认目录下创建。 (默认目录位于$HOME/.dapr/components (Mac/Linux) ，%USERPROFILE%\.dapr\components (Windows)).


您可以使用 helm 在我们的 Kubernetes 集群中快速创建 dapr 实例。 这种方法需要安装Helm。

  1. 安装 Redis 到你的集群：

    helm repo add bitnami https://charts.bitnami.com/bitnami
helm install redis bitnami/redis

  2. 执行kubectl get pods来查看现在正在集群中运行的Redis容器。

  3. 在您的redis.yaml文件中添加redis-master:6379作为redisHost。 例如:

        metadata:
    - name: redisHost
      value: redis-master:6379

  4. 接下来，我们会获取到我们的Redis密码，根据我们使用的操作系统不同，密码也会略有不同：

    • Windows：执行kubectl get secret --namespace default redis -o jsonpath="{.data.redis-password}" > encoded.b64，这将创建一个有你的加密后密码的文件。 接下来，执行certutil -decode encoded.b64 password.txt，它将把你的redis密码放在一个名为password.txt的文本文件中。 复制密码，删除这两个文件。

    • Linux/MacOS：执行 kubectl get secret --namespace default redis -o jsonpath="{.data.redis-password}" | base64 --decode并复制输出的密码。

    将此密码设置为redis.yaml文件的redisPassword的值。 例如:

        - name: redisPassword
      value: "lhDOkwTlp0"

相关链接

Last modified January 1, 0001