2012-06-22 47 views
3

我使用实施这里全碟的readFully方法:请求已中止:连接被关闭意外

public static byte[] ReadFully(Stream stream) 
{ 
    var buffer = new byte[32768]; 
    using (var ms = new MemoryStream()) 
    { 
     while (true) 
     { 
      int read = stream.Read(buffer, 0, buffer.Length); 
      if (read <= 0) 
       return ms.ToArray(); 
      ms.Write(buffer, 0, read); 
     } 
    } 
} 

它抛出在该行的异常:

int read = stream.Read(buffer, 0, buffer.Length); 

的错误消息是The request was aborted: The connection was closed unexpectedly

我正在向web服务发送一个xml请求。我的发送方法是这样的:

private static string SendRequest(XElement request, string url) 
{ 
    var req = (HttpWebRequest)WebRequest.Create(url); 
    req.ContentType = "application/soap+xml;"; 
    req.Method = "POST"; 
    req.KeepAlive = false; 
    req.Timeout = System.Threading.Timeout.Infinite; 
    req.ReadWriteTimeout = System.Threading.Timeout.Infinite; 
    req.ProtocolVersion = HttpVersion.Version10; 
    req.AllowWriteStreamBuffering = false; 

    using (var stm = req.GetRequestStream()) 
    { 
     using (var stmw = new StreamWriter(stm)) 
     { 
      stmw.Write(request.ToString()); 
     } 
    } 

    Stream responseStream; 
    using (var webResponse = req.GetResponse()) 
    { 
     responseStream = webResponse.GetResponseStream(); 
    } 

    // Do whatever you need with the response 
    var myData = ReadFully(responseStream); 
    string responseString = Encoding.ASCII.GetString(myData); 

    return responseString; 
} 

我试过没有,没有设置下列变量,它给了我同样的消息:

req.KeepAlive = false; 
req.Timeout = System.Threading.Timeout.Infinite; 
req.ReadWriteTimeout = System.Threading.Timeout.Infinite; 
req.ProtocolVersion = HttpVersion.Version10; 
req.AllowWriteStreamBuffering = false; 

回答

8

的问题是在这部分代码:

// wrong way to do it! 
Stream responseStream; 
using (var webResponse = req.GetResponse()) 
{ 
    responseStream = webResponse.GetResponseStream(); 
} 

// Do whatever you need with the response 
var myData = ReadFully(responseStream); 

您正在处理您的响应对象,然后再读取它的流。尝试这样的代替:

byte[] myData; 
using (var webResponse = req.GetResponse()) 
{ 
    var responseStream = webResponse.GetResponseStream(); 
    myData = ReadFully(responseStream); // done with the stream now, dispose of it 
} 

// Do whatever you need with the response 
string responseString = Encoding.ASCII.GetString(myData); 
+1

你真棒。这工作。我想这是我得到的信赖Resharper太多。 – Xaisoft

相关问题