WCF技术剖析之十一:异步操作在WCF中的应用(上篇)

From: http://www.cnblogs.com/artech/archive/2009/07/08/1519423.html


按照操作执行所需的资源类型,我们可以将操作分为CPU绑定型(CPU Bound)操作和I/O绑定型(I/O Bound)操作。对于前者,操作的执行主要利用CPU进行密集的计算,而对于后者,大部分的操作处理时间花在I/O操作处理,比如访问数据库、文件系统、网络资源等。对于I/O绑定型操作,我们可以充分利用多线程的机制,让多个操作在自己的线程并发执行,从而提高系统性能和响应能力。服务调用就是典型的I/O绑定型操作,所以多线程在服务调用中具有广泛的应用。在本篇文章中,我们专门来讨论多线程或者是异步操作在WCF中的具体应用。

如果按照异步操作发生的位置,我个人将WCF应用的异步操作分为下面3种变体。

  • 异步信道调用:客户端通过绑定创建的信道向服务端发送消息,从而实现了对服务的调用,不管消息通过信道向服务端发送的方式是同步的(采用请求-回复MEP进行消息交换)还是异步的(采用单向MEP进行消息交换),客户端程序都可以通过代理对象异步地调用信道,从而实现异步服务调用;
  • 单向(One-way)消息交换:客户端的信道通过单向的消息交换模式向服务端发送消息,消息一旦抵达传输层马上返回,从而达到异步服务调用的效果;
  • 异步服务实现:服务端在具体实现服务操作的时候,采用异步调用的方式。

图1清晰地揭示了以上3种异步场景在整个服务调用中所发生的时机。对于这3种典型的异步操作,它们之间是相互独立的。对于单向消息交换,由于在上面一节中已经进行过详细的介绍,在本节中主要介绍其余两种异步操作的具体使用。本篇文章我们着重探讨第一种形式(异步信道调用)的异步调用,关于异步服务的实现放在下篇中。

clip_image002

图1 WCF多线程应用的三种典型场景

为了方便客户端进行异步的服务调用,最简便的方式就通过SvcUtil.exe这个代码生成工具帮助我们生成机遇异步调用的服务代理类。由于SvcUtil.exe同时也为VS提供了添加服务引用的实现,异步服务代理也可以通过添加服务引用的方式创建。在具体通过服务代理进行异步服务调用的时候,可以采用不同的调用形式,不仅可以采用参数典型的BeginXxx和EndXxx的形式,也可以采用回调(Callback)的形式,还可以采用事件注册的形式。

一、异步服务代理的创建

对于任何一个服务操作,不管它是否采用了异步的实现方式,也不管是否采用单向的消息交换模式,我们均可以通过添加服务引用或者直接使用SvcUtil.exe的方式创建异步服务代理,对服务进行异步调用。

如果通过添加服务引用的方式来创建异步服务代理,只需要在添加服务引用对话框中点击“高级(Advanced)”按钮,便会弹出如下一个“服务引用设置(Service Reference Settings)”对话框,勾选“生成异步操作(Generate asynchronous operations)”复选框即可,如图2所示。

clip_image004

图2 添加服务引用时生成异步操作的设置

通过这种方式生成的代理类与没有选择“生成异步操作”选项一样,都是生成一个继承自ClientBase<TChannel>的类,所不同的是,该类中会多出一些与异步服务调用相关的成员。我们同样以我们的CalculatorService为例(服务契约的定义如下)。

   1: [ServiceContract(Namespace="urn:artech.com")]
   2: public interface ICalculator
   3: {
   4:     [OperationContract]
   5:     double Add(double x, double y);
   6: }

通过这种方式生成的代理类CalculateClient会多出下面列出的事件和方法成员。

   1: public partial class CalculateClient : ClientBase< ICalculator>, ICalculator
   2: {
   3:     //其他成员
   4:     public event System.EventHandler<AddCompleteEventArgs> AddComplete;
   5:     public IAsyncResult BeginAdd(double x, double y, AsyncCallback callback, object asyncState)
   6:     {
   7:         //省略实现
   8:     }
   9:     
  10:     public double EndAdd(System.IAsyncResult result)
  11:     {
  12:         //省略实现
  13:     }
  14:     
  15:     public void AddAsync(double x, double y)
  16:     {
  17:         //省略实现
  18:     }
  19:  
  20:     public void AddAsync(double x, double y, object userState)
  21:     {
  22:         //省略实现
  23:     }
  24: }

