Pub/Sub 代理

关于为Dapr Pub/Sub设置不同的消息代理的指南

Dapr集成了pub/sub消息总线,为应用程序提供了创建事件驱动、松散耦合架构的能力,在这种架构下,生产者通过主题向消费者发送事件。

Dapr支持为每个应用配置多个命名的pub/sub组件。 每个pub/sub组件都有一个名称,这个名称在发布消息主题时使用。 阅读 API 参考,了解如何发布和订阅主题的详细信息。

Pub/sub组件是可扩展的, 这里有支持的pub/sub组件列表,实现可以在components-contrib repo中找到。

组件文件

Pub/sub使用Component文件来描述:

  1. apiVersion: dapr.io/v1alpha1
  2. kind: Component
  3. metadata:
  4. name: pubsub
  5. namespace: default
  6. spec:
  7. type: pubsub.<NAME>
  8. version: v1
  9. metadata:
  10. - name: <KEY>
  11. value: <VALUE>
  12. - name: <KEY>
  13. value: <VALUE>
  14. ...

Pub/sub的类型由type字段决定,连接地址和其他元数据等属性放在.metadata部分。 尽管元数据值可以包含纯文本的密钥,但建议你使用密钥仓库来存储并用secretKeyRef引用。

Topic creation

根据你使用的 pub/sub 消息总线及其配置方式,主题可能会被自动创建。 即使消息总线支持自动创建主题,在生产环境中把它禁用也是一种常见的做法。 你可能会需要使用 CLI、管理控制台或请求表单来手动创建应用所需的主题。

请访问 本指南,了解有关配置和使用 pub/sub 组件的说明。

相关链接


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