JSON对象创建PushStreamContent

拉马斯瓦米

我有asp.net网络api,并具有HTTPResponseMessage和api方法名称GetPersonDataStream,实际上将每个人对象作为json流化。因此,当我看到结果时,实际的数据已像两个单独的对象那样构造,并且两个对象之间没有逗号,这是不是按照我的要求构造的。

实际流数据: {"Name":"Ram","Age":30}{"Name":"Sam","Age":32}

但我希望将此作为适当的JSON流式传输为:

{"response": [ {"Name":"Ram","Age":30}, {"Name":"Sam","Age":32} ]}

有没有一种方法可以实现它。以下是我用于流式传输数据的代码,因为记录数将达到数百万,并且我不想一次创建所有对象然后流式传输它,因为这可能导致Syste.OutOfMemory Exception。因此,有一种方法可以在流传输之前编辑/构造对象。如果是,我该如何实现。

码:

    [HttpGet]
    [Route("GetPersonDataStream")]
    public HttpResponseMessage GetPersonDataStream()
    {
        List<Person> ps = new List<Person>();
        Person p1 = new Person();
        p1.Name = "Ram";
        p1.Age = 30;

        Person p2 = new Person();
        p2.Name = "Sam";
        p2.Age = 32;

        ps.Add(p1);
        ps.Add(p2);

        var response = this.Request.CreateResponse(HttpStatusCode.OK);

        response.Content =
            new PushStreamContent((stream, content, context) =>
            {
                foreach (var item in ps)
                {
                    //var result = _clmmgr.GetApprovedCCRDetail(item.ccr_id, liccrDetails);
                    var serializer = new JsonSerializer();
                    using (var writer = new StreamWriter(stream))
                    {
                        serializer.Serialize(writer, item);
                        stream.Flush();
                    }
                }
            });

        return response;
    }

    public class Person
    {
        public string Name {get;set;}
        public int Age { get; set; }
    }
康尼

使用JSON.NET及其JsonTextWriter,您可以将所有项目包装在带有数组的JSON对象中,并且仍然可以流式传输结果,而无需先在内存中构建所有内容。

response.Content =
    new PushStreamContent((stream, content, context) =>
    {
        using (var sw = new StreamWriter(stream))
        using (var jsonWriter = new JsonTextWriter(sw))
        {
            jsonWriter.WriteStartObject();
            {
                jsonWriter.WritePropertyName("response");
                jsonWriter.WriteStartArray();
                {
                    foreach (var item in ps)
                    {
                        var jObject = JObject.FromObject(item);
                        jObject.WriteTo(jsonWriter);
                    }
                }
                jsonWriter.WriteEndArray();
            }
            jsonWriter.WriteEndObject();
        }
    });

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章