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

 更新时间:2025年08月12日 15:05:59   作者:暗黑技能  
控制台程序作为Job时,需同步调用WebApi以确保获取返回结果后执行后续操作,否则会引发TaskCanceledException异常,同步处理可避免异步导致的错误,用户提供了Cls001类中的实现示例,供参考学习

控制台程序一般当作Job使用,有时候需要控制台程序调用WebApi返回结果后才能执行下一步动作,否则会出错,所以这个时候就需要同步处理。

关于异步调用还是同步调用的相关说明这里不做详细阐述,请自行查找资料。

如果是异步就会报错如下:

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

同步调用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;
                }
              }
           catch (Exception Msg)
            {
               logger.Error("程序处理出错,请尽快联系管理员处理!"+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.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;
            
            /*该方法为同步请求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;
                }
                if (!response.IsSuccessStatusCode)
                {
                    result = "Error";
                }                
            }
            catch (Exception Msg)
            {
                logger.Error(Msg);
            }
            return result;
        }
    }
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 深入了解c# 迭代器和列举器

    深入了解c# 迭代器和列举器

    这篇文章主要介绍了c# 迭代器和列举器的相关资料,帮助大家更好的理解和学习C#,感兴趣的朋友可以了解下
    2020-08-08
  • 说说C#的async和await的具体用法

    说说C#的async和await的具体用法

    本篇文章主要介绍了说说C#的async和await的具体用法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • c# mutex互斥量的深入解析

    c# mutex互斥量的深入解析

    本篇文章主要是对c#中的mutex互斥量进行了详细的分析介绍,需要的朋友可以过来参考下,希望对大家有所帮助
    2014-01-01
  • C#实现Excel工作表拆分的项目实践

    C#实现Excel工作表拆分的项目实践

    本文介绍了使用 C# 和 Free Spire.XLS 免费库实现 Excel 工作表拆分的完整方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2026-01-01
  • Unity实现换装系统

    Unity实现换装系统

    这篇文章主要为大家详细介绍了Unity实现换装系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-04-04
  • C#如何优雅地取消进程的执行之Cancellation详解

    C#如何优雅地取消进程的执行之Cancellation详解

    本文介绍了.NET框架中的取消协作模型,包括CancellationToken的使用、取消请求的发送和接收、以及如何处理取消事件
    2024-12-12
  • 利用C#实现绘制出地球旋转效果

    利用C#实现绘制出地球旋转效果

    这篇文章主要为大家详细介绍了如何利用C#语言实现绘制出地球旋转的效果,文中的示例代码讲解详细,具有一定的参考价值,需要的可以了解一下
    2023-02-02
  • C#中按指定质量保存图片的实例代码

    C#中按指定质量保存图片的实例代码

    这篇文章主要介绍了C#中按指定质量保存图片的实例代码,有需要的朋友可以参考一下
    2013-12-12
  • C#创建及访问网络硬盘的实现

    C#创建及访问网络硬盘的实现

    本文主要介绍了C#创建及访问网络硬盘的实现,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-03-03
  • C#使用Data Annotations进行手动数据验证

    C#使用Data Annotations进行手动数据验证

    这篇文章介绍了C#使用Data Annotations进行手动数据验证的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-06-06

最新评论