如何将我的异步帖子转换为同步？答案

【问题标题】：How can I transform my aysnc post to sync?如何将我的异步帖子转换为同步？
【发布时间】：2018-12-06 15:48:00
【问题描述】：

我编写了一个 C# 程序，它以异步方式向供应商发出 API 调用以生成提交令牌。然后将此令牌附加到任何表单发布有效负载以验证其完整性。它作为一个独立的 .Net 4.6.1 应用程序非常有用。我遇到的问题是将它集成到我的 CMS 中。在与 CMS 支持人员交谈后，他们要求我将其改为同步操作。我无法转换我的代码。特别是关于在我检索到令牌后发布表单的部分。

这是我最初编写的源代码。显然 AppID 和秘密已被删除。

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.IO;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using System.Web.UI;

namespace FormSubmission
{
    public partial class _Default : Page
    {
        protected async void Page_Load(object sender, EventArgs e)
        {
            var start = new Start();
            await start.KickOff();
        }

        public class Start
        {

            public async Task<String> KickOff()
            {
                var auth = new Authentication();
                var token = await auth.Authenticate();

                // return await Task.FromResult(token);
                // //Task.FromResult(token);
                if (!String.IsNullOrEmpty(token))
                {
                    var form = new FormSubmission();
                    var formFields = new Form();
                    formFields.createMethod = "SubmitForm";
                    formFields.email = "email@email.com";
                    formFields.mobile = "555-555-5555";
                    formFields.remark = "Hello, hope this works";
                    formFields.attr.attr3 = "mnc";
                    formFields.attr.attr6 = "1000";
                    formFields.attr.attr10 = "first name";
                    formFields.attr.attr11 = "lastname";
                    formFields.attr.attr14 = "City";
                    formFields.attr.attr15 = "State";
                    formFields.attr.attr18 = "USA";
                    formFields.attr.attr25 = "USA";
                    formFields.attr.attr28 = "Newsletter";

                    var serializer = JsonSerializer.Create();

                    var optionsString = new StringBuilder();
                    var writer = new StringWriter(optionsString);

                    serializer.Serialize(writer, formFields);

                    await form.Submit(token, optionsString.ToString());
                }

                return await Task.FromResult("");

            }
        }

        public class Authentication 
        {
            private const string appId = "XXXXXXXXXXXXX";
            private const string secret = "XXXXXXXXXXXXXXXXXXXXXX";

            public async Task<String> Authenticate()
            {
                string url = "https://api-url-goes-here";
                string token = "";

                try
                {

                    using (var client = new HttpClient())
                    {
                        var responseMessage = await client.GetAsync(url + appId + "&secret=" + secret);
                        var content = await responseMessage.Content.ReadAsStringAsync();
                        var contentObject = JObject.Parse(content);
                        token = contentObject["access_token"].ToString();
                        return token;
                    };
                }
                catch (Exception e)
                {
                    throw new Exception("Access token not found");
                }

            }
        }

        public class FormSubmission
        {

            public async Task Submit(string token, string json)
            {
                using (var client = new HttpClient())
                {
                    var message = await client.PostAsync(
                        "https://api-url-goes-here/access_token=" + token,
                        new StringContent(json, Encoding.UTF8, "application/json"));

                    var content = await message.Content.ReadAsStringAsync();
                    Console.Write(content);
                }
            }
        }
    }
}

此代码在与我的 CMS 的 .Net 版本匹配的新 .Net 项目中运行时效果很好。但是他们再次告诉我它不支持异步操作（这看起来很奇怪，但我显然不是一个出色的 C# 开发人员）

所以我重写了它。

public class Attr
{
    public string attr3;
    public string attr6;
    public string attr10;
    public string attr11;
    public string attr14;
    public string attr15;
    public string attr18;
    public string attr25;
    public string attr28;
}

public class FormSubmission
{
    public string mobile;
    public string email;
    public string remark;
    public string createMethod;
    public Attr attr = new Attr();
}
protected void Page_Load(object sender, EventArgs e)
{

    string token = fetchToken();


    var formFields = new FormSubmission();
    formFields.createMethod = "SubmitForm";
    formFields.email = "email@email.com";
    formFields.mobile = "5555555555";
    formFields.remark = "Non sync";
    formFields.attr.attr3 = "mnc";
    formFields.attr.attr6 = "1000";
    formFields.attr.attr10 = "first name";
    formFields.attr.attr11 = "last name";
    formFields.attr.attr14 = "City";
    formFields.attr.attr15 = "State";
    formFields.attr.attr18 = "USA";
    formFields.attr.attr25 = "USA";
    formFields.attr.attr28 = "Newsletter";

    var serializer = JsonSerializer.Create();

    var optionsString = new StringBuilder();
    var writer = new StringWriter(optionsString);

    serializer.Serialize(writer, formFields);


    var x = new submitForm();
    x.Submit(token, optionsString.ToString());
}

