RegisterMessageHandler对特定Topic名称不生效问题问询

从你的代码和描述来看，最可能导致Topic.courier-accepted订阅无法接收消息的原因是订阅的规则被删除后没有添加替代规则，导致消息无法被路由到订阅。

核心问题：订阅规则缺失 #

看你的Subscriber.Listen()方法，你删除了订阅的默认规则，但没有添加任何新的规则：

let! rulesFound = subscriptionClient.GetRulesAsync() |> Async.AwaitTask
let hasDefaultRule = rulesFound.Any(fun r -> r.Name = RuleDescription.DefaultRuleName)
if hasDefaultRule then
    do! subscriptionClient.RemoveRuleAsync(RuleDescription.DefaultRuleName) |> Async.AwaitTask

Azure Service Bus的订阅必须至少有一个有效规则才能接收消息——默认规则$Default是一个匹配所有消息的规则，删除它之后如果没有替代规则，消息就不会被路由到这个订阅。

为什么其他Topic能正常工作？ #

大概率是测试Topic.courier-requested时，订阅是首次创建，且你的代码在某次测试中没有执行删除默认规则的逻辑（比如调试时跳过了这段代码），导致默认规则保留，所以能接收消息。而Topic.courier-accepted的订阅已经被你的代码删除了默认规则，且没有补充新规则，因此无法接收。

为什么Azure Function能收到消息？ #

Azure Function的ServiceBusTrigger在自动创建订阅时，会保留默认规则（除非你显式配置了过滤条件），所以它的订阅有有效的规则，能正常接收消息。

解决方案 #

1. 添加匹配所有消息的规则 #

在删除默认规则后，添加一个新的规则来匹配所有消息，修改你的Listen()方法：

member x.Listen() =
    async {
        subscriptionClient <- new SubscriptionClient(connectionString, topic, subscription)
        subscriptionClient.OperationTimeout <- TimeSpan.FromMinutes(3.0)
        let! rulesFound = subscriptionClient.GetRulesAsync() |> Async.AwaitTask
        let hasDefaultRule = rulesFound.Any(fun r -> r.Name = RuleDescription.DefaultRuleName)
        if hasDefaultRule then
            do! subscriptionClient.RemoveRuleAsync(RuleDescription.DefaultRuleName) |> Async.AwaitTask
        // 添加匹配所有消息的规则
        let allMessagesRule = RuleDescription("AllMessages", SqlFilter("1=1"))
        do! subscriptionClient.AddRuleAsync(allMessagesRule) |> Async.AwaitTask
        
        let msgOptions = MessageHandlerOptions(fun args -> exceptionReceivedHandler(args))
        msgOptions.AutoComplete <- false
        msgOptions.MaxAutoRenewDuration <- TimeSpan.FromMinutes(1.0)
        msgOptions.MaxConcurrentCalls <- 1
        subscriptionClient.RegisterMessageHandler(processMessageAsync, msgOptions)
    }

2. 验证订阅规则状态 #

登录Azure门户，查看Topic.courier-accepted对应的Subscription.all-messages的规则列表：

• 如果没有任何规则，直接手动添加一个1=1的SQL过滤规则，就能立即恢复消息接收。
• 也可以用Azure CLI确认规则：

  az servicebus topic subscription rule list --namespace-name <your-servicebus-namespace> --topic-name Topic.courier-accepted --subscription-name Subscription.all-messages
  

3. 优化异常处理 #

你的processMessageAsync中直接吞掉了所有异常，建议添加日志记录，方便排查潜在问题：

let processMessageAsync (message:Message) (_:CancellationToken) =
    try
        let body = Encoding.UTF8.GetString(message.Body)
        printfn "Received message: %s" body
        do! subscriptionClient.CompleteAsync(message.SystemProperties.LockToken) |> Async.AwaitTask
        Task.CompletedTask
    with ex ->
        printfn "Failed to process message: %A" ex
        do! subscriptionClient.AbandonAsync(message.SystemProperties.LockToken) |> Async.AwaitTask
        Task.CompletedTask

4. 排查门户显示异常 #

你提到点击courier-accepted需要两次才能查看订阅，这可能是Azure门户的缓存问题。可以尝试：

• 刷新门户页面或使用隐私模式打开
• 通过Azure CLI查看订阅详情，确认订阅是否正常存在：

  az servicebus topic subscription show --namespace-name <your-namespace> --topic-name Topic.courier-accepted --name Subscription.all-messages
  

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