欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

.NET2.0版本中基于事件的異步編程模式(EAP)

 更新時(shí)間:2022年06月09日 09:38:15   作者:springsnow  
這篇文章介紹了.NET2.0版本中基于事件的異步編程模式(EAP),文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

一、引言

APM為我們實(shí)現(xiàn)異步編程提供了一定的支持,同時(shí)它也存在著一些明顯的問(wèn)題——不支持對(duì)異步操作的取消和沒(méi)有提供對(duì)進(jìn)度報(bào)告的功能,對(duì)于有界面的應(yīng)用程序來(lái)說(shuō),進(jìn)度報(bào)告和取消操作的支持也是必不可少的。

微軟在.NET 2.0的時(shí)候就為我們提供了一個(gè)新的異步編程模型,也就是基于事件的異步編程模型——EAP(Event-based Asynchronous Pattern )。

二、介紹

實(shí)現(xiàn)了基于事件的異步模式的類(lèi)將具有一個(gè)或者多個(gè)以Async為后綴的方法和對(duì)應(yīng)的Completed事件,并且這些類(lèi)都支持異步方法的取消、進(jìn)度報(bào)告和報(bào)告結(jié)果。

當(dāng)我們調(diào)用實(shí)現(xiàn)基于事件的異步模式的類(lèi)的 XxxAsync方法時(shí),即代表開(kāi)始了一個(gè)異步操作,該方法調(diào)用完之后會(huì)使一個(gè)線程池線程去執(zhí)行耗時(shí)的操作,所以當(dāng)UI線程調(diào)用該方法時(shí),當(dāng)然也就不會(huì)堵塞UI線程了。

并且基于事件的異步模式是建立了APM的基礎(chǔ)之上的,而APM又是建立了在委托之上的。

public static void GetInfomation()
{
    WebClient client = new WebClient();
    Uri uri = new Uri("http://www.baidu.com");
    client.DownloadFileCompleted += new AsyncCompletedEventHandler(client_DownloadFileCompleted);
    client.DownloadProgressChanged += new DownloadProgressChangedEventHandler(client_DownloadProgressCallback);
    client.DownloadFileAsync(uri, "serverdata.txt");
}

static void client_DownloadProgressCallback(object sender, DownloadProgressChangedEventArgs e)
{
    // Displays the operation identifier, and the transfer progress.
    Console.WriteLine("{0}    downloaded {1} of {2} bytes. {3} % complete...", (string)e.UserState, e.BytesReceived, e.TotalBytesToReceive, e.ProgressPercentage);
}

static void client_DownloadFileCompleted(object sender, AsyncCompletedEventArgs e)
{
    string RetStr = (e.Error == null ? "成功" : e.Error.Message);
    Console.Write(RetStr);  //顯示操作結(jié)果信息
}

三、使用BackgroundWorker組件進(jìn)行異步編程

BackgroundWorker類(lèi)就是用EAP實(shí)現(xiàn)的。

BackgroundWorker類(lèi)

公共屬性

  • CancellationPending:獲取一個(gè)值,指示應(yīng)用程序是否已請(qǐng)求取消后臺(tái)操作
  • IsBusy:獲取一個(gè)值,指示 BackgroundWorker 是否正在運(yùn)行異步操作。
  • WorkReportsProgress:獲取或設(shè)置一個(gè)值,該值指示 BackgroundWorker 能否報(bào)告進(jìn)度更新。
  • WorkerSupportsCancellation:獲取或設(shè)置一個(gè)值,該值指示 BackgroundWorker 是否支持異步取消。

公共方法

  • CancelAsync:請(qǐng)求取消掛起的后臺(tái)操作。
  • ReportProgress:引發(fā) ProgressChanged 事件
  • RunWorkerAsync:開(kāi)始執(zhí)行后臺(tái)操作。

公共事件

  • DoWork:調(diào)用 RunWorkerAsync 時(shí)發(fā)生
  • ProgressChanged:調(diào)用ReportProgress時(shí)發(fā)生
  • RunWorkerCompleted:當(dāng)后臺(tái)操作已完成、被取消或引發(fā)異常時(shí)發(fā)生。

下面向大家演示一個(gè)使用BackgroundWorker組件實(shí)現(xiàn)異步下載文件的一個(gè)小程序,該程序支持異步下載(指的就是用線程池線程要執(zhí)行下載操作),斷點(diǎn)續(xù)傳、下載取消和進(jìn)度報(bào)告的功能。

事件綁定:

代碼:

public int DownloadSize = 0;
public string downloadPath = null;
private RequestState requestState = null;
private long totalSize = 0;

