項(xiàng)目需要將音視頻文件上傳服務(wù)器，考慮并發(fā)要求高，通過七牛來實(shí)現(xiàn)。

做了一個(gè)簡(jiǎn)易的壓力測(cè)試，同時(shí)上傳多個(gè)文件，七牛自己應(yīng)該有隊(duì)列處理并發(fā)請(qǐng)求，我無論同時(shí)提交多少個(gè)文件，七牛是批量一個(gè)個(gè)排隊(duì)處理了。

一個(gè)1.5MB的文件，上傳時(shí)間大概2-3秒，感覺不錯(cuò)。?

?

直接上代碼

?

using Qiniu.IO; using Qiniu.IO.Resumable; using Qiniu.RPC; using Qiniu.RS; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks;namespace qiniuTest {/// <summary>/// 文件上傳有兩種方式:/// 一種是以普通方式直傳文件，簡(jiǎn)稱普通上傳;/// 另一種方式是斷點(diǎn)續(xù)上傳，斷點(diǎn)續(xù)上傳在網(wǎng)絡(luò)條件很一般的情況下也能有出色的上傳速度，而且對(duì)大文件的傳輸非常友好。/// </summary>class Program{static string bucket = "cvteXXXX";static void Main(string[] args){Qiniu.Conf.Config.ACCESS_KEY = "6QQ7Cnz4bljdkQOWQ5UOAheVCAd0bCa7Tc5XXXXX";Qiniu.Conf.Config.SECRET_KEY = "9rUGnbFtvm-PLWcZeOR6ed9MUjZ4bKitf7YXXXX";string fileKey = "應(yīng)用系統(tǒng)全貌圖.png";//GetFileStat(bucket, fileKey);//小文件直傳string fileName = "CVTE信息系統(tǒng)-業(yè)務(wù)功能架構(gòu)圖-IM和企業(yè)微信.jpg";//PutFile(bucket, Guid.NewGuid().ToString() + fileName, "d:\\" + fileName);//在asp.net mvc中的文件上傳//ResumablePutFile(bucket, Guid.NewGuid().ToString(), Path.Combine(path, Request.Form[0]));//大文件上傳//string bigFileName = "eclipse-java-luna-SR1-win32-x86_64.zip";//ResumablePutFile(bucket, Guid.NewGuid().ToString() + bigFileName, "d:\\Software\\" + bigFileName);//GetFile("7xq1c1.com1.z0.glb.clouddn.com", fileKey);//********************** 壓力測(cè)試 **********************// 獲取線程池的最大線程數(shù)和維護(hù)的最小空閑線程數(shù)int maxThreadNum, portThreadNum;int minThreadNum;ThreadPool.GetMaxThreads(out maxThreadNum, out portThreadNum);ThreadPool.GetMinThreads(out minThreadNum, out portThreadNum);Console.WriteLine("最大線程數(shù)：{0}", maxThreadNum);Console.WriteLine("最小空閑線程數(shù)：{0}", minThreadNum);int loopNumber = 1; //內(nèi)部循環(huán)次數(shù)int ConcurrentNumber = 10; //并發(fā)數(shù)for (int i = 0; i < ConcurrentNumber; i++){ThreadPool.QueueUserWorkItem(new WaitCallback(TaskProc), loopNumber);}Console.ReadLine();}public static void TaskProc(object loopNumber){int LoopNumber = Convert.ToInt32(loopNumber);Console.WriteLine("啟動(dòng)任務(wù)，小文件直傳");//小文件直傳 壓力測(cè)試for (int i = 0; i < LoopNumber; i++){string fileName = "WinRAR.exe";Console.WriteLine(i + "開始" + fileName + System.DateTime.Now);PutFile(bucket, Guid.NewGuid().ToString() + fileName, "D:\\" + fileName);Console.WriteLine(i + "完成" + fileName + System.DateTime.Now);string fileName1 = "WinRAR1.exe";Console.WriteLine(i + "開始" + fileName1 + System.DateTime.Now);PutFile(bucket, Guid.NewGuid().ToString() + fileName1, "D:\\" + fileName1);Console.WriteLine(i + "完成" + fileName1 + System.DateTime.Now);}}/// <summary>/// 查看單個(gè)文件屬性信息/// </summary>/// <param name="bucket">七牛云存儲(chǔ)空間名</param>/// <param name="key">文件key,也就是文件名</param>public static void GetFileStat(string bucket, string key){RSClient client = new RSClient();Entry entry = client.Stat(new EntryPath(bucket, key));if (entry.OK){Console.WriteLine("Hash: " + entry.Hash);Console.WriteLine("Fsize: " + entry.Fsize);Console.WriteLine("PutTime: " + entry.PutTime);Console.WriteLine("MimeType: " + entry.MimeType);Console.WriteLine("Customer: " + entry.Customer);}else{Console.WriteLine("Failed to Stat");}}/// <summary>/// 刪除單個(gè)文件/// </summary>/// <param name="bucket">文件所在的空間名</param>/// <param name="key">文件key</param>public static void Delete(string bucket, string key){Console.WriteLine("\n===> Delete {0}:{1}", bucket, key);RSClient client = new RSClient();CallRet ret = client.Delete(new EntryPath(bucket, key));if (ret.OK){Console.WriteLine("Delete OK");}else{Console.WriteLine("Failed to delete");}}/// <summary>/// 批量刪除文件/// </summary>/// <param name="bucket">文件所在的空間名</param>/// <param name="keys">文件key</param>public static void BatchDelete(string bucket, string[] keys){RSClient client = new RSClient();List<EntryPath> EntryPaths = new List<EntryPath>();foreach (string key in keys){Console.WriteLine("\n===> Stat {0}:{1}", bucket, key);EntryPaths.Add(new EntryPath(bucket, key));}client.BatchDelete(EntryPaths.ToArray());}/// <summary>/// 普通方式直傳文件/// </summary>/// <param name="bucket">文件所在的空間名</param>/// <param name="key">您可以自行定義文件Key，一般GUID</param>/// <param name="fname">文件路徑+文件名</param>public static void PutFile(string bucket, string key, string fname){var policy = new PutPolicy(bucket, 3600);string upToken = policy.Token();PutExtra extra = new PutExtra();IOClient client = new IOClient();client.PutFile(upToken, key, fname, extra);}/// <summary>/// 斷點(diǎn)續(xù)上傳方式，傳大文件用這種方式/// </summary>/// <param name="bucket">文件所在的空間名</param>/// <param name="key">您可以自行定義文件Key，一般GUID</param>/// <param name="fname">文件路徑+文件名</param>public static void ResumablePutFile(string bucket, string key, string fname){Console.WriteLine("\n===> ResumablePutFile {0}:{1} fname:{2}", bucket, key, fname);PutPolicy policy = new PutPolicy(bucket, 3600);string upToken = policy.Token();Settings setting = new Settings();ResumablePutExtra extra = new ResumablePutExtra();ResumablePut client = new ResumablePut(setting, extra);client.PutFile(upToken, fname, Guid.NewGuid().ToString());}/// <summary>/// Get方式獲取文件/// </summary>/// <param name="domain">文件域</param>/// <param name="key">文件Key</param>public static void GetFile(string domain, string key){System.Diagnostics.Process.Start("http://" + domain + "/" + key);}} }

?

另外，七牛的魔法變量非常強(qiáng)大，多用于增強(qiáng)回調(diào)

魔法變量

魔法變量是一組預(yù)先定義的變量，可以使用?$(var)?或?$(var.field_name)?形式求值。

目前可用的魔法變量如下:

變量名	包含子項(xiàng)	變量說明	適用范圍
bucket	?	獲得上傳的目標(biāo)空間名。	?
key	?	獲得文件保存在空間中的資源名。	?
etag	?	文件上傳成功后的HTTP ETag。若上傳時(shí)未指定資源ID，Etag將作為資源ID使用。	?
fname	?	上傳的原始文件名。	不支持用于分片上傳
fsize	?	資源尺寸，單位為字節(jié)。	?
mimeType	?	資源類型，比如JPG圖片的資源類型為image/jpg。	?
endUser	?	上傳時(shí)指定的endUser字段，通常用于區(qū)分不同終端用戶的請(qǐng)求。	?
persistentId	?	音視頻轉(zhuǎn)碼持久化的進(jìn)度查詢ID。	?
exif	是	獲取所上傳圖片的Exif信息。 該變量包含子字段，比如對(duì)$(exif.ApertureValue.val)取值將得到該圖片拍攝時(shí)的光圈值。	暫不支持用于saveKey中
imageInfo	是	獲取所上傳圖片的基本信息。 該變量包含子字段，比如對(duì)$(imageInfo.width)取值將得到該圖片的寬度。	暫不支持用于saveKey中
year	?	上傳時(shí)的年份。	暫不支持用于’returnBody’、’callbackBody’中
mon	?	上傳時(shí)的月份。	暫不支持用于’returnBody’、’callbackBody’中
day	?	上傳時(shí)的日期。	暫不支持用于’returnBody’、’callbackBody’中
hour	?	上傳時(shí)的小時(shí)。	暫不支持用于’returnBody’、’callbackBody’中
min	?	上傳時(shí)的分鐘。	暫不支持用于’returnBody’、’callbackBody’中
sec	?	上傳時(shí)的秒鐘。	暫不支持用于’returnBody’、’callbackBody’中
avinfo	是	音視頻資源的元信息。	暫不支持用于’saveKey’中
imageAve	?	圖片主色調(diào)，算法由Camera360友情提供。	?
ext	?	上傳資源的后綴名，通過自動(dòng)檢測(cè)的 mimeType 或者原文件的后綴來獲取。	不支持用于分片上傳
uuid	?	生成uuid	暫不支持用于’saveKey’中
bodySha1	?	callbackBody的sha1(hex編碼)	只支持用于’callbackUrl’中

魔法變量支持$(<Object>.<Property>)形式的訪問子項(xiàng)，例如：

• $(<var>)
• $(<var>.<field_name>)
• $(<var>.<field_name>.<sub_field_name>)

求值舉例：

• $(bucket)?- 獲得上傳目標(biāo)bucket名字
• $(imageInfo)?- 獲取當(dāng)前上傳圖片的基本屬性信息
• $(imageInfo.height)?- 獲取當(dāng)前上傳圖片的原始高度

回調(diào)通知（callback）

可以設(shè)置上傳策略（PutPolicy）中的callbackUrl字段,并且設(shè)置callbackBody字段。

“自定義回調(diào)”具體實(shí)現(xiàn)

/// <summary>/// 文件上傳后的自定義回調(diào)/// </summary>/// <param name="bucket">文件所在的空間名</param>/// <param name="key">您可以自行定義文件Key，一般GUID</param>/// <param name="fname">文件路徑+文件名</param>public static PutRet PutFile(string bucket, string key, string fname){var policy = new PutPolicy(bucket, 3600);policy.ReturnBody = "{\"key\": $(key), \"hash\": $(etag), \"extra\": $(x:extra), \"callbackUrl\": $(x:callbackUrl)}";//policy.CallBackBody = "name=$(fname)&location=$(x:location)&price=$(x:price)";//policy.CallBackUrl = "http://ip/url";string upToken = policy.Token();PutExtra extra = new PutExtra(); //擴(kuò)展屬性Dictionary<string,string> dict =new Dictionary<string,string>();dict.Add("x:extra", "location=shanghai&age=28");dict.Add("x:callbackUrl", "http://127.0.0.1/callback");extra.Params = dict;IOClient client = new IOClient();return client.PutFile(upToken, key, fname, extra);}

?

?

完整源代碼下載 ：source code

總結(jié)

以上是生活随笔為你收集整理的C#使用七牛云存储上传下载文件、自定义回调的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。