.NET 8 Azure Functions调用第三方API偶发413请求实体过大问题

我有一个.NET 8 C# Azure Functions应用，调用第三方供应商API获取大体积JSON数据。多数时候代码正常，但偶尔会抛出413 Request Entity Too Large错误，且相同请求在Postman中能正常执行。

相关调用代码 #

public async Task<MyLargeObject> GetMyLargeObjectAsync(string unique_id)
{
    MyLargeObject myLargeObject = new MyLargeObject();

    try
    {
        HttpClient client = new HttpClient();
        client.DefaultRequestHeaders.Clear();
        client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("*/*"));
        client.DefaultRequestHeaders.UserAgent.ParseAdd("MyApp/1.0.0");
        client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", _token);

        var response = await client.GetAsync(_vendorEndPointURL + unique_id);

        response.EnsureSuccessStatusCode(); // 响应JSON过大时抛出异常
        if (response.Content != null)
        {
            HttpContent content = response.Content;
            string result = content.ReadAsStringAsync().Result;
            myLargeObject = JsonConvert.DeserializeObject<MyLargeObject>(result);

        }
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, $"Error getting MyLargeObject from Vendor API. Unique ID: {unique_id}");
        throw;

    }
    return myLargeObject;
}

我已在Program.cs中添加以下配置，但问题未解决：

services.Configure<KestrelServerOptions>(options =>
{
    options.Limits.MaxRequestBodySize = long.MaxValue;
    options.Limits.MaxResponseBufferSize = long.MaxValue;
}); 
services.Configure<IISServerOptions>(options =>
{
    options.MaxRequestBodySize = long.MaxValue; 
});

核心问题分析 #

你配置的KestrelServerOptions和IISServerOptions是针对Azure Functions自身作为服务接收外部请求的大小限制，和你的应用作为客户端调用第三方API的行为完全无关，所以这些配置对当前问题没有作用。

413 Request Entity Too Large是第三方服务器返回的错误，说明你的应用发送的请求实体（或URL长度）超过了对方服务器的限制。Postman能正常执行，说明你的HttpClient请求和Postman的请求存在差异，或者请求本身的大小偶尔触发了对方的限制。

具体解决方案 #

1. 改用IHttpClientFactory复用HttpClient（同时优化配置）

频繁创建HttpClient是不良实践，且难以统一配置客户端参数。使用IHttpClientFactory可以复用连接池，还能配置请求/响应的缓冲限制：

首先在Program.cs注册：

services.AddHttpClient("VendorApiClient", client =>
{
    client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("*/*"));
    client.DefaultRequestHeaders.UserAgent.ParseAdd("MyApp/1.0.0");
    client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", _token);
})
.ConfigurePrimaryHttpMessageHandler(() => new HttpClientHandler
{
    // 设置最大请求内容缓冲大小（针对请求体）
    MaxRequestContentBufferSize = long.MaxValue,
    // 设置最大响应内容缓冲大小（针对响应）
    MaxResponseContentBufferSize = long.MaxValue
});

然后在你的函数类中注入IHttpClientFactory并修改调用逻辑：

private readonly IHttpClientFactory _httpClientFactory;
private readonly ILogger _logger;
private readonly string _vendorEndPointURL;
private readonly string _token;

public YourFunctionClass(IHttpClientFactory httpClientFactory, ILogger<YourFunctionClass> logger, IConfiguration configuration)
{
    _httpClientFactory = httpClientFactory;
    _logger = logger;
    _vendorEndPointURL = configuration["VendorEndPointURL"];
    _token = configuration["Token"];
}

public async Task<MyLargeObject> GetMyLargeObjectAsync(string unique_id)
{
    MyLargeObject myLargeObject = new MyLargeObject();
    var client = _httpClientFactory.CreateClient("VendorApiClient");

    try
    {
        // 对unique_id进行URL编码，避免特殊字符导致URL解析错误或长度异常
        var encodedId = Uri.EscapeDataString(unique_id);
        var response = await client.GetAsync($"{_vendorEndPointURL}{encodedId}");

        response.EnsureSuccessStatusCode();
        if (response.Content != null)
        {
            // 用await替代.Result，避免同步阻塞死锁
            string result = await response.Content.ReadAsStringAsync();
            myLargeObject = JsonConvert.DeserializeObject<MyLargeObject>(result);
        }
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, $"Error getting MyLargeObject from Vendor API. Unique ID: {unique_id}");
        throw;
    }
    return myLargeObject;
}

2. 解决URL长度超限问题

如果unique_id过长，直接拼接在URL中会导致整个URL长度超过第三方服务器的限制（多数服务器对GET请求的URL长度限制在2KB-8KB之间）。这种情况下：

• 若第三方API支持，改用POST请求将unique_id放在请求体中传递：

var requestBody = new { unique_id = unique_id };
var content = new StringContent(JsonConvert.SerializeObject(requestBody), Encoding.UTF8, "application/json");
var response = await client.PostAsync(_vendorEndPointURL, content);

3. 对齐Postman和HttpClient的请求细节

抓包对比Postman和你的应用发送的请求，确保以下内容完全一致：

• 请求头（包括User-Agent、Authorization、Accept等）
• URL的编码方式
• 是否启用了分块传输编码
• 请求的Content-Type（若用POST）

4. 流式处理大响应（针对响应过大的异常情况）

如果第三方服务器的错误提示不准确，实际是响应体积过大导致的问题，可以用流式处理避免缓冲整个响应：

using var stream = await response.Content.ReadAsStreamAsync();
using var reader = new StreamReader(stream);
using var jsonReader = new JsonTextReader(reader);
var serializer = new JsonSerializer();
myLargeObject = serializer.Deserialize<MyLargeObject>(jsonReader);

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