事件AddComplete将在Add操作执行之后触发,你可以注册该事件,在运算结束之后做一些特殊的工作,比如运算结果的显示。该事件包含一个特殊的EventArgs:AddCompleteEventArgs。该事件参数类型同样是通过添加服务引用自动创建的。AddCompleteEventArgs继承自System.ComponentModel.AsyncCompleteEventArgs。在事件处理器中可以通过该参数得到异步方法执行的结果(Result属性)和异步操作执行过程中抛出的异常(Error属性),以及得到在执行异步操作显式指定的信息(UserState)。AddCompleteEventArgs和AsyncCompleteEventArgs的定义如下。

   1: public partial class AddCompleteEventArgs : AsyncCompleteEventArgs
   2: {
   3:  
   4:     public AddCompleteEventArgs(object[] results,Exception exception, bool cancelled, object userState) :
   5:         base(exception, cancelled, userState)
   6:     {
   7:         //省略实现
   8:     }
   9:  
  10:     public double Result
  11:     {
  12:         get
  13:         {
  14:            //省略实现
  15:         }
  16:     }
  17: }

 

   1: public class AsyncCompleteEventArgs : EventArgs
   2: {
   3:     public bool Cancelled { get; }
   4:     public Exception Error { get; }
   5:     public object UserState { get; }
   6: }

二、通过BeginXxx/EndXxx进行异步服务调用

接下来我将介绍3种不同的执行异步服务调用的方式,为了简单起见,我们以上面提到的CalculatorService为例演示通过异步操作得到运算结果,并将结果输出。首先采用传统的异步编程模式BeginXxx/EndXxx,如下面的代码所示,在调用BeginAdd方法后,可以做一些额外的处理工作,这些工作将会和Add服务操作的调用并发地运行,最终的运算结果通过EndAdd方法得到。

   1: CalculateClient proxy = new CalculateClient();
   2: IAsyncResult asynResult = proxy.BeginAdd(1, 2, null, null);
   3: //其他操作
   4: double result = proxy.EndAdd(asynResult);
   5: proxy.Close();
   6: Console.WriteLine("x + y = {2} when x = {0} and y = {1}", 1, 2, result);

三、通过回调的方式进行异步服务调用

通过上面的方式进行异步调用有一个不好的地方,就是当EndAdd方法被执行的时候,如果异步执行的方法Add没有执行结束的话,该方法将会阻塞当前线程并等待异步方法的结束,往往不能起到地多线程并发执行应有的作用。我们真正希望的是在异步执行结束后自动回调设定的操作,这样就可以采用回调的方式来实现这样的机制了。

在下面的代码中,我们通过一个匿名方法的形式定义回调操作,由于在回调操用中输出运算结果时需要使用到参与运算的操作数,我们通过BeginAdd方法的最后一个object类型参数实现向回调操作传递数据,在回调操作中通过IAsyncResult对象的AsyncState获得。

   1: CalculateClient proxy = new CalculateClient();
   2: proxy.BeginAdd(1, 2,
   3:     delegate(IAsyncResult asyncResult)
   4:     {
   5:         double[] operands = asyncResult.AsyncState as double[];
   6:         double result = proxy.EndAdd(asyncResult);
   7:         proxy.Close();
   8:         Console.WriteLine("x + y = {2} when x = {0} and y = {1}", operands[0], operands[1], result);
   9:     }, new double[]{1,2});

四、通过事件注册的方式进行异步服务调用

