.NET中的异步编程-EAP/APM使用方法及案例介绍
更新时间：2021年9月22日 10:17 点击：2182
从.NET 4.5开始，支持的三种异步编程模式：
•基于事件的异步编程设计模式 （EAP，Event-based Asynchronous Pattern）
•异步编程模型（APM，Asynchronous Programming Model）
•基于任务的编程模型（TAP，Task-based Asynchronous Pattern）
基于任务的异步模式 (TAP) 是基于 System.Threading.Tasks 命名空间的 Task 和 Task<TResult>，用于表示任意异步操作。 TAP 是新开发的建议异步设计模式，之后再讨论。
先总结一下旧有的2种模式：EAP、APM。
从以下几个方面，看这2种异步编程方式的异同：
•命名、参数、返回值
•典型应用
•捕获异常
•状态
•取消操作
•进度报告
EAP
命名、参数、返回值
EAP的编程模式的代码命名有以下特点：
•将有一个或多个名为 “[方法名称]Async” 的方法。这些方法可能会创建同步版本的镜像，这些同步版本会在当前线程上执行相同的操作。
•该类还可能有一个 “[方法名称]Completed” 事件，监听异步方法的结果。
•它可能会有一个 “[方法名称]AsyncCancel”（或只是 CancelAsync）方法，用于取消正在进行的异步操作。
参数和返回值都没有特殊规定，按照业务需求而定
典型应用
以请求一个Url为例
public class EAP_Typical
{
public static void AsyncRun()
{
Utility.Log("AsyncRun:start");
//测试网址
string url = http://sports.163.com/nba/;
using (WebClient webClient = new WebClient())
{
//获取完成情况
webClient.DownloadStringCompleted += new DownloadStringCompletedEventHandler(webClient_DownloadStringCompleted);
webClient.DownloadStringAsync(new Uri(url));
Utility.Log("AsyncRun:download_start");
}
}
static void webClient_DownloadStringCompleted(object sender, DownloadStringCompletedEventArgs e)
{
string log = "AsyncRun:download_completed";
//获取返回结果
log += "|result_size=" + Utility.GetStrLen(e.Result);
Utility.Log(log);
}
}
捕获异常
异常信息一般在Completed的事件参数中传递的。紧接上面的例子，如果需要获取返回的异常信息，则需要改写一下DownloadStringComleted的方法。
static void webClient_DownloadStringCompleted(object sender, DownloadStringCompletedEventArgs e)
{
string log = "AsyncRun:download_completed";
if (e.Error != null) //可见，在事件的参数传输异常信息
{
//出现异常，就记录异常
log += "|error=" + e.Error.Message;
}
else
{
//没有出现异常，则记录结果
log += "|result_size=" + Utility.GetStrLen(e.Result);
}
Utility.Log(log);
}
状态
EAP本身并没有维护状态，如果需要的话，应该设置不同的时间响应不同的状态改变；
假设刚才的DownloadStringAsync，需要增加多几个状态值，可以考虑增加多几个事件。
如
Event DownloadStringStarted（响应下载刚开始）
Event DownloadStringPending（响应下载阻塞中）
Event DownloadStringCancel（响应下载取消时）
等等。
取消操作
按命名规范，如果操作对应有“[方法名称]AsyncCancel”（或只是 CancelAsync）方法，则支持取消操作。
取消的状态捕获，还是以刚才的下载Url输出html为例，还是在DownloadStringCompleted 获取取消与否的状态。DownloadStringCompletedEventArgs. Cancelled
注意的是，如果用户执行了CancelAsync后，在DownloadStringCompletedEventArgs.Error就会获取到对应的异常，此时不要再取DownloadStringCompletedEventArgs.Result。
进度报告
EAP没有硬性规定说要支持进度报告，但可以很顺其自然地通过时间响应进度变化。
以当前例子，WebClient 就提供了DownloadProgressChanged 做进度变化的响应事件。
APM
命名、参数、返回值
APM的编程模式的代码命名有以下特点：
•使用 IAsyncResult 设计模式的异步操作是通过名为[Begin操作名称] 和 [End操作名称] 的两个方法来实现的，这两个方法分别开始和结束异步操作 操作名称。 例如，FileStream 类提供 BeginRead 和 EndRead 方法来从文件异步读取字节。 这两个方法实现了 Read 方法的异步版本。
•在调用 [Begin操作名称] 后，应用程序可以继续在调用线程上执行指令，同时异步操作在另一个线程上执行。 每次调用 [Begin操作名称] 时，应用程序还应调用 [End操作名称] 来获取操作的结果。
典型应用
以请求一个Url为例
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.IO;
namespace AsyncTest1.APM
{
public class APMTestRun1
{
public static void AsyncRun()
{
Utility.Log("APMAsyncRun:start");
//测试网址
string url = "http://sports.163.com/nba/";
HttpWebRequest webRequest = HttpWebRequest.Create(url) as HttpWebRequest;
webRequest.BeginGetResponse(Callback, webRequest);
Utility.Log("AsyncRun:download_start");
}
private static void Callback(IAsyncResult ar)
{
var source = ar.AsyncState as HttpWebRequest;
var response = source.EndGetResponse(ar);
using (var stream = response.GetResponseStream())
{
using (var reader = new StreamReader(stream))
{
string content = reader.ReadToEnd();
Utility.Log("AsyncRun:result_size=" + Utility.GetStrLen(content));
}
}
}
}
}
委托的异步调用也用的是APM模式，这个方式的强大之处，在于可以使任何方法编程异步调用。
/// <summary>
/// 一个耗时的方法
/// </summary>
private static void CaluateManyNumber() {
for (int i = 0; i < 10; i++)
{
Thread.Sleep(100);
Console.WriteLine("loop==>"+i.ToString());
}
}
/// <summary>
/// 委托，让耗时方法可以异步执行
/// </summary>
public static void AsyncDelegate() {
//委托简单的包装了一下方法
Action action = CaluateManyNumber;
action.BeginInvoke(DelegateCallback, null);
Console.WriteLine("action begin");
}
/// <summary>
/// 异步回调
/// </summary>
/// <param name="ar"></param>
private static void DelegateCallback(IAsyncResult ar) {
AsyncResult asyncResult = ar as AsyncResult;
var delegateSource = asyncResult.AsyncDelegate as Action;
delegateSource.EndInvoke(ar);
Console.WriteLine("action end");
}
捕获异常
异常信息要在[End操作名称]中获取。
private static void Callback(IAsyncResult ar)
{
var source = ar.AsyncState as HttpWebRequest;
WebResponse response = null;
try
{
response = source.EndGetResponse(ar);
}
catch (Exception ex) {
Utility.Log("error:" + ex.Message);
response = null;
}
if (response != null)
{
using (var stream = response.GetResponseStream())
{
using (var reader = new StreamReader(stream))
{
string content = reader.ReadToEnd();
Utility.Log("AsyncRun:result_size=" + Utility.GetStrLen(content));
}
}
}
}
状态和取消操作、进度报告
APM模式本身不支持状态多样化和取消操作、进度报告。
•基于事件的异步编程设计模式 （EAP，Event-based Asynchronous Pattern）
•异步编程模型（APM，Asynchronous Programming Model）
•基于任务的编程模型（TAP，Task-based Asynchronous Pattern）
基于任务的异步模式 (TAP) 是基于 System.Threading.Tasks 命名空间的 Task 和 Task<TResult>，用于表示任意异步操作。 TAP 是新开发的建议异步设计模式，之后再讨论。
先总结一下旧有的2种模式：EAP、APM。
从以下几个方面，看这2种异步编程方式的异同：
•命名、参数、返回值
•典型应用
•捕获异常
•状态
•取消操作
•进度报告
EAP
命名、参数、返回值
EAP的编程模式的代码命名有以下特点：
•将有一个或多个名为 “[方法名称]Async” 的方法。这些方法可能会创建同步版本的镜像，这些同步版本会在当前线程上执行相同的操作。
•该类还可能有一个 “[方法名称]Completed” 事件，监听异步方法的结果。
•它可能会有一个 “[方法名称]AsyncCancel”（或只是 CancelAsync）方法，用于取消正在进行的异步操作。
参数和返回值都没有特殊规定，按照业务需求而定
典型应用
以请求一个Url为例
复制代码 代码如下:
public class EAP_Typical
{
public static void AsyncRun()
{
Utility.Log("AsyncRun:start");
//测试网址
string url = http://sports.163.com/nba/;
using (WebClient webClient = new WebClient())
{
//获取完成情况
webClient.DownloadStringCompleted += new DownloadStringCompletedEventHandler(webClient_DownloadStringCompleted);
webClient.DownloadStringAsync(new Uri(url));
Utility.Log("AsyncRun:download_start");
}
}
static void webClient_DownloadStringCompleted(object sender, DownloadStringCompletedEventArgs e)
{
string log = "AsyncRun:download_completed";
//获取返回结果
log += "|result_size=" + Utility.GetStrLen(e.Result);
Utility.Log(log);
}
}
捕获异常
异常信息一般在Completed的事件参数中传递的。紧接上面的例子，如果需要获取返回的异常信息，则需要改写一下DownloadStringComleted的方法。
复制代码 代码如下:
static void webClient_DownloadStringCompleted(object sender, DownloadStringCompletedEventArgs e)
{
string log = "AsyncRun:download_completed";
if (e.Error != null) //可见，在事件的参数传输异常信息
{
//出现异常，就记录异常
log += "|error=" + e.Error.Message;
}
else
{
//没有出现异常，则记录结果
log += "|result_size=" + Utility.GetStrLen(e.Result);
}
Utility.Log(log);
}
状态
EAP本身并没有维护状态，如果需要的话，应该设置不同的时间响应不同的状态改变；
假设刚才的DownloadStringAsync，需要增加多几个状态值，可以考虑增加多几个事件。
如
Event DownloadStringStarted（响应下载刚开始）
Event DownloadStringPending（响应下载阻塞中）
Event DownloadStringCancel（响应下载取消时）
等等。
取消操作
按命名规范，如果操作对应有“[方法名称]AsyncCancel”（或只是 CancelAsync）方法，则支持取消操作。
取消的状态捕获，还是以刚才的下载Url输出html为例，还是在DownloadStringCompleted 获取取消与否的状态。DownloadStringCompletedEventArgs. Cancelled
注意的是，如果用户执行了CancelAsync后，在DownloadStringCompletedEventArgs.Error就会获取到对应的异常，此时不要再取DownloadStringCompletedEventArgs.Result。
进度报告
EAP没有硬性规定说要支持进度报告，但可以很顺其自然地通过时间响应进度变化。
以当前例子，WebClient 就提供了DownloadProgressChanged 做进度变化的响应事件。
APM
命名、参数、返回值
APM的编程模式的代码命名有以下特点：
•使用 IAsyncResult 设计模式的异步操作是通过名为[Begin操作名称] 和 [End操作名称] 的两个方法来实现的，这两个方法分别开始和结束异步操作 操作名称。 例如，FileStream 类提供 BeginRead 和 EndRead 方法来从文件异步读取字节。 这两个方法实现了 Read 方法的异步版本。
•在调用 [Begin操作名称] 后，应用程序可以继续在调用线程上执行指令，同时异步操作在另一个线程上执行。 每次调用 [Begin操作名称] 时，应用程序还应调用 [End操作名称] 来获取操作的结果。
典型应用
以请求一个Url为例
复制代码 代码如下:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.IO;
namespace AsyncTest1.APM
{
public class APMTestRun1
{
public static void AsyncRun()
{
Utility.Log("APMAsyncRun:start");
//测试网址
string url = "http://sports.163.com/nba/";
HttpWebRequest webRequest = HttpWebRequest.Create(url) as HttpWebRequest;
webRequest.BeginGetResponse(Callback, webRequest);
Utility.Log("AsyncRun:download_start");
}
private static void Callback(IAsyncResult ar)
{
var source = ar.AsyncState as HttpWebRequest;
var response = source.EndGetResponse(ar);
using (var stream = response.GetResponseStream())
{
using (var reader = new StreamReader(stream))
{
string content = reader.ReadToEnd();
Utility.Log("AsyncRun:result_size=" + Utility.GetStrLen(content));
}
}
}
}
}
委托的异步调用也用的是APM模式，这个方式的强大之处，在于可以使任何方法编程异步调用。
复制代码 代码如下:
/// <summary>
/// 一个耗时的方法
/// </summary>
private static void CaluateManyNumber() {
for (int i = 0; i < 10; i++)
{
Thread.Sleep(100);
Console.WriteLine("loop==>"+i.ToString());
}
}
/// <summary>
/// 委托，让耗时方法可以异步执行
/// </summary>
public static void AsyncDelegate() {
//委托简单的包装了一下方法
Action action = CaluateManyNumber;
action.BeginInvoke(DelegateCallback, null);
Console.WriteLine("action begin");
}
/// <summary>
/// 异步回调
/// </summary>
/// <param name="ar"></param>
private static void DelegateCallback(IAsyncResult ar) {
AsyncResult asyncResult = ar as AsyncResult;
var delegateSource = asyncResult.AsyncDelegate as Action;
delegateSource.EndInvoke(ar);
Console.WriteLine("action end");
}
捕获异常
异常信息要在[End操作名称]中获取。
复制代码 代码如下:
private static void Callback(IAsyncResult ar)
{
var source = ar.AsyncState as HttpWebRequest;
WebResponse response = null;
try
{
response = source.EndGetResponse(ar);
}
catch (Exception ex) {
Utility.Log("error:" + ex.Message);
response = null;
}
if (response != null)
{
using (var stream = response.GetResponseStream())
{
using (var reader = new StreamReader(stream))
{
string content = reader.ReadToEnd();
Utility.Log("AsyncRun:result_size=" + Utility.GetStrLen(content));
}
}
}
}
状态和取消操作、进度报告
APM模式本身不支持状态多样化和取消操作、进度报告。
相关文章
- 1.什么是异步编程？ 异步编程是指由于异步I/O等因素，无法同步获得执行结果时， 在回调函数中进行下一步操作的代码编写风格,常见的如setTimeout函数、ajax请求等等。示例： for (var i = 1; i <= 3; i++) {setTimeout(functi...2015-10-23
- 本篇文章主要介绍了C#异步编程，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧。...2020-06-25
- 这篇文章主要为大家介绍了javascript异步编程，从浅入深的学习javascript异步编程，对javascript异步编程感兴趣的小伙伴们可以参考一下...2016-01-29
- 再谈JavaScript异步编程，简单描述了几种JavaScript异步编程模式，感兴趣的小伙伴们可以参考一下...2016-01-29
- 重点是怎么建立一种高效的UDP机制来实时接收服务器发送过来的数据包.本文将介绍.Net UDP异步编程如何实现解决方案,有需求的朋友可以参考下...2021-09-22
- 从.NET 4.5开始，支持的三种异步编程模式:基于事件的异步编程设计模式;异步编程模型;基于任务的编程模型接下来先总结一下旧有的2种模式：EAP、APM，感兴趣的朋友可以了解下...2021-09-22
- 这篇文章我们来讨论下关于C#异步编程几个不成文的建议，希望对你写出高性能的异步编程代码有所帮助...2020-06-25
- 这篇文章主要为大家详细介绍了javascript异步编程，其实作为一种编程语言Javascript的异步编程是一个非常值得讨论的有趣话题。，感兴趣的小伙伴们可以参考一下...2016-02-23
- 这篇文章主要介绍了数据结构之Treap详解,本文讲解了Treap的基本知识、Treap的基本操作、Treap的高级操作技巧等,需要的朋友可以参考下...2020-04-25
- 这篇文章主要介绍了c# 基于任务的异步编程模式的异常处理方法，帮助大家更好的理解和学习c#...2020-12-08
- 这篇文章主要介绍了c语言stack(栈)和heap(堆)的使用详解,需要的朋友可以参考下...2020-04-25
- 这篇文章主要为大家详细介绍了C#实现异步编程的方法，什么是异步，如何实现异步编程，感兴趣的小伙伴们可以参考一下...2020-06-25
- 本文主要介绍异步编程中Task、Async和Await的基础知识。具有很好的参考价值，下面跟着小编一起来看下吧...2020-06-25
- .net4.5使用async和await异步编程实例,大家参考使用吧...2020-06-25
- 本篇文章主要介绍了.NET异步编程总结----四种实现模式，详细的介绍了每种方法的实现和实例，具有一定的参考价值，有兴趣的可以了解一下。...2021-09-22
- 本篇文章是对C#异步编程进行了详细的分析介绍，需要的朋友参考下...2020-06-25
- 这篇文章主要介绍了c# 基于任务的异步编程模式（TAP）的相关资料，帮助大家更好的理解和学习c# 异步编程的相关知识，感兴趣的朋友可以了解下...2020-12-08