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

如何操作:配置 状态存储 和 发布/订阅 消息代理

配置Dapr的状态存储和 发布/订阅 消息代理

为了启动和运行状态和 发布/订阅 构建块,需要两个组件。

  1. 一个用于持久化和恢复的状态存储组件。
  2. 作为发布/订阅消息代理组件,用于异步式的消息传递。

支持的组件的完整列表可以在这里找到:

此页的其余部分描述了如何使用Redis启动和运行。

创建Redis存储

Dapr可以使用任何Redis实例–无论是在本地开发机器上的容器化的还是在托管云服务上的。 如果您已经有了Redis存储,请转到 配置 部分。


作为初始化过程的一部分,Dapr CLI 会自动在自托管环境中安装 Redis。 您都已设置完毕,可以跳转到[下一步](下一步)


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

  1. 安装 Redis 到您的集群:

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

    请注意,您将需要 Redis 版本大于 5, 这是Dapr 的 发布/订阅 功能所要求的。 如果你打算将Redis仅仅作为一个状态存储(而不是用于 发布/订阅),可以使用一个低版本。

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

    $ kubectl get pods
    NAME             READY   STATUS    RESTARTS   AGE
    redis-master-0   1/1     Running   0          69s
    redis-slave-0    1/1     Running   0          69s
    redis-slave-1    1/1     Running   0          22s
    

请注意,主机名是 redis-master.default.svc.cluster.local:6379,Kubernetes 密钥 redis是自动创建的。


此方法需要 Azure 订阅。

  1. 打开 Azure Portal 来启动 Azure Redis Cache 创建流程。 如有必要,请登录。
  2. 填写必要的信息
    • Dapr 发布/订阅 使用 Redis streams ,这是由Redis 5.0引入的。 如果您想使用 Azure Redis Cache 来处理 发布/订阅,请确保将版本设置为 (PREVIEW) 6。
  3. 点击“创建”来启动您的 Redis 实例的部署。
  4. 你需要Redis实例的主机名,你可以从Azure中的 “概述 “中检索。 它看起来像 xxxxxx.redis.cache.windows.net:6380。 注意这一点,以备后用。
  5. 创建实例后,您需要获取访问密钥。 在“设置”下导航到"访问密钥"并创建一个Kubernetes密钥来存储您的 Redis 密码:
    kubectl create secret generic redis --from-literal=redis-password=*********
    

  1. 访问 AWS Redis 来部署一个 Redis 实例
  2. 注意AWS门户中的Redis主机名,以便以后使用。
  3. 创建一个Kubernetes密钥来存储您的 Redis 密码:
    kubectl create secret generic redis --from-literal=redis-password=*********
    

  1. 访问 GCP Cloud MemoryStore 来部署一个 MemoryStore 实例
  2. 注意GCP门户中的Redis主机名,以便以后使用。
  3. 创建一个Kubernetes密钥来存储您的 Redis 密码:
    kubectl create secret generic redis --from-literal=redis-password=*********
    

配置 Dapr 组件

Dapr 使用组件来定义用于构建块功能的资源。 这些步骤通过如何将你上面创建的资源连接到Dapr的 状态 和 发布/订阅 。

在自托管模式下,组件文件自动创建以下内容:

  • Windows: %USERPROFILE%\.dapr\components\
  • Linux/MacOS: $HOME/.dapr/components

对于Kubernetes来说,文件可以在任何目录下创建,因为它们是用kubectl应用的。

创建 状态 存储组件

创建名为 redis-state.yaml 的文件, 并粘贴以下内容:

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
  namespace: default
spec:
  type: state.redis
  version: v1
  metadata:
  - name: redisHost
    value: <REPLACE WITH HOSTNAME FROM ABOVE - for Redis on Kubernetes it is redis-master.default.svc.cluster.local:6379>
  - name: redisPassword
    secretKeyRef:
      name: redis
      key: redis-password

这个例子使用的是用上面的说明设置集群时创建的 kubernetes 密钥。

创建 发布/订阅 消息代理组件

创建名为 redis-pubsub.yaml 的文件, 并粘贴以下内容:

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
  namespace: default
spec:
  type: pubsub.redis
  version: v1
  metadata:
  - name: redisHost
    value: <REPLACE WITH HOSTNAME FROM ABOVE - for Redis on Kubernetes it is redis-master.default.svc.cluster.local:6379>
  - name: redisPassword
    secretKeyRef:
      name: redis
      key: redis-password

这个例子使用的是用上面的说明设置集群时创建的 kubernetes 密钥。

硬编码密码(不推荐)

仅用于开发目的,你可以跳过创建 kubernetes 密钥,直接将密码放入 Dapr 组件文件中。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
  namespace: default
spec:
  type: state.redis
  version: v1
  metadata:
  - name: redisHost
    value: <HOST>
  - name: redisPassword
    value: <PASSWORD>
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
  namespace: default
spec:
  type: pubsub.redis
  version: v1
  metadata:
  - name: redisHost
    value: <HOST>
  - name: redisPassword
    value: <PASSWORD>

应用配置


默认情况下,当你运行 dapr init 时,CLI 创建一个本地的 Redis 实例。 但是,如果你想要配置一个不同的 Redis 实例你可以:

  • 更新现有的组件文件或在默认的组件目录下创建新的组件文件。
    • Linux/MacOS: $HOME/.dapr/components
    • Windows: %USERPROFILE%\.dapr\components
  • 在你的应用程序文件夹中创建一个新的components目录,其中包含YAML文件,并提供dapr run命令的路径,标志为--components-path

运行 kubectl apply -f <FILENAME> 同时适用于 状态文件 和 发布订阅文件:

kubectl apply -f redis-state.yaml
kubectl apply -f redis-pubsub.yaml

下一步