实际上,事件注册和通过回调从表现上看比较类似,当操作结束之后,对于前者通过触发事件的方式执行相应的操作,而对于后者直接执行指定的回调操作。如果采用事件注册的方式,上面的代码就可以改写成下面的形式。通过AddAsync开始异步操作,如果需要向AddComplete事件传递数据,可以使用该方法的第3个参数userState(该参数和BeginAdd的第4个参数asyncState具有相似的作用),设定的值可以通过AddCompleteEventArgs的UserState属性获得,而操作执行的结果则通过AddCompleteEventArgs的Result属性获得。

   1: CalculateClient proxy = new CalculateClient();
   2: proxy.AddComplete += delegate(object sender, AddCompleteEventArgs args)
   3: {
   4:     double[] operands = args.UserState as double[];
   5:     double result = args.Result;
   6:     proxy.Close();
   7:     Console.WriteLine("x + y = {2} when x = {0} and y = {1}", operands[0], operands[1], result);
   8: };
   9: proxy.AddAsync(1, 2,new double[]{1,2}); 
作者: Artech

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/402973.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

react自适应布局

在 React 中实现自适应布局可以通过使用 CSS 的弹性布局&#xff08;Flexbox&#xff09;或者栅格系统来实现。下面是使用 Flexbox 实现简单的自适应布局的示例&#xff1a; jsx import React from react; import ./App.css; const App () > { return ( <div cl…

vue2使用vant组件库;使用rem后vant组件样式变小了。

vue2使用vant组件库 文章目录vue2使用vant组件库一、vant是什么&#xff1f;二、使用步骤1.引入vant2库2.引入 自动按需引入组件3.在main.js中按需引入组件&#xff08;推荐&#xff09;4.或者只是在某个index.vue内使用&#xff08;推荐&#xff09;5.在main.js中导入所以组件…

EditPlus自定义模板

直接用图表达了,不详之处可以留言. 1.查看帮助中的关于,确定文本编辑器的版本是否一致 2.如图 3.如图 4.这个test.html 需要事先编辑并拷贝到EditPlus的安装目录 5.新建空白html 时,效果如下: 6.方便大家,代码贴上来. html> <head> <title>网页标题…

《大道至简》第一章

Begin //开始叙述 if 你不知道编程是什么 { 简而化之&#xff0c;编程的精义精华在于三种算法&#xff1a;顺序、选择、循环&#xff0c;在论述的愚公移山的故事中&#xff0c;首先&#xff0c;“惩山北之塞&#xff0c;出入之迂”是原始需求的产生&#xff1b;然后“聚室而谋曰…

利用反射获得类的public static/const成员的值

首先&#xff0c;我们定义一个类&#xff1a; class CDynamic{ #if truepublic const string TableName "p_battlerecord"; // OK//public static string TableName "p_battlerecord"; // OK #elsepublic static string TableName // 用属性不行{ge…

vue项目部署测试和生产环境地址

场景&#xff1a;直接本地dev开发项目代码&#xff0c;然后打包提交&#xff0c;将打包后的index.html和static等静态文件&#xff0c;复制一份到本地桌面。 git切换到test分支下&#xff0c;将刚才打包的index.html和static等静态文件直接丢进test的某个文件例如abc文件夹下&a…

每日英语:Go Ahead, Hit the Snooze Button

Turns out a good nights rest is good for business. snooze&#xff1a;小睡&#xff0c;打盹One-third of American workers arent sleeping enough to function at peak levels, and that chronic exhaustion is costing billions of dollars in lost productivity, accord…

wireshark如何抓取本机包

From: http://www.cnblogs.com/lvdongjie/p/6110183.html 在进行通信开发的过程中&#xff0c;我们往往会把本机既作为客户端又作为服务器端来调试代码&#xff0c;使得本机自己和自己通信。但是wireshark此时是无法抓取到数据包的&#xff0c;需要通过简单的设置才可以。 具体…

vue页面使用html2canvas截图;vue使用canvas画布签名

vue页面使用html2canvas截图 vue使用vue-esign画布签名

如何用css将超出部分变成...

通过css控制超出部分变成...比通过javascript截取字符串效率要高得多而且也更简单 不多说&#xff0c;看例子 <html> <body> <style> .ellipsis span { white-space:nowrap; text-overflow:ellipsis; /* for internet explorer */ overflow:hidden;…

