我写了一个 HttpListener
监听其中一个端口:
httpListener.BeginGetContext(new AsyncCallback(ListenerCallback), httpListener);
ListenerCallback
处理在监听器 uri 上收到的任何请求。如果在处理请求期间发生异常,它会运行一个诊断例程,该例程会尝试访问监听器 uri,以检查监听器是否实际上处于事件状态并正在监听 uri 并写入监听器返回的响应日志。 Listener 简单地返回字符串 Listening...
给这样的虚拟请求。
现在在测试期间,当其他模块发生异常导致诊断模块执行时,我可以在查看日志时看到监听器正确返回了Listening...
。
但是,当 ListenerCallback
中发生异常时,尝试在诊断中命中监听器 URI 会引发以下异常:
System.Net.WebException : The operation has timed out
at System.Net.HttpWebRequest.GetResponse()
at MyPackage.Diagnostics.hitListenerUrl(String url) in c:\SW\MyApp\MyProj\Diagnostics.cs:line 190
诊断模块中的第190行如下:
189 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
190 HttpWebResponse response = (HttpWebResponse)request.GetResponse();
现在,如果 AsyncCallback
分派(dispatch)新线程并在该新线程中运行 ListenerCallback
,则在发送虚拟请求时不得导致 Operation Timeout
通过诊断。这就是我认为所需的行为应该是因为它是 *Async*Callback
。其实MSDN也有says the same :
Use an AsyncCallback delegate to process the results of an asynchronous operation in a separate thread.
但似乎并非如此。我在这里错过了什么吗?
视觉解释:
最佳答案
它完全是类的 BeginXxx() 方法的实现细节。有两种基本方案:
- BeginXxx() 启动一个线程来完成工作,该线程进行回调
- BeginXxx() 要求操作系统完成工作,使用 I/O 完成端口要求在完成时得到通知。操作系统启动一个线程来传递通知,该线程运行回调。
第二种方法非常可取,它可以很好地扩展程序能够有许多 挂起的操作。并且是 HttpListener 使用的方法,Windows 上的 TCP/IP 驱动程序堆栈支持完成端口。您的程序可以轻松支持数千套接字,这在服务器场景中很重要。
回调中的 EndXxx() 调用报告在尝试通过抛出异常来完成 I/O 请求时遇到的任何错误。在您的情况下, BeginGetContext() 需要回调中的 EndGetContext() 。如果您没有捕获异常,那么您的程序将终止。
您的代码片段实际上并未演示任何异步 I/O。您调用了 GetResponse() 而不是 BeginGetResponse()。根本不涉及回调,因此失败并引发异常的是 GetResponse() 方法。
关于c# - C# AsyncCallback 是否创建一个新线程?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21015746/