建站
咨詢
售后
建站咨詢
新聞中心
目錄：
創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、西峽網(wǎng)絡(luò)推廣、重慶小程序開發(fā)、西峽網(wǎng)絡(luò)營銷、西峽企業(yè)策劃、西峽品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供西峽建站搭建服務(wù)，24小時(shí)服務(wù)熱線：028-86922220，官方網(wǎng)址：www.cdcxhl.com
1.WCF客戶端異步調(diào)用服務(wù)
2.服務(wù)端的異步實(shí)現(xiàn)
WCF客戶端異步調(diào)用服務(wù)主要通過生成異步的代理類，然后調(diào)用其中的異步方法來實(shí)現(xiàn)異步調(diào)用。
異步代理類的生成：
通過SvcUtil /async 直接生產(chǎn)異步代理；
通過添加應(yīng)用的方式，點(diǎn)擊”添加引用“的“高級(jí)”按鈕，在彈出來的對(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);
- }
1、客戶端異步調(diào)用服務(wù)
客戶端異步調(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)用最終通過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("計(jì)算結(jié)果：{0}",resul));
服務(wù)端代碼：
- public int Add(int x, int y)
- {
- for (int i = 0; i < 20; i++)
- {
- Console.WriteLine(i);
- }
- Console.WriteLine("開始計(jì)算...");
- return x + y;
- }
服務(wù)端輸出如下：
客戶端輸出如下：
這種方式使用了EndAdd方法，如果服務(wù)端沒有執(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("開始計(jì)算...");
- return x + y;
如果在服務(wù)端讓線程睡眠幾秒，就可看到客戶端會(huì)被阻塞：
1.2、通過回調(diào)的方式異步調(diào)用服務(wù)：
在生成的異步調(diào)用代理類中，還可以通過回調(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)來獲取結(jié)果。
1.3、通過為異步操作注冊事件
- //進(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ù)實(shí)現(xiàn)定義成異步的方式，需要將OperationContract的AsyncPattern設(shè)置為true；應(yīng)用到BeginXX接口上,并且此操作的最后兩個(gè)參數(shù)必須為AsyncCallback ，object；需要有一個(gè)EndXX(IAsyncResult asyncResult)的接口與異步調(diào)用的接口匹配。需要注意的是EndXX(IAsyncResult asyncResult)不能再次聲明為契約接口，也就是不能再標(biāo)記為OperationContract。
將服務(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ù)端返回，客戶端只需將消息發(fā)送到傳輸層就立即返回。
那能不能將將這種客戶端對(duì)服務(wù)端的異步調(diào)用直接標(biāo)記為單向的，那是不是可以不用生成異步代理類(即上述SvcUtil /Ayncs或者在添加引用時(shí)聲明將代理類生成異步操作)？答案是否定的，因?yàn)镺neWay要求方法的返回值為void，而異步的方法需要IAsyncResult最為返回值，這兩者矛盾的。
網(wǎng)站標(biāo)題：WCF中的異步實(shí)現(xiàn)
文章分享：http://fisionsoft.com.cn/article/dhhppgs.html
