C#控制台程序同步调用WebApi实现方式

本文主要是介绍C#控制台程序同步调用WebApi实现方式，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《C#控制台程序同步调用WebApi实现方式》控制台程序作为Job时,需同步调用WebApi以确保获取返回结果后执行后续操作,否则会引发TaskCanceledException异常,同步处理可避免异...

System.AggregateException: One or more errors occurred. —>
System.Threading.Tasks.TaskCanceledException: A task was canceled.
— End of inner exception stack trace — at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean
includeTaskCanceledExceptions) at
System.Threading.Tasks.Task1.GetResultCore(Boolean waitCompletionNotification) at System.Threading.Tasks.Task1.get_Result() at
SyncAccounts.Cls001.PostResponse(String url, String postData, String
token) in e:\SyncAccounts\Cls001.cs:line 49 at
SyncAccounts.Program.Main(String[] args) in
e:\SyncAccounts\Program.cs:line 78
—> (Inner Exception #0) System.Threading.Tasks.TaskCanceledException: A task was
canceled.<&China编程mdash;

同步调用WebApi方法

如下：

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using DataAccessTool;
using System.Web.Script.Serialization;
using log4net;
namespace SyncAccounts
{
    class Program
    {
            static string strConnect = "DB";
            static ILog logger;
            
        static void Main(string[] args)
        {
           try
            {
                string url = ConfigurationManager.AppSettings["url"];    
                string UserID = ConfigurationManager.AppSettings["UserID"];/*帐号*/
                string Password = ConfigurationManager.AppSettings["Password"];/*密码*/
                string base64Auth = UserID + ":" + Password; /*合并帐号密码*/
                System.Text.Encoding encode = System.Text.Encoding.UTF8;
                byte[] bytedata = encode.GetBytes(base64Auth);
                string token = Convert.ToBase64String(bytedata);/*编码转Base64*/
                string postTest = "{\"action\":\"T\"}";
                string status =Cls001.PostResponse(url, postTest, token).Result;/*Cls001是新建的类测试API是否畅通*/
                if (!status.Contains("200"))
                {
                    logger.Error(url + "无法访问！********" + status.ToString() + "**********End:" + DateTime.Now.ToString() + "******************");
                    return;
                js}
              }
           catch (Exception Msg)
            {
               logger.Ejsrror("程序处理出错，请尽快联系管理员处理！"+Msg);
               logger.Info("******************End:" + DateTime.Now.ToString() + "******************");
               return;
            }
        }
    }
}

Cls001类里面的写法

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Net;
using System.Netphp.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using DataAccessTool;
using System.Web.Script.Serialization;
using log4net;
namespace SyncAccounts
{
    class Cls001
    {
            static ILog logger;
            
            /*该方法为同步请求Api。*/
        public async static Task<string> PostResponse(string url, string postData, string token)
        {
           string result = null;
            try
            {
                if (url.StartsWith("https"))
                System.Net.ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
                HttpContent httpContent = new StringContent(postData);
                httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
                httpContent.Headers.ContentType.CharSet = "utf-8";
                HttpClient httpClient = new HttpClient();
                AuthenticationHeaderValue authValue = new AuthenticationHeaderValue("Basic", token);
                httpClient.DefaultRequestHeaders.Authorization = authValue;
                HttpResponseMessage response = await httpClient.PostAsync(url, httpContent); /*这里请求时用到同步*/
                if (response.IsSuccessStatusCode)
                {
                    result = response.Content.ReadAsStringAsync().Result;
                    return result;
                }
  javascript              if (!response.IsSuccessStatusCode)
                {
                    result = "Error";
                }                
            }
            catch (Exception Msg)
            {
                logger.Error(Msg);
            }
            return result;
        ｝
    ｝
｝