雙向命名管道問題

我有2個應用程序，我想通過.NET 3.5上的命名管道進行通信。它是一個請求/響應範例，數據以XML格式傳輸，讓我的生活更輕鬆。有一個監聽器應用程序和一個將請求發佈到管道的應用程序。我試圖用雙向管來做到這一點。我遇到的問題是對StreamReader.ReadToEnd（）的調用似乎不會返回。我能做些什麼來解決這個問題？雙向命名管道問題

監聽器代碼

public Class Listener 
{ 
    private void ThreadFunc() 
    { 
     var pipe = new NamedPipeServerStream("GuideSrv.Pipe",PipeDirection.InOut); 
     var instream = new StreamReader(pipe); 
     var outstream = new StreamWriter(pipe); 
     while (true) 
     { 
      pipe.WaitForConnection(); 
      var response = ProcessPipeRequest(instream); 
      outstream.Write(response.ToString()); 
      pipe.Disconnect(); 
     } 
    } 
    private XDocument ProcessPipeRequest(StreamReader stream) 
    { 
     var msg_in = stream.ReadToEnd(); // << This call doesnt return 
     var xml_in = XDocument.Parse(msg_in); 
     // do some stuff here 
     return new XDocument(....); 
    } 
}

委託代碼

public XDocument doIt() 
{ 
    var xml = new XDocument(....); 
    using (var pipe = new NamedPipeClientStream(".", "GuideSrv.Pipe", PipeDirection.InOut)) 
    { 
     using (var outstream = new StreamWriter(pipe)) 
     using (var instream = new StreamReader(pipe)) 
     { 
      pipe.Connect(); 
      outstream.Write(xml.ToString()); 
      xml = XDocument.Parse(instream.ReadToEnd()); 
     } 
    } 
    return xml; 
}

來源

2009-08-20 Jeff Shattock

後你outstream.Write(xml.ToString())在doIt()你再試試從instream閱讀。同時你的另一個線程正在等待stream.ReadToEnd()。它會永遠等待，因爲它不知道你寫完了。據知道你可以再次致電outstream.Write()來寫更多的數據。只有在您實際關閉doIt()的管道時，ReadToEnd()呼叫纔會返回。

您可以通過使它們彼此更加智能地進行通信來解決此問題。例如，您可以將長度xml.ToString()寫入管道，然後寫入字符串。然後在讀者線程中，首先讀取長度，然後讀取msg_in，只讀取您期望發送的確切字節數，一旦全部讀取而停止，而不是等待管道關閉。

來源

2009-08-20 22:10:04

雙向命名管道問題

回答

相關問題