如何在Asp.net核心Web API中为messagepack内容类型启用LZ4压缩

Install-Package MessagePack.AspNetCoreMvcFormatter
Install-Package LZ4.Streams

using MessagePack.AspNetCoreMvcFormatter;

public void ConfigureServices(IServiceCollection services)
{
    services.AddControllers().AddMvcOptions(options =>
    {
        // 添加MessagePack输入输出格式
        options.OutputFormatters.Clear();
        options.InputFormatters.Clear();
        options.OutputFormatters.Add(new MessagePackOutputFormatter(ContractlessStandardResolver.Instance));
        options.InputFormatters.Add(new MessagePackInputFormatter(ContractlessStandardResolver.Instance));
    });
}

using LZ4;
using Microsoft.AspNetCore.Http;
using System.IO;
using System.IO.Compression;
using System.Threading.Tasks;

public class LZ4CompressionMiddleware
{
    private readonly RequestDelegate _next;

    public LZ4CompressionMiddleware(RequestDelegate next)
    {
        _next = next;
    }

    public async Task Invoke(HttpContext context)
    {
        // 检查请求的Content-Type是否为messagepack
        if (context.Request.ContentType == "application/x-msgpack")
        {
            // 启用LZ4压缩
            using (var originalBody = context.Response.Body)
            {
                using (var memoryStream = new MemoryStream())
                {
                    context.Response.Body = memoryStream;

                    await _next(context);

                    memoryStream.Seek(0, SeekOrigin.Begin);

                    using (var lz4Stream = new LZ4Stream(originalBody, CompressionMode.Compress))
                    {
                        memoryStream.CopyTo(lz4Stream);
                    }
                }
            }
        }
        else
        {
            await _next(context);
        }
    }
}

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    // ...

    // 添加LZ4CompressionMiddleware中间件
    app.UseMiddleware<LZ4CompressionMiddleware>();

    // ...
}