public FileDownloader()
{
    InitializeComponent();

    string url = "http://download.microsoft.com/download/7/0/3/703455ee-a747-4cc8-bd3e-98a615c3aedb/dotNetFx35setup.exe";
    //string url = "http://download.microsoft.com/download/9/5/A/95A9616B-7A37-4AF6-BC36-D6EA96C8DAAE/dotNetFx40_Full_x86_x64.exe";
    txbUrl.Text = url;
    this.btnPause.Enabled = false;
    //this.status = DownloadStatus.Initialized;
    // Get download Path

    GetTotalSize();
    downloadPath = Environment.GetFolderPath(Environment.SpecialFolder.Desktop) + "\\" + Path.GetFileName(this.txbUrl.Text.Trim());
    if (File.Exists(downloadPath))
    {
        FileInfo fileInfo = new FileInfo(downloadPath);
        DownloadSize = (int)fileInfo.Length;
        progressBar1.Value = (int)((float)DownloadSize / (float)totalSize * 100);
    }

    // 啟用支持 ReportProgress and Cancellation
    bgWorkerFileDownload.WorkerReportsProgress = true;
    bgWorkerFileDownload.WorkerSupportsCancellation = true;
}

//開(kāi)始或恢復(fù)下載
private void btnDownload_Click(object sender, EventArgs e)
{
    if (bgWorkerFileDownload.IsBusy != true)
    {
        // 啟動(dòng)異步操作觸發(fā)DoWork事件
        bgWorkerFileDownload.RunWorkerAsync();

        // 創(chuàng)建RequestState 實(shí)例
        requestState = new RequestState(downloadPath);
        requestState.filestream.Seek(DownloadSize, SeekOrigin.Begin);
        this.btnDownload.Enabled = false;
        this.btnPause.Enabled = true;
    }
    else
    {
        MessageBox.Show("正在執(zhí)行操作,請(qǐng)稍后");
    }
}

// 暫停下載
private void btnPause_Click(object sender, EventArgs e)
{
    if (bgWorkerFileDownload.IsBusy && bgWorkerFileDownload.WorkerSupportsCancellation == true)
    {
        // 終止異步操作觸發(fā)RunWorkerCompleted事件
        bgWorkerFileDownload.CancelAsync();
    }
}

#region BackGroundWorker Event

// 1、當(dāng)調(diào)用RunWorkerAsync方法時(shí)觸發(fā)
private void bgWorkerFileDownload_DoWork(object sender, DoWorkEventArgs e)
{
    //獲取事件源
    BackgroundWorker bgworker = sender as BackgroundWorker;
    try
    {
        // 執(zhí)行下載操作
        // 初始化一個(gè)HttpWebRequest對(duì)象
        HttpWebRequest myHttpWebRequest = (HttpWebRequest)WebRequest.Create(txbUrl.Text.Trim());

        // 如果文件已下載了一部分,
        // 服務(wù)器應(yīng)該從DownloadSize開(kāi)始發(fā)送數(shù)據(jù)到HTTP實(shí)體中數(shù)據(jù)的末尾。
        if (DownloadSize != 0)
        {
            myHttpWebRequest.AddRange(DownloadSize);
        }

        // 指定一個(gè) HttpWebRequest 實(shí)例到request字段.
        requestState.request = myHttpWebRequest;
        requestState.response = (HttpWebResponse)myHttpWebRequest.GetResponse();
        requestState.streamResponse = requestState.response.GetResponseStream();
        int readSize = 0;
        while (true)
        {
            if (bgworker.CancellationPending == true)
            {
                e.Cancel = true;
                break;
            }

            readSize = requestState.streamResponse.Read(requestState.BufferRead, 0, requestState.BufferRead.Length);
            if (readSize > 0)
            {
                DownloadSize += readSize;
                int percentComplete = (int)((float)DownloadSize / (float)totalSize * 100);
                requestState.filestream.Write(requestState.BufferRead, 0, readSize);

                // 報(bào)告進(jìn)度,引發(fā)ProgressChanged事件的發(fā)生
                bgworker.ReportProgress(percentComplete);
            }
            else
            {
                break;
            }
        }
    }
    catch
    {
        throw;
    }
}

//  2、當(dāng)調(diào)用ReportProgress方法時(shí)觸發(fā)
private void bgWorkerFileDownload_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
    this.progressBar1.Value = e.ProgressPercentage;
}

// 3、當(dāng)后臺(tái)操作完成,取消或者有錯(cuò)誤時(shí)觸發(fā)
private void bgWorkerFileDownload_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
    if (e.Error != null)
    {
        MessageBox.Show(e.Error.Message);
        requestState.response.Close();
    }
    else if (e.Cancelled)
    {
        MessageBox.Show(String.Format("下載暫停,下載的文件地址為:{0}\n 已經(jīng)下載的字節(jié)數(shù)為: {1}字節(jié)", downloadPath, DownloadSize));
        requestState.response.Close();
        requestState.filestream.Close();

        this.btnDownload.Enabled = true;
        this.btnPause.Enabled = false;
    }
    else
    {
        MessageBox.Show(String.Format("下載已完成,下載的文件地址為:{0},文件的總字節(jié)數(shù)為: {1}字節(jié)", downloadPath, totalSize));

        this.btnDownload.Enabled = false;
        this.btnPause.Enabled = false;
        requestState.response.Close();
        requestState.filestream.Close();
    }
}

