同步并发 HttpClient 使用

Question

我正在尝试同步使用 HttpClient，但是当我发出许多并发请求时它停止工作。我写了两个测试，一个用于异步使用，一个用于同步使用。 TestMethod 总是在 4 秒后返回响应。异步测试工作正常。几乎所有请求在同步测试中都超时，只有大约 20 个最后的请求是成功的。我尝试使用单个 HttpClient 请求并为每个新请求创建新的 HttpClient 实例。没有不同。可能和this deadlock有关。

我正在将 VS2013 与面向 Framework 4.5 的 .NET Framework 4.5.1 一起使用。我通过 NuGet 获得 HttpClient：<package id="Microsoft.Net.Http" version="2.2.15" targetFramework="net45" />

我还不想异步使用HttpClient，因为这意味着我必须重写我的整个应用程序。任何想法我在这里做错了什么？

// all 800 requests complete successfully
[Test]
public async void Asyncmethod()
{
    var sw = new Stopwatch();
    sw.Start();

    var client = new HttpClient();
    client.Timeout = TimeSpan.FromSeconds(15);

    var tasks = Enumerable.Range(0, 800).Select(x => Task.Run(async () =>
    {
        try
        {
            var swx = new Stopwatch();
            swx.Start();
            var response = await client.GetStringAsync("http://localhost:7002/TestMethod").ConfigureAwait(false);
            swx.Stop();
            Console.WriteLine(x + " " + response + " in " + swx.ElapsedMilliseconds + " ms.");
        }
        catch (Exception e)
        {
            Console.WriteLine(x + " Exception: " + e.Message);
        }
    })).ToArray();

    await Task.WhenAll(tasks);

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
}

// almost all of 800 requests time out
[Test]
public void Syncmethod()
{
    var sw = new Stopwatch();
    sw.Start();

    var client = new HttpClient();

    var tasks = Enumerable.Range(0, 800).Select(x => Task.Run(() =>
    {
        try
        {
            var swx = new Stopwatch();
            swx.Start();
            var response = client.GetStringAsync("http://localhost:7002/TestMethod");
            if (response.Wait(15000))
            {
                swx.Stop();
                Console.WriteLine(x + " " + response.Result + " in " + swx.ElapsedMilliseconds + " ms.");
            }
            else
            {
                swx.Stop();
                Console.WriteLine(x + " timed out.");
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(x + " Exception: " + e.Message);
        }
    })).ToArray();

    foreach (var task in tasks)
        task.Wait(60000);

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
}

Answer 1

我建议您使用await 代替HttpClient 而不是Wait。如果您确实想要同步请求，请考虑使用支持同步方法的WebClient。

也就是说，我相信您看到这种行为的原因是由于ServicePointManager.DefaultConnectionLimit，它会限制对给定服务器的请求数量。如果您希望对同一服务器有大量并发请求（同步或异步），则需要增加该限制（UI 应用程序默认为 2）。

Answer 2

是的，这似乎是僵局。

这段代码完美运行

public static void Syncmethod()
    {
        var sw = new Stopwatch();
        sw.Start();

        var client = new HttpClient();

        var tasks = Enumerable.Range(0, 800).Select(x => Task.Run(() =>
        {

            var swx = new Stopwatch();
            swx.Start();
            var result =
            client.GetStringAsync("http://yandex.ru").ContinueWith(task =>
            {
                try
                {
                    swx.Stop();
                    Console.WriteLine(x + " " + task.Result + " in " + swx.ElapsedMilliseconds + " ms.");
                    return task.Result;
                }
                catch (Exception e)
                {
                    swx.Stop();
                    Console.WriteLine(x + " Exception: " + e.Message);
                    throw e;
                }
            }, TaskContinuationOptions.AttachedToParent);

        })).ToArray();

        foreach (var task in tasks)
            task.Wait(60000);

        sw.Stop();
        Console.WriteLine(sw.ElapsedMilliseconds);
    }

我猜你需要额外的逻辑来处理超时。例如，可能是在 15 秒内完成的另一项任务。

看这个帖子HttpClient.GetAsync(...) never returns when using await/async

如上所述，您可以通过简单的更改来挂起您的异步示例

var response = client.GetStringAsync("http://yandex.ru").GetAwaiter().GetResult();

当您编写异步代码时，永远不要使用阻止执行并等待结果。