如何通过Dapr Pub/Sub组件声明式订阅多主题及多订阅

问题1：如何在同一订阅中支持多个主题？ #

Dapr的Subscription资源（v2alpha1版本）本身是单主题绑定的，无法在单个订阅YAML文件中声明多个主题。如果需要接收多个主题的消息，有两种可行方案：

• 使用主题通配符：部分Pub/Sub组件支持通配符匹配主题（比如Redis Streams支持*通配符，可匹配前缀/后缀一致的多个主题），只需将spec.topic设置为通配符格式即可，前提是你使用的组件（如Azure Service Bus）支持该特性。
• 创建多个订阅资源：为每个需要订阅的主题单独编写一份订阅YAML，保证每个订阅的metadata.name唯一即可。

问题2：如何从不同订阅中消费多个不同主题？ #

创建多个指向同一Pub/Sub组件的订阅YAML是可行的，之前未生效大概率是配置细节出错，需要检查以下几点：

1. 订阅名称唯一：每个订阅的metadata.name必须是唯一值，不能重复。
2. 组件名称匹配：订阅的spec.pubsubname必须和Pub/Sub组件的metadata.name完全一致（比如你的组件名为dapr-pubsub-component，所有订阅都要指定这个值）。
3. 路由端点存在：确保订阅中配置的routes.default对应的API端点在你的控制器中已正确实现，且请求方法为POST。
4. 配置加载生效：
   • 自托管模式下：所有订阅YAML必须放在components目录下，重启Dapr sidecar加载新配置。
   • Kubernetes模式下：使用kubectl apply部署每个订阅资源，查看Dapr sidecar日志确认订阅已加载。

示例：两个订阅YAML示例

订阅1：order-created-topic #

apiVersion: dapr.io/v2alpha1
kind: Subscription
metadata:
    name: order-created-sub
spec:
    topic: order-created-topic
    routes:
        default: /api/orders/created
    pubsubname: dapr-pubsub-component

订阅2：order-cancelled-topic #

apiVersion: dapr.io/v2alpha1
kind: Subscription
metadata:
    name: order-cancelled-sub
spec:
    topic: order-cancelled-topic
    routes:
        default: /api/orders/cancelled
    pubsubname: dapr-pubsub-component

对应的控制器代码：

[ApiController]
[Route("api/orders")]
public class OrderController : ControllerBase
{
    [HttpPost("created")]
    public IActionResult OrderCreated(OrderCreated @event)
    {
        // 处理订单创建事件
    }

    [HttpPost("cancelled")]
    public IActionResult OrderCancelled(OrderCancelled @event)
    {
        // 处理订单取消事件
    }
}

问题3：是否可在订阅YAML文件中为路由指定HTTP请求方法？ #

目前Dapr的Subscription资源（v2alpha1版本）不支持直接配置HTTP请求方法，默认会使用POST方法向你的应用路由推送消息。

如果业务场景中必须使用其他请求方法（如PUT），只能通过在应用端添加转发逻辑（比如编写一个中间件，将Dapr发来的POST请求转换为PUT请求转发到内部处理函数），但不推荐这种做法——遵循Dapr默认的POST模式是Pub/Sub场景的标准交互方式，更利于兼容性和维护性。

内容的提问来源于stack exchange，提问作者David Liang