#endregion BackGroundWorker Event

// 獲取文件總大小
private void GetTotalSize()
{
    HttpWebRequest myHttpWebRequest = (HttpWebRequest)WebRequest.Create(txbUrl.Text.Trim());
    HttpWebResponse response = (HttpWebResponse)myHttpWebRequest.GetResponse();
    totalSize = response.ContentLength;
    response.Close();
}
}

// 此類(lèi)存儲(chǔ)請(qǐng)求的狀態(tài)
public class RequestState
{
 public int BufferSize = 2048;

 public byte[] BufferRead;
 public HttpWebRequest request;
 public HttpWebResponse response;
 public Stream streamResponse;

 public FileStream filestream;

 public RequestState(string downloadPath)
 {
    BufferRead = new byte[BufferSize];
    request = null;
    streamResponse = null;
    filestream = new FileStream(downloadPath, FileMode.OpenOrCreate);
 }

運(yùn)行程序點(diǎn)擊"下載"按鈕然后再點(diǎn)擊"暫停"后的結(jié)果:

當(dāng)暫停下載后,我們還可以點(diǎn) ”下載“按鈕繼續(xù)下載該文件,此時(shí)并不會(huì)從開(kāi)開(kāi)始下載,而會(huì)接著上次的下載繼續(xù)下載。

這個(gè)實(shí)現(xiàn)主要是通過(guò)AddRange方法來(lái)實(shí)現(xiàn)的,該方法是指出向服務(wù)器請(qǐng)求文件的大小,上面代碼中通過(guò)傳入DownloadSize來(lái)告訴服務(wù)器,這次我需要的內(nèi)容不是從開(kāi)頭開(kāi)始的,而是從已經(jīng)下載的文件字節(jié)數(shù)開(kāi)始到該文件的總的字節(jié)結(jié)尾,這樣就就實(shí)現(xiàn)了斷點(diǎn)續(xù)傳的功能了,使戶(hù)暫停下載不至于之前下載的都白費(fèi)了。程序的運(yùn)行結(jié)果為:

到此這篇關(guān)于.NET2.0異步編程模式(EAP)的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • ASP.NET 5已終結(jié),迎來(lái)ASP.NET Core 1.0和.NET Core 1.0

    ASP.NET 5已終結(jié),迎來(lái)ASP.NET Core 1.0和.NET Core 1.0

    命名是非常困難的事情,微軟這次為了和ASP.NET4.6做區(qū)分,采用了全新的命名方式ASP.NET Core 1.0,它是一個(gè)全新的框架。
    2016-03-03
  • 使用Docker部署ASP.NET?Core程序

    使用Docker部署ASP.NET?Core程序

    這篇文章介紹了使用Docker部署ASP.NET?Core程序的方法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-03-03
  • asp.net中MVC的處理流程詳解

    asp.net中MVC的處理流程詳解

    本文詳細(xì)講解了asp.net MVC的處理流程,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-07-07
  • Blazor組件事件處理功能

    Blazor組件事件處理功能

    這篇文章介紹了Blazor組件的事件處理功能,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-01-01
  • Blazor數(shù)據(jù)綁定用法

    Blazor數(shù)據(jù)綁定用法

    這篇文章介紹了Blazor數(shù)據(jù)綁定的用法,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-01-01
  • C#控件命名規(guī)范

    C#控件命名規(guī)范

    C#控件命名規(guī)范,遵守規(guī)范有利于代碼的可維護(hù)性。
    2010-09-09
  • Asp.net中Request.Url的各個(gè)屬性對(duì)應(yīng)的意義介紹

    Asp.net中Request.Url的各個(gè)屬性對(duì)應(yīng)的意義介紹

    網(wǎng)絡(luò)上關(guān)于Request.Url的說(shuō)明已經(jīng)很多也很豐富了,但是自己還是實(shí)踐了一下,看看最終的結(jié)果與網(wǎng)絡(luò)上的是否一致
    2012-05-05
  • .Net報(bào)表開(kāi)發(fā)控件XtraReport介紹

    .Net報(bào)表開(kāi)發(fā)控件XtraReport介紹

    這篇文章介紹了.Net報(bào)表開(kāi)發(fā)控件XtraReport,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-06-06
  • ASP.NET Core基礎(chǔ)之請(qǐng)求處理管道

    ASP.NET Core基礎(chǔ)之請(qǐng)求處理管道

    這篇文章介紹了ASP.NET Core的請(qǐng)求處理管道,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2022-02-02
  • ASP.NET Core讀取配置文件

    ASP.NET Core讀取配置文件

    這篇文章介紹了ASP.NET Core讀取配置文件的方法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-02-02

最新評(píng)論