我有以下几点
public async Task PostTest()
{
using (var client = new HttpClient())
{
client.BaseAddress = new Uri("abc.com");
var response = await client.PostAsync("/api/call", new StringContent("hello world"));
//do something with response and dispose it.
//NOTE: server is long running, so dispose is not getting called before sending other remaning requests.
}
}然后,我从循环中调用此方法,快速连续地发送大量请求。
根据我所读到的关于HttpClient的内容,它会将请求关联到一个特定的ServicePoint对象,该对象的缺省ConnectionLimit值为2。由于我的所有请求都指向相同的uri,所以只应该创建一个ServicePoint对象,因此将我限制在两个最大并发请求(假设管道关闭)。
在运行时,我实际看到的是,如果我“同时”调用我的PostTest()方法n,那么在任何响应被发送回之前,都会看到n数量的请求,因为服务器的api逻辑运行时间很长。
有人能解释为什么这个示例似乎超过了2的ServicePointManager.DefaultConnectionLimit吗?我最好的猜测是,由于我要为每个请求创建一个新的HttpClient,所以ServicePointManager在每个请求中创建一个ServicePoint对象,但根据我所读到的内容,我认为ServicePointManager应该只在每个唯一的模式和域中创建不同的ServicePoint实例,所以我不确定。
注意:我确实计划重用我的HttpClient实例,但是这个结果达到了我的好奇心:)。
发布于 2016-10-27 16:18:32
为了防止其他人好奇,我检查了一下HttpClient代码,看起来每个HttpClient每个实例都实例化一个HttpMessageHandler。HttpMessageHandler对象除了创建由HttpClient定义的uri的架构和域之外,每个实例都会创建一个哈希代码,用于创建ServicePoint对象。
发布于 2017-05-07 05:05:17
@cjablonski76 76我相信你的解释是错误的。因为根据框架代码创建ServicePoint如下所示。
sp = new ServicePoint(address)
{
ConnectionLimit = DefaultConnectionLimit,
IdleSince = DateTime.Now,
Expect100Continue = Expect100Continue,
UseNagleAlgorithm = UseNagleAlgorithm
};
s_servicePointTable[tableKey] = new WeakReference<ServicePoint>(sp);如果您看到这一点,则不使用支持您的语句的hashcode。
https://stackoverflow.com/questions/40144965
复制相似问题