个人中心
文章发布
退出
作者热门文章
- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库？
- java - OnItemClickListener 不起作用，但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
27
4
我很难确定在使用 .NET 的 HttpWebRequest 类调用远程服务器(特别是 REST Web 服务)时是否有办法处理潜在的连接问题。根据我的调查，WebClient 类的行为是相同的，这在某种程度上是意料之中的，因为它似乎只为 HttpWebRequest 提供了一个更简单的接口(interface)。
出于模拟目的，我编写了一个非常简单的 HTTP 服务器，它的行为不符合 HTTP 1.1 RFC。它所做的是接受客户端连接，然后发送适当的 HTTP 1.1 header 和“Hello World!”有效负载返回给客户端并关闭套接字，服务器端接受客户端连接的线程如下所示:
private const string m_defaultResponse = "<html><body><h1>Hello World!</h1></body></html>";
private void Listen()
{
while (true)
{
using (TcpClient clientConnection = m_listener.AcceptTcpClient())
{
NetworkStream stream = clientConnection.GetStream();
StringBuilder httpData = new StringBuilder("HTTP/1.1 200 OK\r\nServer: ivy\r\nContent-Type: text/html\r\n");
httpData.AppendFormat("Content-Length: {0}\r\n\r\n", m_defaultResponse.Length);
httpData.AppendFormat(m_defaultResponse);
Thread.Sleep(3000); // Sleep to simulate latency
stream.Write(Encoding.ASCII.GetBytes(httpData.ToString()), 0, httpData.Length);
stream.Close();
clientConnection.Close();
}
}
}
由于 HTTP 1.1 RFC 指出 HTTP 1.1 默认情况下会保持连接处于事件状态，并且如果服务器想要关闭连接，则它必须发送“连接:关闭”响应 header ，这对于客户端来说是意外的行为。客户端通过以下方式使用 HttpWebRequest:
private static void SendRequest(object _state)
{
WebResponse resp = null;
try
{
HttpWebRequest request = (HttpWebRequest)WebRequest.Create("http://192.168.0.32:7070/asdasd");
request.Timeout = 50 * 1000;
DateTime requestStart = DateTime.Now;
resp = request.GetResponse();
TimeSpan requestDuration = DateTime.Now - requestStart;
Console.WriteLine("OK. Request took: " + (int)requestDuration.TotalMilliseconds + " ms.");
}
catch (WebException ex)
{
if (ex.Status == WebExceptionStatus.Timeout)
{
Console.WriteLine("Timeout occurred");
}
else
{
Console.WriteLine(ex);
}
}
finally
{
if (resp != null)
{
resp.Close();
}
((ManualResetEvent)_state).Set();
}
}
上述方法是通过ThreadPool.QueueUserWorkItem(waitCallback, stateObject)进行排队的。 ManualResetEvent 用于控制排队行为，这样整个线程池就不会被等待任务填满(因为 HttpWebRequest 隐式使用工作线程，因为它在内部异步运行以实现超时功能)。
所有这一切的问题在于，一旦 HttpWebRequest 的底层 ServicePoint 的所有连接都“用完”(即被远程服务器关闭)，将不会有新的连接打开。 ServicePoint 的 ConnectionLeaseTimeout 是否设置为较低的值(10 秒)也无关紧要。一旦系统进入此状态，它将不再正常运行，因为它不会自动重新连接并且所有后续的 HttpWebRequests 都会超时。现在真正的问题是，是否有一种方法可以通过在某些条件下以某种方式破坏 ServicePoint 或关闭底层连接来解决这个问题(我对 ServicePoint.CloseConnectionGroup() 还没有任何运气，该方法在如何使用方面也没有记录正确使用它)。
有人知道我该如何解决这个问题吗？
最佳答案
我根据这里的一些想法提出的解决方案是自己管理连接。如果将唯一的 ConnectionGroupName 分配给 WebRequest(例如 Guid.NewGuid().ToString())，将在 ServicePoint 中为该请求创建一个具有一个连接的新连接组。请注意，此时不再有连接限制，因为 .NET 限制每个连接组而不是每个 ServicePoint，因此您必须自己处理。您需要重用连接组，以便重用与 KeepAlive 的现有连接，但如果发生 WebException 异常，则应销毁请求的连接组，因为它可能已过时。像这样(为每个主机名创建一个新实例):
public class ConnectionManager {
private const int _maxConnections = 4;
private Semaphore _semaphore = new Semaphore(_maxConnections, _maxConnections);
private Stack<string> _groupNames = new Stack<string>();
public string ObtainConnectionGroupName() {
_semaphore.WaitOne();
return GetConnectionGroupName();
}
public void ReleaseConnectionGroupName(string name) {
lock (_groupNames) {
_groupNames.Push(name);
}
_semaphore.Release();
}
public string SwapForFreshConnection(string name, Uri uri) {
ServicePoint servicePoint = ServicePointManager.FindServicePoint(uri);
servicePoint.CloseConnectionGroup(name);
return GetConnectionGroupName();
}
private string GetConnectionGroupName() {
lock (_groupNames) {
return _groupNames.Count != 0 ? _groupNames.Pop() : Guid.NewGuid().ToString();
}
}
}
关于c# - HttpWebRequest 如何处理(过早)关闭底层 TCP 连接？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/1390780/
27
4
0
我有以下功能: function addChange(result, bill) { for (var i=0;i
这是网站: www.wearethefirehouse.com/phasetest 如果您慢慢滚动，您会注意到一旦菜单栏完全不透明，nav li 元素就会全部从 Enzo 300 跳起来(如在没有导航
美好的一天。对于当前的项目，我需要知道数据类型如何表示为字节。例如，如果我使用: long three = 500;var bytes = BitConverter.GetBytes(three);
请解释 JVM 是如何在底层收集 ThreadDump 的。 我不明白它如何收集脱离 CPU 的线程的堆栈跟踪(等待磁盘 IO、网络、非自愿上下文切换)。 例如，linux perf 仅收集有关 on
开始学习 R，如果能帮助我理解 R 如何决定不同向量的类别，我将不胜感激。我初始化 vec <- c(1:6)当我执行 class(vec)我得到“整数”。为什么它不是“数字”，因为我认为 R 中的整
我有一个透明的 UIView，几乎覆盖了整个屏幕。我在顶部留下了 50 像素。它是 View Controller View 的 subview 。 在UIView下面有一个继承自UIView的MyV
我很好奇对象是如何在 Nodejs 中显示的，在本例中是 Promise。使用 console.log(promiseObject) 时，输出的类型为 {状态:待处理} 这对我来说似乎很奇怪，因为在该
当您在 Windows Azure 中使用表服务 API 时，幕后到底在做什么？我想我在某处读到这没有使用 SQL Server。它是否执行哈希表，然后过滤器真的像映射/减少操作一样运行？我对这些东西
如何查看函数 concat 中的代码？它是如何做的？有没有人有代码的副本或在浏览器控制台中查看它的方法？ console.dir 不给我访问权限 console.dir(Array.prototype
我是 C++ 的新手，所以如果这个问题的答案显而易见，我深表歉意。 我一直在编写 STL 样式的自定义数据结构，以此来提高我的技能。 (我实际上也确实需要这种结构，但出于学习目的，我有点过分了。) 此
我正在尝试使用 log4j appender 将日志发送到 GrayLog2 (log4j2-gelf)。所以我将我的依赖项添加到我的 pom.xml 配置 log4j2.xml 来配置我的 appe
我正在使用带有 vector 的 priority_queue 作为底层容器。但是我希望堆的大小非常大。我知道动态 vector 容量调整大小的问题。所以我正在寻找方法来为我的priority_que
我有一个 SqlDataAdapter，它填充了 21 行数据(4 列)。驱动它的 sproc 在几秒钟内在 SQL Mgmt Studio 中返回，但 .Fill() 需要 5 分钟。 Ar
我想实现一个屏幕控制按钮，按下它可以作为 GUI 交互的修饰符。 这对于 MouseArea 是不可能的，因为该 API 只能处理一个鼠标区域中的一个触摸点。 该限制不适用于 MultiPointTo
我试图将图像和 div 层置于包含 div 的中心，但到目前为止我无法让它从列的左侧移动。我尝试了几种不同的方法，但就是无法让它移动。即使 margin auto 技巧也不起作用，我怀疑这是因为 bo
需要明确的是，我不是在询问 HDFS 中的权限设置，而是在 ext3 中或在 HDFS 运行于其上的各个数据节点机器上使用的任何文件系统中。 p> 我知道我们设置了 sudo chown hduser
我在服务器上创建了一个枚举，其中手动设置了整数值，而不是默认从 0 开始递增 public enum UserType { Anonymous = 0, Customer = 10,
如果显示框架图像，我们能否使以下 Google map 具有交互性。 Vie
我有一个顶部有自定义状态栏的布局 [在 Apple 的状态栏下方]，然后是 UIScrollview 在中间部分从左到右分页，然后我有一个 UIView 底部有一些自定义按钮。一个简单的三 Pane
事情是这样的。我有一个 MVC 操作，在该操作上，我应用了自定义 ActionFilterAttribute 来使反序列化工作。现在，我想要做的是根据在此 View 中设置的 ViewBag.Titl
我是一名优秀的程序员,十分优秀！