Azure Functions .NET 5 环境下是否有办法实现POCO绑定？

核心背景：.NET 5 隔离进程模型默认移除了3.1 进程内模型自带的HTTP请求POCO自动绑定能力，以下是三个可直接落地的实现方案：

方案1：自定义HTTP POCO绑定特性（最贴近原生使用体验） #

完全模拟原生绑定的使用方式，代码侵入性极低：

• 第一步：定义绑定特性与绑定逻辑

[AttributeUsage(AttributeTargets.Parameter)]
public class HttpPocoBindingAttribute : BindingAttribute
{
}

public class HttpPocoBindingProvider : IBindingProvider
{
    public Task<IBinding> TryCreateAsync(BindingProviderContext context)
    {
        var attribute = context.Parameter.GetCustomAttribute<HttpPocoBindingAttribute>();
        if (attribute == null) return Task.FromResult<IBinding>(null);
        return Task.FromResult<IBinding>(new HttpPocoBinding(context.Parameter.ParameterType));
    }
}

public class HttpPocoBinding : IBinding
{
    private readonly Type _targetType;
    public HttpPocoBinding(Type targetType) => _targetType = targetType;

    public async Task<IValueProvider> BindAsync(BindingContext context)
    {
        var request = context.BindingData["req"] as HttpRequestData;
        if (request == null) return null;
        using var reader = new StreamReader(request.Body);
        var bodyContent = await reader.ReadToEndAsync();
        var poco = JsonSerializer.Deserialize(bodyContent, _targetType, new JsonSerializerOptions { PropertyNameCaseInsensitive = true });
        return new SimpleValueProvider(poco, _targetType);
    }
}

public class SimpleValueProvider : IValueProvider
{
    private readonly object _value;
    private readonly Type _type;
    public SimpleValueProvider(object value, Type type) => (_value, _type) = (value, type);
    public object GetValue() => _value;
    public Type Type => _type;
}

• 第二步：注册绑定服务

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddSingleton<IBindingProvider, HttpPocoBindingProvider>();
    })
    .Build();
host.Run();

• 第三步：直接在函数参数中使用

[Function("TestFunction")]
public HttpResponseData Run(
    [HttpTrigger(AuthorizationLevel.Function, "post")] HttpRequestData req,
    [HttpPocoBinding] YourCustomDto dto)
{
    // 可直接使用dto对象
}

方案2：轻量扩展方法（快速实现零配置） #

不需要改动服务注册，仅需一个扩展方法即可快速实现POCO解析：

public static class HttpRequestDataExtensions
{
    public static async ValueTask<T> ReadFromJsonAsync<T>(this HttpRequestData request, CancellationToken cancellationToken = default)
    {
        request.Body.Seek(0, SeekOrigin.Begin);
        return await JsonSerializer.DeserializeAsync<T>(request.Body, new JsonSerializerOptions { PropertyNameCaseInsensitive = true }, cancellationToken);
    }
}

使用方式：

[Function("TestFunction")]
public async Task<HttpResponseData> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post")] HttpRequestData req)
{
    var dto = await req.ReadFromJsonAsync<YourCustomDto>();
    // 后续业务逻辑
}

方案3：全局中间件统一绑定（适合批量处理场景） #

无需每个函数单独处理，可全局为所有HTTP触发函数统一完成POCO绑定：

• 中间件实现

public class PocoBindingMiddleware : IFunctionsWorkerMiddleware
{
    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
    {
        var httpTrigger = context.FunctionDefinition.InputBindings.Values
            .FirstOrDefault(b => b.Type == "httpTrigger");
        if (httpTrigger != null)
        {
            var request = context.GetHttpRequestData();
            if (request != null)
            {
                request.Body.Seek(0, SeekOrigin.Begin);
                using var reader = new StreamReader(request.Body);
                var bodyContent = await reader.ReadToEndAsync();
                // 可根据函数参数元数据批量匹配反序列化目标类型
                var dto = JsonSerializer.Deserialize<YourCustomDto>(bodyContent, new JsonSerializerOptions { PropertyNameCaseInsensitive = true });
                context.Items["RequestDto"] = dto;
                request.Body.Seek(0, SeekOrigin.Begin);
            }
        }
        await next(context);
    }
}

• 注册中间件

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults(builder =>
    {
        builder.UseMiddleware<PocoBindingMiddleware>();
    })
    .Build();
host.Run();

• 函数中使用

[Function("TestFunction")]
public HttpResponseData Run(
    [HttpTrigger(AuthorizationLevel.Function, "post")] HttpRequestData req,
    FunctionContext context)
{
    var dto = context.Items["RequestDto"] as YourCustomDto;
    // 后续业务逻辑
}

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