要求C#语言在微博service接口中使用content-type：multiparty/form-data属性，上传csv文件，且头部添加bear格式的jwt鉴权。实现通过接口完成批量数据的传输及同步。

//全局变量

public string urlHost=“”；

#region 主函数

[WebMethod(Description="连通性测试")]

public void TestBatch()

{

        urlHost="http://22.22.22.22.:8089/tencent";

        if(!string.IsNullOrEmpty(urlHost))

        {

                //根目录

                string departID = "tt-6e4rrtty4579dsfs96";

                //urlHost 访问地址的接口地址

                urlHost+=string.Format(@"/api/v"+departID +"/obj?obj=user");

                #region 创建文件

                DateTime dt = DateTime.Now;

                string TencentBatch=ConfigurationManager.AppSettings["mulu1"];

                string headPath=ConfigurationManager.AppSettings["mulu2"];

                string middlePath=TencentBatch+dt.Year+"/"+(dt.Month<10?"0":"")+dt.Month+"/"+(dt.Day<10?"0":"")+dt.Day+"/";

                if(!System.IO.Directory.Exists(headPath+middlePath.Replace("/","\\")))

                {

                        Directory.CreateDirectory(headPath+middlePath.Replace("/","\\"));

                }

                //eg:D:\\测试文件夹\\测试1\\测试2\2022\01\22\aa_1_1.csv

                string path = headPath+middlePath.Replace("/","\\")+"aa_1_1.csv";

               int pos=path.LastIndexOf("\\");

                string fileName=path.Substring(pos+1);

               string firstLine=string.Format(@"id,modifiedOn");

               //tchModel上送模板的列明，

               List<tchModel> lt = new List<tchModel>();

               tchModel tmbm = new tchModel();

               tmbm .id="id2";

               tmbm .modifiedOn="2022/02/02";

               lt.Add(tmbm);

               bool bl=WriteFile<tmbm>(path,lt,firstLine); 

                #endregion

                //自定义请求方式

                HttpRequestMessage requestMessage=new HttpRequestMessage();

                requestMessage.Method = HttpMethod.Put;

                requestMessage.RequestUri = new Uri(urlHost);

                //1.数据流存入

                Stream fileStream=new FileStream(path,FileMode.Open,FileAccess.Read); 

                var formData=new MultipartFormDataContent();

                formData.Add(new StreamContent(fileStream),"file",fileName);

                /*

                //2.字节存入

                Stream fileStream=new FileStream(path,FileMode.Open,FileAccess.Read); 

                byte[] data = new byte[fileStream.Length]

                fileStream.Read(data,0,data.Length);

                fileStream.Close();

                formData.Add(new ByteArrayContent(data),"file",fileName); 

                */

                requestMessage.Content=formData;

                /*

                //！注意：千万别指定Content-Type的multiparty/form-data属性，因为该属性会添加boundary属性，其是不可控的。

                //这个值有浏览器生成的。如果强行指明很可能导致边界值不一致而失败。报错信息为

                //result{ StatusCode:400,ReasonPhrase:'Bad Request',Version:1.1,Content:System.Net.Http.StreamContent,Headers:{ i-transaction-id:9bfe3a88-cla8-43df-b9b9-630fdef601de

                //x-envoy-upstream-service-time:16

                //Connection:close

                //Date:Thu,27 Jan 2022 08:09:17 GMT

                //Server:nginx

                //Content-Length:0 } }

                string boundary =string.Format（“-------test{0}-------”,DateTime.Now.Ticks.ToString("x")）；

                formData =new MultipartFormDataContent(boundary);

                requestMessage.Content.Headers.ContentType = new MediaTypeHeaderValue("multipart/form-data");

                */

                HttpClient client = new HttpClient();

                var authenticationHeaderValue = new AuthenticationHeaderValue("Bearer",GetToken());

                client.DefaultRequestHeaders.Authorization = authenticationHeaderValue;

                client.DefaultRequestHeaders.Add("CharSet","utf-8");

                HttpResponseMessage result = client.SendAsync(requestMessage).Result;

                string responseResult = result.Content.ReadAsStringAsync().Result;

                client.Dispose();

                fileStream.Close();

                try{

                        if(result.IsSuccessStatusCode)

                        {

                                string r=result.Content.ReadAsStringAsync().Result;

                                Context.Response.Write(r);

                        }                

                }finally{

                        fileStream.Close();

                        client.Dispose();

                }

        }

}

#endregion

//====================生成文件===================

public static bool WriteFile<T>(string fileName,List<T> dataTable,string firstLine)

{

        bool flag = false;

        try{

                if(File.Exists(fileName))

                {

                        File.Delete(fileName);

                }

                using(FileStream fs=new FileStream(fileName,FileMode.Create))

                {

                        //指定Encodeing.UTF8，避免生成的文件乱码

                        using(StreamWriter sw = new StreamWriter(fs,Encodeing.UTF8))

                        {

                                string info Line= string.Empty;

                                sw.WriteLine(firstLine);

                                foreach(var item in dataTable)

                                {

                                        infoLine +=",,";

                                }

                                sw.Close();        

                        }

                        fs.Close();

                }

        }

}

//-----生成J问题Token---

public string Get Token（）

{

        var headers = new Dictionary<string,object>(){

                {"type","JWT"},

                {"kid","58888888-8888-8888-8888-888888888888"}

        };

        long iat =(long)DateTime.Now.ToUniversalTime().Subtract(new DateTime(1970,1,1)).TotalSeconds;

        long exp =(long)DateTime.Now.AddMinutes(1.0).ToUniversalTime().Subtract(new DateTime(1970,1,1)).TotalSeconds;

        var claims = new Dictionary<string,object>()

        {

                {"aud","test"},

                {"iss","22222222-2222-2222-2222-222222222222"},

                {"iat",iat},

                {"exp",exp},

                {"accounttype","serviceA"}

        };

        //需要通过pem实例化[RS256算法，需要实例化RSAParameters ]

        RSACryptoServiceProvider privateKey;

        string path=HttpContext.Current.Server.MapPath("~/"+"test-pri.pem");

        StreamReader reader =new StreamReader(path);

        PemReader pemReader = new PemReader(reader);

        AsymmetricCipherKeyPair keyPair = (AsymmetricCipherKeyPair)pemReader.ReadObject();

        RSAParameters rsaParameters=DotNetUtilities.ToRSAParameters((RsaPrivateCrtKeyParameters)keyPair.Private);

        privateKey = new RSACryptoServiceProvider();

        privateKey.ImportParameters(rsaParameters);

        var token=Jose.JWT.Encode(claims,privateKey,Jose.JwsAlgorithm.RS256,extraHeaders:headers);

        return token;

}