通過Socket c讀取xml＃

Question

我試圖從/向服務器讀/寫使用tcp套接字連接的xml。它給我錯誤根元素缺失。我知道那裏有xmpp/jabber庫，但我正在尋找一個簡單的自定義解決方案，如何在一般情況下做到這一點，以及如何解決我的代碼中的錯誤。 我將不勝感激，如果有人可以幫助我:)

 private void WritePreauthStreamInit(XmlWriter writer, string domain) 
     {    
      this.socketStream = new NetworkStream(this._socket); 

      XmlWriter writer1 = XmlWriter.Create(this.socketStream); 
      writer1.WriteStartElement("stream", "stream", "http://etherx.jabber.org/streams"); 
      writer1.WriteAttributeString("to", domain); 
      writer1.WriteAttributeString("version", "1.0"); 
      writer1.WriteStartElement("start-ack"); 
      writer1.WriteEndElement(); 
      writer1.Flush(); 

      XmlReader reader1 = XmlReader.Create(this.socketStream); 
       while (reader1.Read()) //Exception: Root element is missing 
       { 
        string xml = reader1.Read().ToString(); 
       } 
     } 

Answer 1

我的猜測是，要麼XMLReader有一個關於接收到的數據（IE的緩存大小錯誤的假設：預計可以讀取這兩種4096個字節或撞擊結束在它開始處理數據之前的流）或者服務器沒有發送什麼是有效的文檔。

無論採用哪種方式，您都可以通過實施將網絡流量轉儲到磁盤或使用Wireshark或類似軟件的日誌流包裝來進行檢查。

public class LoggingStreamWrapper : Stream 
{ 
    private Stream baseStream; 
    private TextWriter twLog; 
    private Encoding baseEncoding; 

    public LoggingStreamWrapper(Stream baseStream, TextWriter twLog) 
     : this(baseStream, twLog, Encoding.UTF8) 
    { 
    } 

    public LoggingStreamWrapper(Stream baseStream, TextWriter twLog, Encoding encoding) 
    { 
     if (baseStream == null) 
      throw new ArgumentNullException("baseStream"); 
     if (twLog == null) 
      throw new ArgumentNullException("twLog"); 

     this.baseStream = baseStream; 
     this.twLog = twLog; 
     this.baseEncoding = encoding; 
    } 

    public override bool CanRead 
    { 
     get { return baseStream.CanRead; } 
    } 

    public override bool CanSeek 
    { 
     get { return baseStream.CanSeek; } 
    } 

    public override bool CanWrite 
    { 
     get { return baseStream.CanWrite; } 
    } 

    public override void Flush() 
    { 
     baseStream.Flush(); 
     twLog.WriteLine("Flushed stream"); 
     twLog.Flush(); 
    } 

    public override long Length 
    { 
     get { return baseStream.Length; } 
    } 

    public override long Position 
    { 
     get { return baseStream.Position; } 
     set 
     { 
      baseStream.Position = value; 

      twLog.WriteLine(string.Format("Set position to {0}", value)); 
      twLog.Flush(); 
     } 
    } 

    public override int Read(byte[] buffer, int offset, int count) 
    { 
     var bRead = baseStream.Read(buffer, offset, count); 

     if (bRead > 1) 
     { 
      twLog.WriteLine(string.Format("Read {0} bytes from stream: {1}\r\n{2}", bRead, 
       getText(buffer, offset, bRead), 
       Convert.ToBase64String(buffer, offset, bRead, Base64FormattingOptions.InsertLineBreaks))); 
      twLog.Flush(); 
     } 
     else 
     { 
      twLog.WriteLine(string.Format("Read {0} bytes from stream", bRead)); 
      twLog.Flush(); 
     } 

     return bRead; 
    } 

    private string getText(byte[] buffer, int offset, int bRead) 
    { 
     try 
     { 
      return baseEncoding.GetString(buffer, offset, bRead); 
     } 
     catch 
     { 
      return "{ERROR: Could not convert to text}"; 
     } 
    } 

    public override long Seek(long offset, SeekOrigin origin) 
    { 
     var newpos = baseStream.Seek(offset, origin); 

     twLog.WriteLine(string.Format("Seeked to {0} relative to {1}. New offset {2}", offset, origin, newpos)); 
     twLog.Flush(); 

     return newpos; 
    } 

    public override void SetLength(long value) 
    { 
     baseStream.SetLength(value); 

     twLog.WriteLine(string.Format("Set length to {0}", value)); 
     twLog.Flush(); 
    } 

    public override void Write(byte[] buffer, int offset, int count) 
    { 
     baseStream.Write(buffer, offset, count); 

     twLog.WriteLine(string.Format("Wrote {0} bytes to stream: {1}\r\n{2}", count, 
      getText(buffer, offset, count), 
      Convert.ToBase64String(buffer, offset, count, Base64FormattingOptions.InsertLineBreaks))); 
     twLog.Flush(); 
    } 

    protected override void Dispose(bool disposing) 
    { 
     base.Dispose(disposing); 

     if (disposing) 
     { 
      twLog.Dispose(); 
      baseStream.Dispose(); 
     } 
    } 
}