HowTo: 配置多命名空间的发布订阅组件

在多命名空间中使用 Dapr 发布订阅

在某些场景中，应用程序可以分布在多个命名空间中，并通过 PubSub 共享队列或主题。在这种情况下，必须在每个命名空间中配置 PubSub 组件。

本示例使用 PubSub 示例。Redis 安装和订阅者位于 namespace-a 中，而发布者 UI 位于 namespace-b 中。如果 Redis 安装在另一个命名空间中，或者您使用托管云服务（如 Azure ServiceBus、AWS SNS/SQS 或 GCP PubSub），此解决方案也可以工作。

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



下表显示了哪些资源部署到哪些命名空间：

资源namespace-anamespace-b
Redis master✅❌
Redis replicas✅❌
Dapr 的 PubSub 组件✅✅
Node 订阅者✅❌
Python 订阅者✅❌
React UI 发布者❌✅

前置条件

设置 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

相关链接