如何從json流反序列化多個對象？

Question

好吧，我之前已經提出過這樣的問題，但這是一個不同的主題，所以我覺得我應該對此做一個新的話題。我很抱歉，如果這事我不應該那樣做......

總之：

目前，我正在讀通過twitterfeed，並試圖將其轉換爲失去（狀態）對象。我現在的代碼如下，但失敗：

webRequest = (HttpWebRequest)WebRequest.Create(stream_url); 
webRequest.Credentials = new NetworkCredential(username, password); 
webRequest.Timeout = -1; 
webResponse = (HttpWebResponse)webRequest.GetResponse(); 
Encoding encode = Encoding.GetEncoding("utf-8"); 
responseStream = new StreamReader(webResponse.GetResponseStream(), encode); 
int i = 0; 

//Read the stream. 
while (_running) 
{ 
    jsonText = responseStream.ReadLine(); 

    byte[] sd = Encoding.Default.GetBytes(jsonText); 
    stream.Write(sd, i, i + sd.Length); 

    try 
    { 
     status s = json.ReadObject(stream) as status; 
     if (s != null) 
     { 
      //write s to a file/collection or w/e 
      i = 0; 
     } 
    } 
    catch 
    { 

    } 

} 

想法是：將流複製到另一個流。並不斷嘗試閱讀，直到發現狀態對象。 這是爲了防止溪流變小，所以它有機會成長。當然，這個流並不總是始於一個對象的開始，或者可能是腐敗的。

現在我確實找到了方法IsStartObject，我想我應該使用它。 雖然我沒有使用流的經驗，但我永遠也找不到如何使用它的好例子。

有沒有人可以向我解釋如何從流中讀取多個對象，以便我可以將它們寫入列表或w/e中。我真的找不到任何在互聯網上的好例子..

非常感謝你的嘗試！

Answer 1

我用Json.Net庫和this extension class，使得使用的DynamicObject解析流JSON對象

HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create("https://stream.twitter.com/1/statuses/sample.json"); 
webRequest.Credentials = new NetworkCredential("...", "......"); 
webRequest.Timeout = -1; 
HttpWebResponse webResponse = (HttpWebResponse)webRequest.GetResponse(); 
Encoding encode = Encoding.GetEncoding("utf-8"); 
StreamReader responseStream = new StreamReader(webResponse.GetResponseStream()); 

string line; 
while (true) 
{ 
    line = responseStream.ReadLine(); 
    dynamic obj = JsonUtils.JsonObject.GetDynamicJsonObject(line); 
    if(obj.user!=null) 
     Console.WriteLine(obj.user.screen_name + " => " + obj.text); 
} 

Answer 2

這是通過計算的嵌套層次{和} L.B的建議對分裂的實現。

public static IEnumerable<string> JsonSplit(this StreamReader input, char openChar = '{', char closeChar = '}', 
    char quote='"', char escape='\\') 
{ 
    var accumulator = new StringBuilder(); 
    int count = 0; 
    bool gotRecord = false; 
    bool inString = false; 
    while (!input.EndOfStream) 
    { 
    char c = (char)input.Read(); 
    if (c == escape) 
    { 
     accumulator.Append(c); 
     c = (char)input.Read(); 
    } 
    else if (c == quote) 
    { 
     inString = !inString; 
    } 
    else if (inString) 
    { 
    } 
    else if (c == openChar) 
    { 
     gotRecord = true; 
     count++; 
    } 
    else if (c == closeChar) 
    { 
     count--; 
    } 
    accumulator.Append(c); 
    if (count != 0 || !gotRecord) continue; 
    // now we are not within a block so 
    string result = accumulator.ToString(); 
    accumulator.Clear(); 
    gotRecord = false; 
    yield return result; 
    } 
} 

這是一個測試

[TestClass] 
    public class UnitTest1 
    { 
    [TestMethod] 
    public void TestMethod1() 
    { 
     string text = "{\"a\":1}{\"b\":\"hello\"}{\"c\":\"oh}no!\"}{\"d\":\"and\\\"also!\"}"; 
     var reader = FromStackOverflow.GenerateStreamFromString(text); 
     var e = MyJsonExtensions.JsonSplit(reader).GetEnumerator(); 
     e.MoveNext(); 
     Assert.AreEqual("{\"a\":1}", e.Current); 
     e.MoveNext(); 
     Assert.AreEqual("{\"b\":\"hello\"}", e.Current); 
     e.MoveNext(); 
     Assert.AreEqual("{\"c\":\"oh}no!\"}", e.Current); 
     e.MoveNext(); 
     Assert.AreEqual("{\"d\":\"and\\\"also!\"}", e.Current); 
    } 
    } 

GenerateStreamFromString的實施是here