C#實(shí)現(xiàn)FTP文件下載及超時(shí)控制詳解
前言
如果你的函數(shù)不是async,你仍然可以實(shí)現(xiàn)相同的超時(shí)功能,但你將不得不依賴(lài)更多的同步代碼或使用.Result或.GetAwaiter().GetResult()來(lái)阻塞等待任務(wù)完成,這可能導(dǎo)致死鎖的風(fēng)險(xiǎn),特別是在UI線(xiàn)程或ASP.NET上下文中。不過(guò),在一些簡(jiǎn)單的后臺(tái)任務(wù)或控制臺(tái)應(yīng)用程序中,這種方法可能是可行的。
以下是如何在非異步函數(shù)中實(shí)現(xiàn)FTP請(qǐng)求與超時(shí)控制的示例:
using System; using System.Net; using System.Threading.Tasks; public bool DownloadFileWithTimeoutSync(string uri, string localPath) { var ftpRequest = (FtpWebRequest)WebRequest.Create(uri); ftpRequest.Method = WebRequestMethods.Ftp.DownloadFile; // 設(shè)置FtpWebRequest其他屬性,如Credentials等 Task<bool> ftpTask = Task.Run(() => { try { using (var response = (FtpWebResponse)ftpRequest.GetResponse()) using (var responseStream = response.GetResponseStream()) using (var fileStream = System.IO.File.Create(localPath)) { responseStream.CopyTo(fileStream); } return true; // 或者根據(jù)響應(yīng)狀態(tài)返回成功/失敗 } catch { return false; } }); // 創(chuàng)建一個(gè)延遲10秒的超時(shí)任務(wù) Task delayTask = Task.Delay(TimeSpan.FromSeconds(10)); // 等待FTP任務(wù)完成或超時(shí) var completedTask = Task.WhenAny(ftpTask, delayTask).GetAwaiter().GetResult(); if (completedTask == ftpTask) { // FTP任務(wù)完成,檢查結(jié)果 return ftpTask.GetAwaiter().GetResult(); } else { // 超時(shí)發(fā)生 // 這里可以根據(jù)需要取消FTP請(qǐng)求 return false; } }
請(qǐng)注意,使用.Result或.GetAwaiter().GetResult()會(huì)導(dǎo)致當(dāng)前線(xiàn)程阻塞,直到任務(wù)完成。這在后臺(tái)線(xiàn)程或控制臺(tái)應(yīng)用程序中可能是可以接受的,但在UI線(xiàn)程中使用時(shí)可能會(huì)導(dǎo)致應(yīng)用程序無(wú)響應(yīng)。如果可能,最佳實(shí)踐是使用async和await,因?yàn)樗鼈兲峁┝烁忧逦桶踩姆绞絹?lái)處理異步操作和并發(fā)。
此外,當(dāng)你調(diào)用.GetAwaiter().GetResult()或.Result時(shí),如果任務(wù)中拋出了異常,這些異常會(huì)被封裝在AggregateException中。如果你需要處理特定的異常類(lèi)型,可能需要檢查AggregateException的InnerExceptions屬性。
場(chǎng)景描述
在進(jìn)行FTP文件下載時(shí),我們可能會(huì)遇到網(wǎng)絡(luò)延遲或服務(wù)不穩(wěn)定的情況,這時(shí)候?yàn)橄螺d任務(wù)設(shè)置一個(gè)超時(shí)限制就顯得非常必要。如果超出了預(yù)定的時(shí)間限制,程序應(yīng)該能夠自動(dòng)放棄下載任務(wù),以避免無(wú)限期地等待,影響用戶(hù)體驗(yàn)。
實(shí)現(xiàn)步驟
我們的目標(biāo)是創(chuàng)建一個(gè)同步方法DownloadFileWithTimeoutSync,這個(gè)方法封裝了異步操作,用于從FTP服務(wù)器下載文件,并且如果操作超過(guò)了指定的時(shí)間(比如10秒),則自動(dòng)取消。
1. 創(chuàng)建FTP請(qǐng)求
首先,我們需要?jiǎng)?chuàng)建一個(gè)FtpWebRequest對(duì)象,并設(shè)置必要的屬性,如請(qǐng)求方法、憑證等。
var ftpRequest = (FtpWebRequest)WebRequest.Create(uri); ftpRequest.Method = WebRequestMethods.Ftp.DownloadFile;
2. 開(kāi)啟異步下載任務(wù)
我們通過(guò)Task.Run啟動(dòng)一個(gè)異步任務(wù)來(lái)執(zhí)行下載操作。這樣可以保持UI的響應(yīng)性,或者避免阻塞主線(xiàn)程。
Task<bool> ftpTask = Task.Run(() => { // 這里包含下載文件的邏輯 });
3. 實(shí)現(xiàn)超時(shí)控制
為了實(shí)現(xiàn)超時(shí)控制,我們使用Task.Delay創(chuàng)建一個(gè)延遲任務(wù),作為超時(shí)的計(jì)時(shí)器。然后,我們使用Task.WhenAny等待下載任務(wù)和超時(shí)任務(wù)中的任何一個(gè)首先完成。
Task delayTask = Task.Delay(TimeSpan.FromSeconds(10)); var completedTask = Task.WhenAny(ftpTask, delayTask).GetAwaiter().GetResult();
4. 處理下載結(jié)果和超時(shí)
最后,我們檢查是下載任務(wù)先完成還是超時(shí)任務(wù)。如果是下載任務(wù)完成,我們檢查下載是否成功;如果是超時(shí)任務(wù)先完成,則認(rèn)為下載操作超時(shí),返回失敗。
if (completedTask == ftpTask) { // 檢查下載結(jié)果 return ftpTask.GetAwaiter().GetResult(); } else { // 處理超時(shí) return false; }
總結(jié)
通過(guò)上述步驟,我們實(shí)現(xiàn)了一個(gè)具有超時(shí)控制的FTP文件下載方法。這個(gè)方法既利用了異步編程的優(yōu)勢(shì)來(lái)提高應(yīng)用的性能和響應(yīng)性,又通過(guò)超時(shí)機(jī)制避免了因網(wǎng)絡(luò)問(wèn)題導(dǎo)致的長(zhǎng)時(shí)間等待。
異步編程在處理I/O密集型任務(wù)時(shí)尤為重要,它能夠有效地提升應(yīng)用程序的并發(fā)能力和用戶(hù)體驗(yàn)。希望本文的內(nèi)容能幫助你在實(shí)際開(kāi)發(fā)中更好地運(yùn)用異步編程技術(shù)。
到此這篇關(guān)于C#實(shí)現(xiàn)FTP文件下載及超時(shí)控制詳解的文章就介紹到這了,更多相關(guān)C# FTP文件下載與超時(shí)控制內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
基于C#解決庫(kù)存扣減及訂單創(chuàng)建時(shí)防止并發(fā)死鎖的問(wèn)題
這篇文章主要介紹了基于C#解決庫(kù)存扣減及訂單創(chuàng)建時(shí)防止并發(fā)死鎖的問(wèn)題,很多開(kāi)發(fā)人員對(duì)于這個(gè)問(wèn)題的排查起來(lái)是比較困難的,而生產(chǎn)生的原因多種多樣,很多人認(rèn)是因?yàn)楸碇械臄?shù)據(jù)太多了同時(shí)操作的人多人才會(huì)產(chǎn)生這種錯(cuò)誤,下面我們來(lái)還原一下死鎖的過(guò)程2022-05-05C# 站點(diǎn)IP訪(fǎng)問(wèn)頻率限制 針對(duì)單個(gè)站點(diǎn)的實(shí)現(xiàn)方法
下面小編就為大家?guī)?lái)一篇C# 站點(diǎn)IP訪(fǎng)問(wèn)頻率限制 針對(duì)單個(gè)站點(diǎn)的實(shí)現(xiàn)方法。小編覺(jué)的挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-12-12C# 9.0新特性——擴(kuò)展方法GetEnumerator支持foreach循環(huán)
這篇文章主要介紹了C# 9.0新特性——擴(kuò)展方法GetEnumerator支持foreach循環(huán)的相關(guān)資料,幫助大家更好的理解和學(xué)習(xí)c# 9.0,感興趣的朋友可以了解下2020-11-11C# 類(lèi)型轉(zhuǎn)換(隱式類(lèi)型,顯式類(lèi)型,自定義類(lèi)型)
本文詳細(xì)介紹了C#中的類(lèi)型轉(zhuǎn)換,包括隱式類(lèi)型轉(zhuǎn)換和顯式類(lèi)型轉(zhuǎn)換(強(qiáng)制類(lèi)型轉(zhuǎn)換),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-11-11C#驗(yàn)證控件validator的簡(jiǎn)單使用
這篇文章主要介紹了C#驗(yàn)證控件validator的簡(jiǎn)單使用方法和示例,十分的簡(jiǎn)單實(shí)用,有需要的小伙伴可以參考下。2015-06-06C#在復(fù)雜多線(xiàn)程環(huán)境下使用讀寫(xiě)鎖同步寫(xiě)入文件
這篇文章介紹了C#在復(fù)雜多線(xiàn)程環(huán)境下使用讀寫(xiě)鎖同步寫(xiě)入文件的方法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-04-04