Azure HTTP函数获取OAuth令牌时触发Socket错误求助

核心问题根源 #

你遇到的套接字错误，本质是**每次请求都创建并销毁ServiceBusClient**导致的连接资源耗尽。ServiceBusClient是设计为可复用的线程安全对象，频繁创建/销毁会让底层TCP连接无法被连接池复用，在Azure函数的高并发场景下快速耗尽套接字资源。

修复步骤 #

• 将ServiceBusClient改为静态成员，确保整个函数应用生命周期内只初始化一次，复用连接池
• 优化配置读取方式，避免每次请求重新构建ConfigurationBuilder
• 简化响应逻辑，直接返回符合要求的IActionResult实现

修改后的完整代码 #

using Azure.Messaging.ServiceBus;
using Azure.Identity;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using System.IO;
using System.Threading.Tasks;

public static class AdobeWebhook
{
    // 静态ServiceBusClient，全局复用连接池
    private static readonly ServiceBusClient _serviceBusClient;
    private static readonly string _clientId;

    // 静态构造函数，仅在类首次加载时初始化一次
    static AdobeWebhook()
    {
        var config = new ConfigurationBuilder()
            .AddEnvironmentVariables()
            .Build();
        
        _clientId = config["ClientId"];
        var serviceBusNamespace = config["ServiceBusNamespace"]; // 从应用设置读取命名空间，避免硬编码
        
        _serviceBusClient = new ServiceBusClient(serviceBusNamespace, new DefaultAzureCredential());
    }

    [FunctionName("AdobeWebhook")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
        ILogger log)
    {
        log.LogInformation("C# HTTP trigger function processed a request.");

        // 异步读取请求体，提升性能
        string requestBody;
        using (var reader = new StreamReader(req.Body))
        {
            requestBody = await reader.ReadToEndAsync();
        }

        // 复用全局ServiceBusClient创建Sender
        using var serviceBusSender = _serviceBusClient.CreateSender("qestesting");
        using var messageBatch = await serviceBusSender.CreateMessageBatchAsync();
        
        // 检查消息是否能加入批次
        if (!messageBatch.TryAddMessage(new ServiceBusMessage(requestBody)))
        {
            log.LogError("消息大小超过批次限制");
            return new BadRequestObjectResult("消息过大无法发送");
        }

        await serviceBusSender.SendMessagesAsync(messageBatch);

        // 构造响应并添加自定义头部
        var response = new OkObjectResult("Success")
        {
            StatusCode = StatusCodes.Status200OK
        };
        response.HttpContext.Response.Headers.Add("X-AdobeSign-ClientId", _clientId);

        return response;
    }
}

额外优化建议 #

• 配置管理：将Service Bus命名空间、队列名等配置项存入Azure函数的应用设置，不要硬编码在代码中，便于后续修改
• 错误处理：增加异常捕获逻辑，针对Service Bus操作的异常记录详细日志，便于排查问题
• 非静态函数模式：如果项目允许，改为非静态函数并通过构造函数注入IConfiguration和ServiceBusClient，提升代码的可测试性和可维护性

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