WCF中的异步实现

目录：

创新互联专注为客户提供全方位的互联网综合服务，包含不限于做网站、成都网站设计、西峡网络推广、重庆小程序开发、西峡网络营销、西峡企业策划、西峡品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供西峡建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com

1.WCF客户端异步调用服务

2.服务端的异步实现

WCF客户端异步调用服务主要通过生成异步的代理类，然后调用其中的异步方法来实现异步调用。

异步代理类的生成：

通过SvcUtil /async 直接生产异步代理；

通过添加应用的方式，点击”添加引用“的“高级”按钮，在弹出来的对话框中选择“生成异步”。如图：

生成的异步调用代理类部分借口：

 
 
 
 
    
  
  
  
  
  1. [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 
    2. 
  
  
  
  
  2. public System.IAsyncResult BeginAdd(int x, int y, System.AsyncCallback callback, object asyncState) { 
    3. 
  
  
  
  
  3. return base.Channel.BeginAdd(x, y, callback, asyncState); 
    4. 
  
  
  
  
  4. } 
    5. 
  
  
  
  
  5. 
  
  
  
  
  6. 
  
  
  
  
  7. public void AddAsync(int x, int y) { 
    8. 
  
  
  
  
  8. this.AddAsync(x, y, null); 
    9. 
  
  
  
  
  9. } 
    10. 
  
  
  
  
  10. 
  
  
  
  
  11. public void AddAsync(int x, int y, object userState) { 
    12. 
  
  
  
  
  12. if ((this.onBeginAddDelegate == null)) { 
    13. 
  
  
  
  
  13. this.onBeginAddDelegate = new BeginOperationDelegate(this.OnBeginAdd); 
    14. 
  
  
  
  
  14. } 
    15. 
  
  
  
  
  15. if ((this.onEndAddDelegate == null)) { 
    16. 
  
  
  
  
  16. this.onEndAddDelegate = new EndOperationDelegate(this.OnEndAdd); 
    17. 
  
  
  
  
  17. } 
    18. 
  
  
  
  
  18. if ((this.onAddCompletedDelegate == null)) { 
    19. 
  
  
  
  
  19. this.onAddCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnAddCompleted); 
    20. 
  
  
  
  
  20. } 
    21. 
  
  
  
  
  21. base.InvokeAsync(this.onBeginAddDelegate, new object[] { 
    22. 
  
  
  
  
  22. x, 
    23. 
  
  
  
  
  23. y}, this.onEndAddDelegate, this.onAddCompletedDelegate, userState); 
    24. 
  
  
  
  
  24. }
    25.

1、客户端异步调用服务

客户端异步调用服务主要方式有几种：

1.1、直接调用异步方法：

在生成的代理类中，有BeginAdd\EndAdd等服务契约中定义的Add操作的异步实现。直接调用BeginAdd方法，实现客户端异步调用服务端方法。在调用BeginAdd方法后，可执行一些其他操作，这些操作与服务端Add调用并行执行，Add调用最终通过EndAdd方法得到。

测试代码如下：

