Azure ServiceBusSender与ServiceBusClient：如何获取订阅者连接事件？

方案1：通过Azure Event Grid监听订阅创建事件 #

Azure Service Bus和Event Grid原生集成，能捕获主题的订阅创建事件，发送端可通过订阅这些事件来触发消息推送：

• 配置步骤：
  • 在Azure门户给目标Service Bus命名空间开启Event Grid事件订阅，选择Microsoft.ServiceBus.SubscriptionCreated事件类型（可过滤仅监听指定主题）。
  • 将Event Grid的事件投递端点指向发送应用的API接口，或者用Azure Function做中间转发层。
  • 发送端收到Event Grid的POST事件通知后，验证事件类型为订阅创建，随即触发向该主题发送初始化消息。
• 注意：需给发送端的端点配置身份验证（比如用Event Grid的访问密钥校验请求合法性），避免恶意请求。

方案2：定期轮询Service Bus订阅列表 #

如果不想依赖Event Grid，发送端可以主动轮询主题的订阅列表，对比本地缓存发现新订阅时触发发送：

• 实现要点：
  • 发送端需持有Service Bus命名空间的管理权限（比如Azure Service Bus Data Owner角色），才能调用管理API。
  • 使用Azure.Messaging.ServiceBus.Administration客户端库编写轮询逻辑：

    var adminClient = new ServiceBusAdministrationClient("<your-service-bus-connection-string>");
    var currentSubscriptions = await adminClient.GetSubscriptionsAsync("<target-topic-name>").ToListAsync();
    // 对比本地缓存的订阅列表，筛选新增项
    foreach (var sub in currentSubscriptions)
    {
        if (!localCachedSubscriptions.Contains(sub.SubscriptionName))
        {
            await SendInitialMessageToTopic("<target-topic-name>");
            localCachedSubscriptions.Add(sub.SubscriptionName);
        }
    }
    

  • 根据业务需求设置轮询间隔（比如5-15分钟），平衡实时性和API调用成本。

方案3：订阅端主动触发初始化 #

让新订阅的应用在完成订阅配置后，主动通知发送端发送初始化消息：

• 实现思路：
  • 发送端暴露一个REST接口（比如POST /api/trigger-init-message），接收目标主题名称参数。
  • 订阅端在创建Service Bus订阅完成后，调用该接口告知发送端有新订阅。
  • 发送端收到请求后，立即向对应主题发送初始化消息。
• 优势：逻辑简单直接，无需依赖外部服务，订阅端可自主控制初始化时机。

方案4：兜底机制：订阅端请求补发初始化消息 #

如果以上方案都不适用，可采用订阅端主动请求的兜底方式：

• 实现方式：
  • 发送端将初始化消息持久化存储（比如Azure Blob Storage或数据库）。
  • 订阅端首次启动时，向发送端的专用请求队列发送一条"请求初始化消息"的标识消息。
  • 发送端监听该专用队列，收到请求后从存储取出初始化消息发送到目标主题。

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