Json.NET可以序列化/反序列化到/从一个stream?

我听说Json.NET比DataContractJsonSerializer更快,并试图给它一个尝试…

但我找不到任何方法JsonConvert采取stream而不是string。

例如,对于在WinPhone上反序列化包含JSON的文件,我使用下面的代码将文件内容读入string,然后反序列化为JSON。 在使用DataContractJsonSerializer直接从stream中反序列化的过程中,它似乎比我的(非常特别的)testing慢了大约4倍…

// DCJS DataContractJsonSerializer dc = new DataContractJsonSerializer(typeof(Constants)); Constants constants = (Constants)dc.ReadObject(stream); // JSON.NET string json = new StreamReader(stream).ReadToEnd(); Constants constants = JsonConvert.DeserializeObject<Constants>(json); 

我做错了吗?

谢谢,

暗利。

更新:这不再适用于当前版本,请参阅下面的正确答案( 不需要投票,这在旧版本中是正确的 )。

使用带有StreamReaderJsonTextReader类,或使用直接使用StreamReaderJsonSerializer重载:

 var serializer = new JsonSerializer(); serializer.Deserialize(streamReader); 

Json.net的当前版本不允许您使用接受的答案代码。 目前的替代scheme是:

 public static object DeserializeFromStream(Stream stream) { var serializer = new JsonSerializer(); using (var sr = new StreamReader(stream)) using (var jsonTextReader = new JsonTextReader(sr)) { return serializer.Deserialize(jsonTextReader); } } 

文档: 从文件stream反序列化JSON

 public static void Serialize(object value, Stream s) { using (StreamWriter writer = new StreamWriter(s)) using (JsonTextWriter jsonWriter = new JsonTextWriter(writer)) { JsonSerializer ser = new JsonSerializer(); ser.Serialize(jsonWriter, value); jsonWriter.Flush(); } } public static T Deserialize<T>(Stream s) { using (StreamReader reader = new StreamReader(s)) using (JsonTextReader jsonReader = new JsonTextReader(reader)) { JsonSerializer ser = new JsonSerializer(); return ser.Deserialize<T>(jsonReader); } } 

我写了一个扩展类来帮助我从JSON源(string,stream,文件)反序列化。

 public static class JsonHelpers { public static T CreateFromJsonStream<T>(this Stream stream) { JsonSerializer serializer = new JsonSerializer(); T data; using (StreamReader streamReader = new StreamReader(stream)) { data = (T)serializer.Deserialize(streamReader, typeof(T)); } return data; } public static T CreateFromJsonString<T>(this String json) { T data; using (MemoryStream stream = new MemoryStream(System.Text.Encoding.Default.GetBytes(json))) { data = CreateFromJsonStream<T>(stream); } return data; } public static T CreateFromJsonFile<T>(this String fileName) { T data; using (FileStream fileStream = new FileStream(fileName, FileMode.Open)) { data = CreateFromJsonStream<T>(fileStream); } return data; } } 

反序列化和写作一样简单:

 MyType obj1 = aStream.CreateFromJsonStream<MyType>(); MyType obj2 = "{\"key\":\"value\"}".CreateFromJsonString<MyType>(); MyType obj3 = "data.json".CreateFromJsonFile<MyType>(); 

希望它能帮助别人。

我到了这个问题寻找一种方法来stream的一个开放的对象到System.IO.Stream列表,并从另一端读取它们,而不发送之前缓冲整个列表。 (具体来说,我通过Web API从MongoDBstream式传输持久对象。)

Paul Tyng和@Rivers在回答原始问题方面做得非常出色,我用他们的答案为我的问题build立了一个概念certificate。 我决定在这里发布我的testing控制台应用程序,以防其他人面临同样的问题。

 using System; using System.Diagnostics; using System.IO; using System.IO.Pipes; using System.Threading; using System.Threading.Tasks; using Newtonsoft.Json; namespace TestJsonStream { class Program { static void Main(string[] args) { using(var writeStream = new AnonymousPipeServerStream(PipeDirection.Out, HandleInheritability.None)) { string pipeHandle = writeStream.GetClientHandleAsString(); var writeTask = Task.Run(() => { using(var sw = new StreamWriter(writeStream)) using(var writer = new JsonTextWriter(sw)) { var ser = new JsonSerializer(); writer.WriteStartArray(); for(int i = 0; i < 25; i++) { ser.Serialize(writer, new DataItem { Item = i }); writer.Flush(); Thread.Sleep(500); } writer.WriteEnd(); writer.Flush(); } }); var readTask = Task.Run(() => { var sw = new Stopwatch(); sw.Start(); using(var readStream = new AnonymousPipeClientStream(pipeHandle)) using(var sr = new StreamReader(readStream)) using(var reader = new JsonTextReader(sr)) { var ser = new JsonSerializer(); if(!reader.Read() || reader.TokenType != JsonToken.StartArray) { throw new Exception("Expected start of array"); } while(reader.Read()) { if(reader.TokenType == JsonToken.EndArray) break; var item = ser.Deserialize<DataItem>(reader); Console.WriteLine("[{0}] Received item: {1}", sw.Elapsed, item); } } }); Task.WaitAll(writeTask, readTask); writeStream.DisposeLocalCopyOfClientHandle(); } } class DataItem { public int Item { get; set; } public override string ToString() { return string.Format("{{ Item = {0} }}", Item); } } } } 

请注意,当处理AnonymousPipeServerStream时,您可能会收到一个exception,我忽略了这一点,因为它与手边的问题无关。