如何在 web api 中压缩 HttpClient 发布和接收数据

Question

我有以下 web api 客户端，它使用 json 和 gzip 将数据发送到服务器：

    public void Remote_Push(BlockList Blocks)
    {
        // Pushes pending records to the remote server
        using (var Client = new HttpClient())
        {
            Client.BaseAddress = new Uri(Context.ServerUrl);
            Client.DefaultRequestHeaders.Accept.Clear();
            Client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
            var Content = JsonCompress(Blocks);
            var T1 = Client.PostAsync("SyncPush/", Content); T1.Wait();
            T1.Result.EnsureSuccess();
        }
    }

    private static ByteArrayContent JsonCompress(object Data)
    {
        // Compress given data using gzip 
        var Bytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(Data));
        using (var Stream = new MemoryStream())
        {
            using (var Zipper = new GZipStream(Stream, CompressionMode.Compress, true)) Zipper.Write(Bytes, 0, Bytes.Length);
            var Content = new ByteArrayContent(Stream.ToArray());
            Content.Headers.ContentType = new MediaTypeHeaderValue("application/json");
            Content.Headers.ContentEncoding.Add("gzip");
            return Content;
        }
    }

在服务器上，我在 web api 控制器中创建了以下操作：

    [HttpPost]
    public void SyncPush([FromBody]BlockList Blocks)
    {
        var Context = SyncCreateContext();
        var Sync = new Processor(Context);
        Sync.ServerPush(Blocks);
    }

以前，我在客户端上使用过PostAsJsonAsync，效果很好。

现在，我已切换到 ByteArrayContent 和 gzip 并且不再工作，Blocks 在服务器上始终为 null。 我在这里遗漏了什么，有什么问题或可能是问题所在？

Answer 1

这是一个示例控制台应用程序，用于执行您正在尝试执行的操作。

      /*using System;
      using System.IO;
      using System.IO.Compression;
      using System.Net.Http;
      using System.Net.Http.Headers;
      using System.Text;
      using Newtonsoft.Json;
      using WebApi.Models;*/

 class Program
{
    static void Main(string[] args)
    {
        Console.WriteLine("Press any key to POST");
        Console.ReadLine();
        RemotePush(new BlockList());
        Console.ReadLine();
    }

    public static async void RemotePush(BlockList blocks)
    {
        try
        {
            using (var client = new HttpClient())
            {
                try
                {
                    Console.WriteLine("Please wait.");
                    client.BaseAddress = new Uri("http://localhost:52521/Home/"); 
                    client.DefaultRequestHeaders.Accept.Clear();
                    client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                    var content = JsonCompress(blocks);
                    var response = await client.PostAsync("SyncPush/", content);
                    using (var stream = await response.Content.ReadAsStreamAsync())
                    {
                        using (var streamReader = new StreamReader(stream))
                        {
                            Console.WriteLine(streamReader.ReadToEnd());
                        }
                    }
                    Console.WriteLine("Done.");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }

    private static MultipartFormDataContent JsonCompress(object data)
    {
        var bytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(data));
        var stream = new MemoryStream();
        using (var zipper = new GZipStream(stream, CompressionMode.Compress, true))
        {
            zipper.Write(bytes, 0, bytes.Length);
        }
        MultipartFormDataContent multipartContent = new MultipartFormDataContent();
        multipartContent.Add(new StreamContent(stream), "gzipContent");
        return multipartContent;
    }
}

我的控制器是这样的。

    [System.Web.Mvc.HttpPost]
    public JsonResult SyncPush(BlockList content)
    {
        try
        {
            if (content != null)
            {
                return Json("success", JsonRequestBehavior.AllowGet);
            }
            return Json("failed due to null", JsonRequestBehavior.AllowGet);
        }
        catch (Exception ex)
        {
            return Json("failed " + ex.Message, JsonRequestBehavior.AllowGet);
        }
    }