操作:配置具有多个命名空间的 Pub/Sub 组件

多个命名空间下使用Dapr Pub/Sub

在某些场景下,应用程序分布在不同的命名空间,并通过PubSub共享一个队列或主题。 在这种情况下,必须在每个命名空间上都提供PubSub组件。

这个例子使用了PubSub示例。 Redis安装和其订阅者在namespace-a中,而发布者UI在namespace-b中。 如果Redis安装在另一个命名空间上,或者使用Azure ServiceBus、AWS SNS/SQS或GCP PubSub等云服务,该解决方案也同样奏效。

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



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

资源 namespace-a namespace-b
Redis master X
Redis slave X
Dapr’s PubSub component X X
Node subscriber X
Python subscriber X
React UI publisher 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

相关链接

Last modified January 1, 0001