【Android】Android开发启动app弹出一张广告图片,Dialog可以查看大图,查看某个图片功能...

作者&#xff1a;程序员小冰&#xff0c;GitHub主页&#xff1a;https://github.com/QQ986945193 新浪微博&#xff1a;http://weibo.com/mcxiaobing 首先给大家看一下我们今天这个最终实现的效果图&#xff1a; 首先说一下&#xff0c;这里利用的是一个dialog&#xff0c;然…

el-dialog弹框中img图片保持比例最大化;图片保持比例最大化

图片保持比例最大化 <el-dialog :visible.sync"dialogVisible" center class"look_img_dia"><img width"100%" :src"dialogImageUrl" alt"" /></el-dialog>.look_img_dia {/deep/.el-dialog {margin-top…

Wireshark技巧-过滤规则和显示规则

From: http://www.cnblogs.com/icez/p/3973873.html Wireshark是一个强大的网络协议分析软件&#xff0c;最重要的它是免费软件。 过滤规则 只抓取符合条件的包&#xff0c;在Wireshark通过winpacp抓包时可以过滤掉不符合条件的包&#xff0c;提高我们的分析效率。 如果要填写过…

正则表达式及扩展

正则表达式&#xff1a; 正则表达式是对字符串操作的一种逻辑公式&#xff0c;就是用事先定义好的一些特定字符、及这些特定字符的组合&#xff0c;组成一个“规则字符串”&#xff0c;这个“规则字符串”用来表达对字符串的一种过滤逻辑。给定一个正则表达式和另一个字符串&am…

easyUI 展开DataGrid里面的行显示详细信息

http://blog.csdn.net/yanghongchang_/article/details/7854156原著 datagrid 可以改变它的view(视图)去显示不同的效果.使用详细视图,datagrid可以显示展开按钮("" 或者 "-")在数据行的左边,用户可以展开一个行去显示一个附加的详细信息. 查看 Demo 步骤 …

vue父组件调用子组件的方法;vue子组件使用父组件的方法

vue父组件调用子组件的方法 <div><son ref"son"></son></div>// 直接在父组件页面的某个点击事件内调用此方法即可 sonMethod是子组件的方法 // 注意当前父组件内的子组件需要设置ref this.$nextTick(() > {this.$refs[son].sonMethod(参…

理解OAuth 2.0(转)

From: http://www.mamicode.com/info-detail-1610036.html 理解OAuth 2.0 作者&#xff1a; 阮一峰 日期&#xff1a; 2014年5月12日 OAuth是一个关于授权&#xff08;authorization&#xff09;的开放网络标准&#xff0c;在全世界得到广泛应用&#xff0c;目前的版本是2.0版。…

Havel-Hakimi定理

转自http://sbp810050504.blog.51cto.com/2799422/883904 我一直想写一些关于图论学习的收获。一直由于这样或者那样的原因都没有开始。无论如何&#xff0c;现在开始吧&#xff01;那么到底什么是图呢&#xff1f;我们这里说的图当然不是像照片一样的东东。最权威的定义&a…

Axure RP 8.0正式版下载地址 安装和汉化说明

1.Axure RP和中文包包下载地址 官网地址&#xff1a;http://www.axure.com.cn/3510/ 2.下载完成后安装 3.破解 axure8.0注册码激活码&#xff1a;&#xff08;亲测可用&#xff09;用户名&#xff1a;aaa注册码&#xff1a;2GQrt5XHYY7SBK/4b22Gm4Dh8alaR0/0k3gEN5h7FkVPIn8oG3…

el-table记录删除后的表格滚动条位置

场景&#xff1a;一般el-table的删除操作&#xff0c;在删除数据后前端会重新调接口获取数据&#xff0c;此时列表更新会自动回到el-table顶部。但是我们想要让列表刷新后回到当时的滚动条位置那里&#xff0c;那么就需要记住删除时候的位置。 <el-table ref"eltable&q…