在foreach中使用HTTPClient实现Async/await

Question

我有一个webservice，它加载一些插件并调用它们的过程方法。其中一个插件获取成员列表，并确保它们都包含在MailChimp列表中。

    private async Task AddMCUsers(List<Member> _memberList)
    {
        using (var http = new HttpClient())
        {
            var creds = Convert.ToBase64String(Encoding.ASCII.GetBytes("user:password");
            http.DefaultRequestHeaders.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Basic", creds);
            string memberURI = string.Format(@"{0}lists/{1}/members", _baseURI, _memberGroupId);
            var jss = new JavaScriptSerializer();

            foreach (var user in _memberlist)
            {
                var _addStatus = "";

                try
                {
                    var content = jss.Serialize(new MCPost()
                    {
                        email_address = user.Email,
                        status = "subscribed",
                        merge_fields = new MCMergeFields()
                        {
                            FNAME = user.Firstname,
                            LNAME = user.Lastname
                        }
                    });

                    using(var result = await http.PostAsync(memberURI, new StringContent(content,Encoding.UTF8, "application/json")))
                    {
                        var resultText = await result.Content.ReadAsStringAsync();

                        if(result.IsSuccessStatusCode)
                        {
                            _addStatus = "Success";
                            var _returnedUser = jss.Deserialize<MCMember>(resultText);
                            //Store new user's id
                            user.ServiceId = _returnedUser.id;
                        }
                        else
                        {
                            _addStatus = "Fail";
                        }
                    }
                }
                catch {
                    _addStatus = "Error";
                }

                LogEvent("Add User - " + _addStatus, string.Format("Id: {0} - {1} {2} (Account: {3}) : {4}", user.Id, user.Firstname, user.Lastname, user.AccountId, user.Email));

            }
        }
    }

在正常的过程代码中，这不会是一个问题。但是，httpClient上唯一可用的Post方法是PostAsync。对于Async/Await来说，我是相当陌生的，我不确定我的其余代码会有什么影响……特别是因为它涉及到我试图重用httpClient而不是为每个http调用实例化一个新的httpClient。

我不确定当await像我一样被包裹在foreach中时会发生什么。在异步运行时，重用httpClient进行重复调用是否会遇到问题？

我的另一个问题是，实际要返回的是什么。我的理解是等待返回任务。然而，在这里，我正在遍历列表并进行多次调用以等待PostAsync。我的方法返回一个任务。但是哪个任务会被返回呢？如果我的调用方法需要等待完成才能继续，那么它的调用是什么样子的？

private void Process()
{
    //Get List

    var task = AddMCUsers(list);
    task.Wait();

    //Subsequent processing
 }

我读到你应该一直使用异步。这是否意味着我的调用方法应该更像这样？

 public async Task Process()
 {
    //Get list
    ...
    await AddMCUsers(list);

    //Other processing
  }

感谢你在这方面能提供的任何帮助。

Answer 1

在正常的过程代码中，这不会是一个问题。

Async/Await的全部意义在于以一种看起来与“普通”同步代码几乎相同的方式编写异步代码。

对于Async/Await来说，我是相当陌生的，我不确定我的其余代码会有什么影响……特别是因为它涉及到我试图重用httpClient而不是为每个http调用实例化一个新的httpClient。

HttpClient旨在重用；事实上，它可以同时用于任意数量的调用。

我不确定当await像我一样被包裹在foreach中时会发生什么。

一种方法是await“暂停”该方法，直到其操作完成。当操作完成时，方法继续执行。我有一个Async介绍，其中有更详细的内容。

在异步运行时，重用httpClient进行重复调用是否会遇到问题？

不,这很好.

我的理解是等待返回任务。

是的，它应该看起来像您的第二个代码片段：

public async Task ProcessAsync()
{
  //Get list
  ...
  await AddMCUsers(list);

  //Other processing
}

我唯一更改的是Async后缀，这是基于任务的异步模式推荐的。