如何通过Dapr订阅启用会话的Azure Service Bus队列？

问题根源 #

你遇到的错误是因为[Topic]属性是为主题订阅设计的，而你的资源是Azure Service Bus队列（非主题），强行使用会导致Dapr尝试查找对应主题的订阅资源，自然会失败。针对队列的订阅逻辑和主题完全不同，需要调整实现方式。

解决方案步骤 #

1. 确认Dapr PubSub组件配置

确保你的Dapr组件配置文件（如components/pubsub-azurebus.yaml）正确绑定到目标会话队列：

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub-azurebus
spec:
  type: pubsub.azure.servicebus
  version: v1
  metadata:
  - name: connectionString
    value: "你的Azure Service Bus连接字符串"
  - name: queueName
    value: "product"
  - name: sessionEnabled
    value: "true"

这里关键是指定queueName为你的队列名product，并开启sessionEnabled。

2. 在.NET Core最小API中实现队列消息订阅

不需要使用[Topic]属性，直接通过Dapr的云事件订阅机制接收队列消息：

var builder = WebApplication.CreateBuilder(args);

// 添加Dapr客户端支持
builder.Services.AddDaprClient();

var app = builder.Build();

// 启用云事件处理
app.UseCloudEvents();
// 映射Dapr订阅处理路由
app.MapSubscribeHandler();

// 定义消息处理端点，对应队列的消息接收
app.MapPost("/product-queue-handler", async (HttpRequest req, ILogger<Program> logger) =>
{
    // 读取消息内容（根据你发送的消息结构调整实体类）
    var message = await req.ReadFromJsonAsync<ProductMessage>();
    if (message == null)
    {
        logger.LogError("接收到空消息");
        return Results.BadRequest();
    }

    // 从请求头获取会话ID（Dapr自动传递该字段）
    if (req.Headers.TryGetValue("session-id", out var sessionId))
    {
        logger.LogInformation("收到会话[{SessionId}]的消息: {Content}", sessionId, message.Content);
        // 这里可以根据sessionId（如CARS.12）拆分租户ID做业务处理
    }

    // 执行你的业务逻辑
    // ...

    return Results.Ok();
});

app.Run();

// 匹配你发送的消息结构的实体类
public class ProductMessage
{
    public string Content { get; set; } = string.Empty;
    // 其他字段根据实际发送内容添加
}

3. 启动服务并验证

启动服务时通过Dapr sidecar运行：

dapr run --app-id product-consumer --app-port 5000 --dapr-http-port 3500 dotnet run

发送带会话ID的消息后，服务会正确接收并处理队列中的会话消息。

内容的提问来源于stack exchange，提问作者Zoltan Hernyak