비동기 httpwebresponse를 읽는 동안 처리되지 않은 socketexception을 잡습니다
-
06-07-2019 - |
문제
httpwebrequest.begingetresponse/endgetResponse 및 httpwebreprons.getResponsestream ()에 대한 모든 비동기 호출은 시도/캐치 블록에서 만들어 지지만 이러한 예외는 전파되고 가능성을 멈추지 않고 응용 프로그램 종료를 중지하지 않습니다.
처리되지 않은 예외 : System.io.ioexception : 전송 연결에서 데이터를 읽을 수 없습니다. 호스트 머신의 소프트웨어에 의해 확립 된 연결이 중단되었습니다. ---> system.net.sockets.socketexception : 호스트 시스템의 소프트웨어에 의해 확립 된 연결이 중단되었습니다.
처리되지 않은 예외 : System.io.ioexception : 전송 연결에서 데이터를 읽을 수 없습니다. 원격 호스트는 기존 연결을 강제로 닫았습니다. ---> system.net.sockets.socketexception : 원격 호스트가 기존 연결을 강제로 닫았습니다.
Unhandled Exception: System.IO.IOException: Unable to read data from the transport connection: An established connection was aborted by the software in your host machine. ---> System.Net.Sockets.SocketException: An established connection was aborted by the software in your host machine
at System.Net.Sockets.Socket.BeginReceive(Byte[] buffer, Int32 offset, Int32 size, SocketFlags socketFlags, AsyncCallback callback, Object state)
at System.Net.Sockets.NetworkStream.BeginRead(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
--- End of inner exception stack trace ---
at System.Net.Sockets.NetworkStream.BeginRead(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
at System.Net.PooledStream.BeginRead(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
at System.Net.ConnectStream.BeginReadWithoutValidation(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
at System.Net.ConnectStream.BeginRead(Byte[] buffer, Int32 offset, Int32 size, AsyncCallback callback, Object state)
at System.IO.Compression.DeflateStream.ReadCallback(IAsyncResult baseStreamResult)
at System.Net.LazyAsyncResult.Complete(IntPtr userToken)
at System.Net.ContextAwareResult.CompleteCallback(Object state)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Net.ContextAwareResult.Complete(IntPtr userToken)
at System.Net.LazyAsyncResult.ProtectedInvokeCallback(Object result, IntPtr userToken)
at System.Net.Sockets.BaseOverlappedAsyncResult.CompletionPortCallback(UInt32 errorCode, UInt32 numBytes, NativeOverlapped* nativeOverlapped)
at System.Threading._IOCompletionCallback.PerformIOCompletionCallback(UInt32 errorCode, UInt32 numBytes, NativeOverlapped* pOVERLAP)
실제 코드 조각 :
public static RequestState StartDownload(string url, string referer, RequestData data, DownloadEventHandler completedHandler, DownloadExceptionHandler failedHandler)
{
RequestState state = null;
try
{
var request = CreateWebRequest(url, referer, data);
state = new RequestState(url, data, request)
{
DownloadCompleted = completedHandler;
DownloadFailed = failedHandler;
}
state.ResponseAsyncResult = request.BeginGetResponse(WebResponseCallback, state);
state.AsyncTimeoutHandle = ThreadPool.RegisterWaitForSingleObject(state.CompletedHandle, DownloadTimeoutCallback, state, TimeSpan.FromSeconds(data.DownloadTimeout), true);
}
catch(Exception ex)
{
Trace.TraceError(ex.ToString());
}
return state;
}
private static void DownloadTimeoutCallback(object state, bool timedOut)
{
var requestState = (RequestState)state;
try
{
requestState.AsyncTimeoutHandle.Unregister(null);
if(timedOut)
{
requestState.Request.Abort();
}
}
catch(Exception ex)
{
Trace.TraceError(ex.ToString());
}
}
private static void WebResponseCallback(IAsyncResult asyncResult)
{
var state = (RequestState)asyncResult.AsyncState;
try
{
var response = (HttpWebResponse)state.Request.EndGetResponse(asyncResult);
WebResponse(state, response);
}
catch (Exception ex)
{
Trace.TraceError(ex.ToString());
}
}
private static void WebResponse(RequestState state, HttpWebResponse response)
{
state.ActualUrl = state.Request.Address.ToString();
state.Response = response;
BeginRead(state);
}
private static void BeginRead(RequestState state)
{
var stream = state.Response.GetResponseStream();
state.ReadAsyncResult = stream.BeginRead(state.Buffer, 0, state.BufferSize, ReadCallBack, state);
}
private static void ReadCallBack(IAsyncResult asyncResult)
{
var state = (RequestState)asyncResult.AsyncState;
try
{
var stream = state.Response.GetResponseStream();
var bytesRead = stream.EndRead(asyncResult);
if (bytesRead > 0)
{
//there is still more data to read
state.AppendResponseData(state.Buffer, 0, bytesRead);
BeginRead(state);
}
else
{
state.Response.Close();
state.InvokeDownloadCompleted();
}
}
catch(Exception ex)
{
Trace.TraceError(ex.ToString());
}
}
추신 : 버그 보고서는 Microsoft Connect에 제출되었습니다. https://connect.microsoft.com/visualstudio/feedback/viewfeedback.aspx?feedbackid=510564
해결책 2
2009 년 11 월 1 일 오전 11시 14 분에 Microsoft에 의해 게시 됨
이 문제는 .NET 4.0 프레임 워크에서 해결되었습니다.
고맙습니다,
네트워크 클래스 라이브러리 팀
https://connect.microsoft.com/visualstudio/feedback/viewfeedback.aspx?feedbackid=510564
다른 팁
그 이유는 Begaingetresponse를 시작한 것과는 다른 스레드에서 예외가 제기 되었기 때문입니다. System.Threading.ExecutionContext.Run
통화 스택에서 호출하십시오. 예외가 제기되기 전에 Try Catch 블록을 종료 할 수 있으므로 핸들러가없는 상태로 올라가면 코드의 일부를 게시하여 어떻게 개선 할 수 있는지 확인할 수 있습니다.