目錄：

1.WCF客戶端異步調(diào)用服務(wù)

2.服務(wù)端的異步實(shí)現(xiàn)

WCF客戶端異步調(diào)用服務(wù)主要通過(guò)生成異步的代理類，然后調(diào)用其中的異步方法來(lái)實(shí)現(xiàn)異步調(diào)用。

異步代理類的生成：

通過(guò)SvcUtil /async 直接生產(chǎn)異步代理；

通過(guò)添加應(yīng)用的方式，點(diǎn)擊”添加引用“的“高級(jí)”按鈕，在彈出來(lái)的對(duì)話框中選擇“生成異步”。如圖：

生成的異步調(diào)用代理類部分借口：

[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);  
} 

客戶端異步調(diào)用服務(wù)主要方式有幾種：

1.1、直接調(diào)用異步方法：

在生成的代理類中，有BeginAdd\EndAdd等服務(wù)契約中定義的Add操作的異步實(shí)現(xiàn)。直接調(diào)用BeginAdd方法，實(shí)現(xiàn)客戶端異步調(diào)用服務(wù)端方法。在調(diào)用BeginAdd方法后，可執(zhí)行一些其他操作，這些操作與服務(wù)端Add調(diào)用并行執(zhí)行，Add調(diào)用最終通過(guò)EndAdd方法得到。

測(cè)試代碼如下：

客戶端代碼：

IAsyncResult asyncResult = calculatorClient.BeginAdd(1, for (int i = 0; i < 10; i++)   
{  
Console.WriteLine(i);  
}  
int resul = calculatorClient.EndAdd(asyncResult);  
Console.WriteLine(string.Format("計(jì)算結(jié)果：{0}",resul)); 

public int Add(int x, int y)   
{  
for (int i = 0; i < 20; i++)  
{  
Console.WriteLine(i);  
}  
Console.WriteLine("開(kāi)始計(jì)算...");  
return x + y;  
} 

服務(wù)端輸出如下：

客戶端輸出如下：

這種方式使用了EndAdd方法，如果服務(wù)端沒(méi)有執(zhí)行完成，當(dāng)前線程會(huì)被阻塞直到異步調(diào)用的服務(wù)完成后結(jié)束。如客戶端代碼保持不變，將服務(wù)實(shí)現(xiàn)改為如下：

for (int i = 0; i < 20; i++)   
{  
Console.WriteLine(i);  
}  
Thread.Sleep(5000);  
Console.WriteLine("開(kāi)始計(jì)算...");  
return x + y; 

如果在服務(wù)端讓線程睡眠幾秒，就可看到客戶端會(huì)被阻塞：

1.2、通過(guò)回調(diào)的方式異步調(diào)用服務(wù)：

在生成的異步調(diào)用代理類中，還可以通過(guò)回調(diào)用服務(wù)：

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}); 

這種方式是對(duì)服務(wù)的異步調(diào)用完成以后，自動(dòng)調(diào)用回調(diào)來(lái)獲取結(jié)果。

1.3、通過(guò)為異步操作注冊(cè)事件

//進(jìn)行異步調(diào)用  
calculatorClient.AddAsync(10, 36, new[] { 1000 });  
//為異步調(diào)用完成定義觸發(fā)事件  
calculatorClient.AddCompleted += calculatorClient_AddCompleted;  
Console.WriteLine("服務(wù)調(diào)用完成...");  
Console.ReadKey();  
//異步調(diào)用完成后執(zhí)行  
privatestaticvoid calculatorClient_AddCompleted(object obj, AddCompletedEventArgs args)  
{  
var array = args.UserState as int[];  
int result = args.Result;  
Console.WriteLine(result);  
} 

2、服務(wù)的異步實(shí)現(xiàn)：

將服務(wù)定義為異步服務(wù)，契約定義如下 ：

[OperationContract(AsyncPattern = true)]   
IAsyncResult BeginCalculator   
(int x,int y ,AsyncCallback asyncCallback, object state);  
void EndCalculator(IAsyncResult); 

然后在實(shí)現(xiàn)契約接口的服務(wù)中，將方法實(shí)現(xiàn)為異步的。

將契約接口聲明為單向，也就是OneWay，這樣客戶端對(duì)此服務(wù)接口調(diào)用就是異步的。因?yàn)樗鼰o(wú)需等待服務(wù)端返回，客戶端只需將消息發(fā)送到傳輸層就立即返回。

那能不能將將這種客戶端對(duì)服務(wù)端的異步調(diào)用直接標(biāo)記為單向的，那是不是可以不用生成異步代理類(即上述SvcUtil /Ayncs或者在添加引用時(shí)聲明將代理類生成異步操作)？答案是否定的，因?yàn)镺neWay要求方法的返回值為void，而異步的方法需要IAsyncResult最為返回值，這兩者矛盾的。