Azure Service Bus触发器函数：判断当前是否为消息最后一次投递尝试及获取队列MaxDeliveryCount方法

我之前也碰到过类似的需求——要在消息被移去DLQ前清理关联资源，确实得先判断当前是不是最后一次投递尝试。直接从触发的消息里拿不到队列的MaxDeliveryCount，得借助Service Bus的SDK来获取队列属性，下面是具体的实现步骤和代码示例：

第一步：安装必要的NuGet包 #

首先确保你的Azure函数项目里安装了最新的Service Bus SDK包：

Install-Package Azure.Messaging.ServiceBus

或者用.NET CLI：

dotnet add package Azure.Messaging.ServiceBus

第二步：通过依赖注入复用ServiceBusClient #

ServiceBusClient是线程安全的，适合单例复用，别每次处理消息都新建一个，所以最好通过依赖注入注入到函数类里。

第三步：编写函数逻辑，获取MaxDeliveryCount并判断 #

下面是完整的C#函数示例，逻辑很清晰：

using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

public class QueueCleanupFunction
{
    private readonly ServiceBusClient _serviceBusClient;
    private readonly ILogger<QueueCleanupFunction> _logger;

    // 依赖注入注入ServiceBusClient
    public QueueCleanupFunction(ServiceBusClient serviceBusClient, ILogger<QueueCleanupFunction> logger)
    {
        _serviceBusClient = serviceBusClient;
        _logger = logger;
    }

    [Function("ProcessQueueMessage")]
    public async Task Run([ServiceBusTrigger("your-target-queue", Connection = "ServiceBusConnectionString")] ServiceBusReceivedMessage message)
    {
        try
        {
            // 拿到当前消息的投递次数
            int currentDeliveryCount = message.DeliveryCount;
            
            // 获取队列的属性，里面就包含MaxDeliveryCount
            var queueProps = await _serviceBusClient.GetQueuePropertiesAsync("your-target-queue");
            int maxDeliveryCount = queueProps.MaxDeliveryCount;

            // 判断是否是最后一次投递尝试
            if (currentDeliveryCount >= maxDeliveryCount)
            {
                _logger.LogInformation($"消息 {message.MessageId} 是最后一次投递，开始清理关联资源");
                // 这里写你的资源清理逻辑，比如删数据库记录、释放分布式锁等
                await CleanUpLinkedResources(message.MessageId);
            }

            // 这里写你的消息业务处理逻辑
            // ...

            // 处理成功后完成消息
            await message.CompleteAsync();
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "处理消息出错");
            // 处理失败则放弃消息，让它继续重试或进入DLQ
            await message.AbandonAsync();
        }
    }

    private async Task CleanUpLinkedResources(string messageId)
    {
        // 示例：清理数据库中关联该消息的记录
        // await _dbContext.ResourceRecords.Where(r => r.MessageId == messageId).ExecuteDeleteAsync();
        _logger.LogInformation($"已完成消息 {messageId} 的资源清理");
    }
}

注意事项 #

• 配置连接字符串：在local.settings.json或者Azure门户的函数配置里，确保ServiceBusConnectionString指向你的Service Bus命名空间的连接字符串，这个连接字符串需要有足够的权限（一般用命名空间级的连接字符串就可以，默认包含获取队列属性的权限）。
• 队列名称一致性：函数触发的队列名称和调用GetQueuePropertiesAsync时传入的名称要保持一致，也可以把队列名称放到配置里，避免硬编码。
• 异常处理：获取队列属性的过程可能会失败，记得做好异常捕获，避免影响消息的正常处理。

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