protected string fetchToken()
{

    string appId = "xxxxxxxxxxxxxxx";
    string secret = "xxxxxxxxxxxxxxxxxxxxxxxxxx";
    string url = "https://api-url-goes-here/security/accesstoken?grant_type=client_credentials&appid=";

    string token;

    try
    {
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url + appId + "&secret=" + secret);
        request.Method = "GET";
        request.KeepAlive = false;
        request.ContentType = "appication/json";

        HttpWebResponse response = (HttpWebResponse)request.GetResponse();

        string myResponse = "";

        using (System.IO.StreamReader sr = new System.IO.StreamReader(response.GetResponseStream()))
        {
            myResponse = sr.ReadToEnd();
        }

        JObject jobj = JObject.Parse(myResponse);
        token = jobj["access_token"].ToString();

        return token;


    }
    catch (Exception e)
    {
        return e.ToString();
    }

}

public class submitForm
{
    public void Submit(string token, string json)
    {
        using (var client = new HttpClient())
        {
            var message = client.PostAsync("https://api-url-goes-here/v1/customers?access_token=" + token,
                new StringContent(json, Encoding.UTF8, "application/json"));

        }
    }
}

如您所见，它应该是相同的代码。我在 submitForm 类的 Submit 方法中遇到的问题。当我运行我的程序并打开提琴手时，我可以看到获取令牌的请求。并收到一个令牌。给我问题的是 submitForm 类。我什至没有在提琴手中看到 POST 请求。谁能帮我吗？

这是给我带来问题的课程。

public class submitForm
{
    public void Submit(string token, string json)
    {
        using (var client = new HttpClient())
        {
            var message = client.PostAsync("https://api-url-goes-here/v1/customers?access_token=" + token,
                new StringContent(json, Encoding.UTF8, "application/json"));

        }
    }
}

【问题讨论】：

标签： c# http-post

【解决方案1】：

public void Submit(string token, string json)
{
    using (var client = new HttpClient())
    {
        var message = client.PostAsync("https://api-url-goes-here/v1/customers?access_token=" + token,
            new StringContent(json, Encoding.UTF8, "application/json"));

    }
}

这与您预期的不同，因为 message 现在是 Task，而不是您希望的响应，因为您没有等到 PostAsync 完成。

要实现同步，您有两种选择：

拨打.GetAwaiter().GetResult()就可以了。这可以在您之前使用await 的任何地方使用，并且不存在该方法的同步版本。例如：

public void Submit(string token, string json)
{
    using (var client = new HttpClient())
    {
        var message = client.PostAsync(
            "https://api-url-goes-here/access_token=" + token,
            new StringContent(json, Encoding.UTF8, "application/json")).GetAwaiter().GetResult();

        var content = message.Content.ReadAsStringAsync().GetAwaiter().GetResult();
        Console.Write(content);
    }
}

here 描述了使用.GetAwaiter().GetResult() 而不仅仅是.Result 的原因（主要是因为抛出异常的方式）。

或者，

使用 HttpWebRequest 而不是 HttpClient 发出相同的请求，就像您在代码的其他部分中所做的那样，因此您不必处理仅异步方法。

【讨论】：

这是“同步而不是异步”，从根本上来说是危险且不鼓励的。只是...谨慎对待:)
@MarcGravell 有些危险需要避免，是的，但一旦避免，就不再危险。但是，是的，我同意这并不理想。我更新了我的答案以包括根本不使用HttpClient 的另一个选项。
同步使用异步方法可能有效。但是，如果您使用的是外部库，您依赖它不会改变它的内部实现并导致您的代码中断。
感谢大家的cmets。上述解决方案对我有用，所以我接受了答案。但是，我将采用第二种选择，因为从对话中可以清楚地看出第一种并不理想。我还会将我的代码提交给我的 cms 支持团队，看看他们是否有任何建议。
.NET 中还有 WebClient 类。它比HttpClient 更早，但具有非异步方法，并且仍然比HttpWebRequest 更容易。有一个示例说明如何使用它发送 JSON here。还有here is 解释了HttpWebRequest、WebClient 和HttpClient 之间的区别。

【解决方案2】：

这可能不是您想听到的，但您不应该将异步方法转换为同步方法。当您使用GetAwaiter().GetResult() 时，您可能会很幸运它们可以正常工作，但存在死锁的风险，或者它们无法正常工作。您可以使用Task.Run 然后GetAwaiter().GetResult() 运行它们，但这会旋转另一个线程，因此效率不高，并且您的代码仍处于阻塞状态。使它比同步代码慢，因为它必须旋转另一个线程。另外，它肯定会分配更多 gc 必须处理的内存。

您还应该使用Async 后缀命名您的异步方法。

【讨论】：