ASP.NET2.0中数据源控件之异步数据访问

在第 1 部分和第 2 部分中，建立了 WeatherDataSource 控件，该控件针对 weather.com（英文）所提供的 XML API 来运行，使用 WebRequest 和 WebResponse 来通过 HTTP 访问数据。迄今为止，均是同步访问该服务。因此，页面处理被阻止，直到 Web 请求完成为止。此方法对于测试页面是有效的，在小站点上也可能有效，但是在接收大量通信流量的站点上则会惨败；例如门户页面，天气模块在其中可能非常常见。

　　引言

　　在线程池中有固定不变的大量线程可用于服务请求，遗憾的是，该解决方案并非仅仅提高限制（还会增加线程占用资源以及 CPU 占用资源）。因此，当一个页面被阻止而等候另一个服务器时，它还在占用线程，因而可能会导致其他传入的请求在队列中等候更长的时间。这将导致对站点的访问变慢，并降低 CPU 的利用率。在 Visual Studio 2005 中，我们引入了异步页面，这使得控件能够定义它们希望异步完成的任务，即，无需阻止用来处理请求的线程。在此将不介绍异步页面本身的详细信息，Dmitry（英文）和 Fritz Onion（英文）中以前已经有所介绍。此处要介绍的是如何在数据源控件中利用此功能，使用加载项框架来实现异步数据源。

　　背景

　　在第 1 部分中，间接提到了 DataSourceView 类的有些古怪的设计：

public abstract class DataSourceView "90%" align=center bgColor=#e3e3e3 border=1>public abstract class AsyncDataSourceControl : DataSourceControl,
IAsyncDataSource "90%" align=center bgColor=#e3e3e3 border=1>public class AsyncWeatherDataSource : AsyncDataSourceControl {

//与 WeatherDataSource 相同
}

private sealed class AsyncWeatherDataSourceView : AsyncDataSourceView {
private AsyncWeatherDataSource _owner;
private WeatherService _weatherService;

public AsyncWeatherDataSourceView(AsyncWeatherDataSource owner,
string viewName)
: base(owner, viewName) {
_owner = owner;
}

protected override IAsyncResult BeginExecuteSelect(DataSourceSelectArguments arguments,
AsyncCallback asyncCallback,
object asyncState) {
arguments.RaiseUnsupportedCapabilitiesError(this);

string zipCode = _owner.GetSelectedZipCode();
if (zipCode.Length == 0) {
return new SynchronousAsyncSelectResult(/* selectResult */
null,
asyncCallback, asyncState);
}

_weatherService = new WeatherService(zipCode);
return _weatherService.BeginGetWeather(asyncCallback, asyncState);
}

protected override IEnumerable EndExecuteSelect(IAsyncResult asyncResult) {
SynchronousAsyncSelectResult syncResult =
asyncResult as SynchronousAsyncSelectResult;
if (syncResult != null) {
return syncResult.SelectResult;
}
else {
Weather weatherObject =
_weatherService.EndGetWeather(asyncResult);
_weatherService = null;

if (weatherObject != null) {
return new Weather[] { weatherObject };
}
}

return null;
}
}
　　要注意的关键问题是，在使用该框架时，只需要实现 BeginExecuteSelect 和 EndExecuteSelect。在它们的实现过程中，通常要调用由该框架中的各种对象（例如 WebRequest 或 IO 流）所揭示的 BeginXXX 和 EndXXX 方法（在 Visual Studio 2005 中，还需要调用 SqlDataCommand），并返回 IAsyncResult。在此示例中，有一个封装了基础 WebRequest 对象的 WeatherService 帮助程序类。

　　对于那些实际缺少异步模式的框架，您在此会看到有效的异步模式；以及您要实现的 BeginExecuteSelect 和 EndExecuteSelect，和您要调用以返回 IAsyncResult 实例的 Begin 和 End 方法。

　　最有趣的可能是 SynchronousAsyncSelectResult 类（在某种程度上而言是一种矛盾）。此类是框架附带的。它基本上是一个 IAsyncResult 实现，可使数据立即可用，并从其 IAsyncResult.CompletedSynchronously 属性报告 true。到目前为止，这仅适用于未选择邮政编码的情况，并且需要返回 null（启动异步任务而只返回 null 是没有意义的），但正如您会在下文中看到的，这在其他方案中也是有用的。

　　页面基础结构隐藏了在 Microsoft ASP.NET 上下文中执行异步工作的大部分详细信息。希望在此提供的框架使您执行最少的操作就能编写使用此基础结构的数据源。不过，就其本质而言，实现异步行为是复杂的。有时候，第一次阅读本文时会有一些疑问，而第二次阅读时可能就明白了。您可以使用下面“我的评论”表单来发送问题或进行讨论。