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

操作方法：使用多个命名空间配置发布/订阅组件

将 Dapr 发布/订阅与多个命名空间结合使用

在某些情况下，应用程序可以跨命名空间分布，并通过发布订阅共享队列或主题。 在这种情况下，必须在每个命名空间上都提供订阅发布组件。

这个例子使用了发布订阅示例。 Redis 安装和订阅服务器位于 namespace-a 中，而发布者 UI 位于 namespace-b。 如果 Redis 安装在另一个命名空间上，或者如果您使用 Azure ServiceBus、AWS SNS/SQS 或 GCP PubSub 等托管云服务，则此解决方案也有效。

这是使用命名空间的示例图片。



下表描述了部署的资源和所在命名空间的对应关系：

资源 namespace-a namespace-b
Redis master X
Redis replicas X
Dapr’s 发布订阅组件 X X
Node 订阅者 X
Python 订阅者 X
React UI 发布者 X

先决条件

设置 namespace-a

创建命名空间并切换 kubectl 以使用它。

kubectl create namespace namespace-a
kubectl config set-context --current --namespace=namespace-a

遵循这些说明，在 namespace-a 上安装 Redis（主从）。

现在，配置 deploy/redis.yaml，注意包含 namespace-a 的主机名。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
spec:
  type: pubsub.redis
  version: v1
  metadata:
  - name: "redisHost"
    value: "redis-master.namespace-a.svc:6379"
  - name: "redisPassword"
    value: "YOUR_PASSWORD"

将资源部署到 namespace-a：

kubectl apply -f deploy/redis.yaml
kubectl apply -f deploy/node-subscriber.yaml
kubectl apply -f deploy/python-subscriber.yaml

设置 namespace-b

创建命名空间并切换 kubectl 以使用它。

kubectl create namespace namespace-b
kubectl config set-context --current --namespace=namespace-b

将资源部署到 namespace-b，包括 Redis 组件:

kubectl apply -f deploy/redis.yaml
kubectl apply -f deploy/react-form.yaml

现在，找到 react-form 的 IP 地址，在浏览器上打开它，并将消息发布到每个主题（A、B 和 C）。

kubectl get service -A

确认订阅者已收到消息。

切换回 namespace-a:

kubectl config set-context --current --namespace=namespace-a

查找 POD 名称：

kubectl get pod # 复制POD名称并在接下来的命令中使用。

显示日志：

kubectl logs node-subscriber-XYZ node-subscriber
kubectl logs python-subscriber-XYZ python-subscriber

在浏览器上发布的消息应显示在相应订阅者的日志中。 Node.js 订阅者接收的消息类型为 “A” 和 “B”，而 Python 订阅者接收的消息类型为 “A” 和 “C”。

清理

kubectl delete -f deploy/redis.yaml  --namespace namespace-a
kubectl delete -f deploy/node-subscriber.yaml  --namespace namespace-a
kubectl delete -f deploy/python-subscriber.yaml  --namespace namespace-a
kubectl delete -f deploy/react-form.yaml  --namespace namespace-b
kubectl delete -f deploy/redis.yaml  --namespace namespace-b
kubectl config set-context --current --namespace=default
kubectl delete namespace namespace-a
kubectl delete namespace namespace-b

相关链接