客户端代码：

  
 
 
 
    
   
  
  
  
  1. IAsyncResult asyncResult = calculatorClient.BeginAdd(1, for (int i = 0; i < 10; i++)  
    2. 
   
  
  
  
  2. { 
    3. 
   
  
  
  
  3. Console.WriteLine(i); 
    4. 
   
  
  
  
  4. } 
    5. 
   
  
  
  
  5. int resul = calculatorClient.EndAdd(asyncResult); 
    6. 
   
  
  
  
  6. Console.WriteLine(string.Format("计算结果：{0}",resul));
    7.

服务端代码： 

  
 
 
 
    
   
  
  
  
  1. public int Add(int x, int y)  
    2. 
   
  
  
  
  2. { 
    3. 
   
  
  
  
  3. for (int i = 0; i < 20; i++) 
    4. 
   
  
  
  
  4. { 
    5. 
   
  
  
  
  5. Console.WriteLine(i); 
    6. 
   
  
  
  
  6. } 
    7. 
   
  
  
  
  7. Console.WriteLine("开始计算..."); 
    8. 
   
  
  
  
  8. return x + y; 
    9. 
   
  
  
  
  9. }
    10.

服务端输出如下：

客户端输出如下：

这种方式使用了EndAdd方法，如果服务端没有执行完成，当前线程会被阻塞直到异步调用的服务完成后结束。如客户端代码保持不变，将服务实现改为如下：

 
 
 
 
    
  
  
  
  
  1. for (int i = 0; i < 20; i++)  
    2. 
  
  
  
  
  2. { 
    3. 
  
  
  
  
  3. Console.WriteLine(i); 
    4. 
  
  
  
  
  4. } 
    5. 
  
  
  
  
  5. Thread.Sleep(5000); 
    6. 
  
  
  
  
  6. Console.WriteLine("开始计算..."); 
    7. 
  
  
  
  
  7. return x + y;
    8.

如果在服务端让线程睡眠几秒，就可看到客户端会被阻塞：

1.2、通过回调的方式异步调用服务：

在生成的异步调用代理类中，还可以通过回调用服务：

 
 
 
 
    
  
  
  
  
  1. IAsyncResult asyncResult = calculatorClient.BeginAdd(1, 2, 
    2. 
  
  
  
  
  2. delegate(IAsyncResult asyncResult) 
    3. 
  
  
  
  
  3. { 
    4. 
  
  
  
  
  4. int [] array = asyncResult.AsyncState as int []; 
    5. 
  
  
  
  
  5. int result= calculatorClient.EndAdd(asyncResult1); 
    6. 
  
  
  
  
  6. calculatorClient.close() 
    7. 
  
  
  
  
  7. Console.WriteLine(string.Format("{0}+{1}={2}", array[0], array[1], result)); 
    8. 
  
  
  
  
  8. }, new []{1,2});
    9.

这种方式是对服务的异步调用完成以后，自动调用回调来获取结果。

1.3、通过为异步操作注册事件

 
 
 
 
    
  
  
  
  
  1. //进行异步调用 
    2. 
  
  
  
  
  2. calculatorClient.AddAsync(10, 36, new[] { 1000 }); 
    3. 
  
  
  
  
  3. //为异步调用完成定义触发事件 
    4. 
  
  
  
  
  4. calculatorClient.AddCompleted += calculatorClient_AddCompleted; 
    5. 
  
  
  
  
  5. Console.WriteLine("服务调用完成..."); 
    6. 
  
  
  
  
  6. Console.ReadKey(); 
    7. 
  
  
  
  
  7. //异步调用完成后执行 
    8. 
  
  
  
  
  8. privatestaticvoid calculatorClient_AddCompleted(object obj, AddCompletedEventArgs args) 
    9. 
  
  
  
  
  9. { 
    10. 
  
  
  
  
  10. var array = args.UserState as int[]; 
    11. 
  
  
  
  
  11. int result = args.Result; 
    12. 
  
  
  
  
  12. Console.WriteLine(result); 
    13. 
  
  
  
  
  13. }
    14.

2、服务的异步实现：

将服务实现定义成异步的方式，需要将OperationContract的AsyncPattern设置为true；应用到BeginXX接口上,并且此操作的最后两个参数必须为AsyncCallback ，object；需要有一个EndXX(IAsyncResult asyncResult)的接口与异步调用的接口匹配。需要注意的是EndXX(IAsyncResult asyncResult)不能再次声明为契约接口，也就是不能再标记为OperationContract。

将服务定义为异步服务，契约定义如下 ：

 
 
 
 
    
  
  
  
  
  1. [OperationContract(AsyncPattern = true)]  
    2. 
  
  
  
  
  2. IAsyncResult BeginCalculator  
    3. 
  
  
  
  
  3. (int x,int y ,AsyncCallback asyncCallback, object state); 
    4. 
  
  
  
  
  4. void EndCalculator(IAsyncResult);
    5.

然后在实现契约接口的服务中，将方法实现为异步的。

将契约接口声明为单向，也就是OneWay，这样客户端对此服务接口调用就是异步的。因为它无需等待服务端返回，客户端只需将消息发送到传输层就立即返回。

那能不能将将这种客户端对服务端的异步调用直接标记为单向的，那是不是可以不用生成异步代理类(即上述SvcUtil /Ayncs或者在添加引用时声明将代理类生成异步操作)？答案是否定的，因为OneWay要求方法的返回值为void，而异步的方法需要IAsyncResult最为返回值，这两者矛盾的。

分享标题：WCF中的异步实现
URL地址：http://www.csdahua.cn/qtweb/news41/516641.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

App开发知识

行业网站建设

成都二枢机房　　 　四川白乌鱼　　 　眉山电信机房　　 　成都画册设计公司　　 　营山产后护理　　 　成都微信开发　　 　成都枢纽中心　　 　成都封阳台　　 　成都小程序开发　　 　成都广告招牌　　 　小程序开发　　 　重庆网络营销　　 　四川电信机房托管　　 　gyruijie.cn　　 　宇仓仓储　　 　成都网站制作　　 　VI设计　　 　全网营销网站推广　　 　成都网站设计　　 　成都木托盘