WCF中的異步實現
目錄:
1.WCF客戶端異步調用服務
2.服務端的異步實現
WCF客戶端異步調用服務主要通過生成異步的代理類,然后調用其中的異步方法來實現異步調用。
異步代理類的生成:
通過SvcUtil /async 直接生產異步代理;
通過添加應用的方式,點擊”添加引用“的“高級”按鈕,在彈出來的對話框中選擇“生成異步”。如圖:

生成的異步調用代理類部分借口:
- [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)]
- public System.IAsyncResult BeginAdd(int x, int y, System.AsyncCallback callback, object asyncState) {
- return base.Channel.BeginAdd(x, y, callback, asyncState);
- }
- public void AddAsync(int x, int y) {
- this.AddAsync(x, y, null);
- }
- public void AddAsync(int x, int y, object userState) {
- if ((this.onBeginAddDelegate == null)) {
- this.onBeginAddDelegate = new BeginOperationDelegate(this.OnBeginAdd);
- }
- if ((this.onEndAddDelegate == null)) {
- this.onEndAddDelegate = new EndOperationDelegate(this.OnEndAdd);
- }
- if ((this.onAddCompletedDelegate == null)) {
- this.onAddCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnAddCompleted);
- }
- base.InvokeAsync(this.onBeginAddDelegate, new object[] {
- x,
- y}, this.onEndAddDelegate, this.onAddCompletedDelegate, userState);
- }
客戶端異步調用服務主要方式有幾種:
1.1、直接調用異步方法:
在生成的代理類中,有BeginAdd\EndAdd等服務契約中定義的Add操作的異步實現。直接調用BeginAdd方法,實現客戶端異步調用服務端方法。在調用BeginAdd方法后,可執行一些其他操作,這些操作與服務端Add調用并行執行,Add調用最終通過EndAdd方法得到。
測試代碼如下:
客戶端代碼:
- IAsyncResult asyncResult = calculatorClient.BeginAdd(1, for (int i = 0; i < 10; i++)
- {
- Console.WriteLine(i);
- }
- int resul = calculatorClient.EndAdd(asyncResult);
- Console.WriteLine(string.Format("計算結果:{0}",resul));
- public int Add(int x, int y)
- {
- for (int i = 0; i < 20; i++)
- {
- Console.WriteLine(i);
- }
- Console.WriteLine("開始計算...");
- return x + y;
- }
服務端輸出如下:
客戶端輸出如下:
這種方式使用了EndAdd方法,如果服務端沒有執行完成,當前線程會被阻塞直到異步調用的服務完成后結束。如客戶端代碼保持不變,將服務實現改為如下:
- for (int i = 0; i < 20; i++)
- {
- Console.WriteLine(i);
- }
- Thread.Sleep(5000);
- Console.WriteLine("開始計算...");
- return x + y;
如果在服務端讓線程睡眠幾秒,就可看到客戶端會被阻塞:
1.2、通過回調的方式異步調用服務:
在生成的異步調用代理類中,還可以通過回調用服務:
- IAsyncResult asyncResult = calculatorClient.BeginAdd(1, 2,
- delegate(IAsyncResult asyncResult)
- {
- int [] array = asyncResult.AsyncState as int [];
- int result= calculatorClient.EndAdd(asyncResult1);
- calculatorClient.close()
- Console.WriteLine(string.Format("{0}+{1}={2}", array[0], array[1], result));
- }, new []{1,2});
這種方式是對服務的異步調用完成以后,自動調用回調來獲取結果。
1.3、通過為異步操作注冊事件
- //進行異步調用
- calculatorClient.AddAsync(10, 36, new[] { 1000 });
- //為異步調用完成定義觸發事件
- calculatorClient.AddCompleted += calculatorClient_AddCompleted;
- Console.WriteLine("服務調用完成...");
- Console.ReadKey();
- //異步調用完成后執行
- privatestaticvoid calculatorClient_AddCompleted(object obj, AddCompletedEventArgs args)
- {
- var array = args.UserState as int[];
- int result = args.Result;
- Console.WriteLine(result);
- }
2、服務的異步實現:
將服務定義為異步服務,契約定義如下 :
- [OperationContract(AsyncPattern = true)]
- IAsyncResult BeginCalculator
- (int x,int y ,AsyncCallback asyncCallback, object state);
- void EndCalculator(IAsyncResult);
然后在實現契約接口的服務中,將方法實現為異步的。
將契約接口聲明為單向,也就是OneWay,這樣客戶端對此服務接口調用就是異步的。因為它無需等待服務端返回,客戶端只需將消息發送到傳輸層就立即返回。
那能不能將將這種客戶端對服務端的異步調用直接標記為單向的,那是不是可以不用生成異步代理類(即上述SvcUtil /Ayncs或者在添加引用時聲明將代理類生成異步操作)?答案是否定的,因為OneWay要求方法的返回值為void,而異步的方法需要IAsyncResult最為返回值,這兩者矛盾的。


2010-02-25 09:13:34
2010-02-22 17:58:06
2009-12-21 14:10:26
2009-11-06 15:54:15
2010-03-01 10:12:54
2009-12-22 18:43:00
2009-12-07 14:35:42
2010-03-01 10:26:40
2010-03-01 15:08:05
2010-02-24 09:59:19
2010-02-22 13:28:05
2009-11-09 15:49:01
2009-11-09 15:58:07




