快捷導(dǎo)航

C#控制臺(tái)程序同步調(diào)用WebApi實(shí)現(xiàn)方式

更新時(shí)間：2025年08月12日 15:05:59 作者：暗黑技能

控制臺(tái)程序作為Job時(shí),需同步調(diào)用WebApi以確保獲取返回結(jié)果后執(zhí)行后續(xù)操作,否則會(huì)引發(fā)TaskCanceledException異常,同步處理可避免異步導(dǎo)致的錯(cuò)誤,用戶(hù)提供了Cls001類(lèi)中的實(shí)現(xiàn)示例,供參考學(xué)習(xí)

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.<—

同步調(diào)用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"];/*帳號(hào)*/
                string Password = ConfigurationManager.AppSettings["Password"];/*密碼*/
                string base64Auth = UserID + ":" + Password; /*合并帳號(hào)密碼*/
                System.Text.Encoding encode = System.Text.Encoding.UTF8;
                byte[] bytedata = encode.GetBytes(base64Auth);
                string token = Convert.ToBase64String(bytedata);/*編碼轉(zhuǎn)Base64*/
                string postTest = "{\"action\":\"T\"}";
                string status =Cls001.PostResponse(url, postTest, token).Result;/*Cls001是新建的類(lèi)測(cè)試API是否暢通*/
                if (!status.Contains("200"))
                {
                    logger.Error(url + "無(wú)法訪問(wèn)！********" + status.ToString() + "**********End:" + DateTime.Now.ToString() + "******************");
                    return;
                }
              }
           catch (Exception Msg)
            {
               logger.Error("程序處理出錯(cuò)，請(qǐng)盡快聯(lián)系管理員處理！"+Msg);
               logger.Info("******************End:" + DateTime.Now.ToString() + "******************");
               return;
            }
        }
    }
}

Cls001類(lèi)里面的寫(xiě)法

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 Cls001
    {
            static ILog logger;
            
            /*該方法為同步請(qǐng)求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); /*這里請(qǐng)求時(shí)用到同步*/
                if (response.IsSuccessStatusCode)
                {
                    result = response.Content.ReadAsStringAsync().Result;
                    return result;
                }
                if (!response.IsSuccessStatusCode)
                {
                    result = "Error";
                }                
            }
            catch (Exception Msg)
            {
                logger.Error(Msg);
            }
            return result;
        ｝
    ｝
｝