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); 我做错了吗？
谢谢，
暗利。
更新：这不再适用于当前版本，请参阅下面的正确答案（ 不需要投票，这在旧版本中是正确的 ）。
使用带有StreamReader的JsonTextReader类，或使用直接使用StreamReader的JsonSerializer重载：
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，我忽略了这一点，因为它与手边的问题无关。
