建站
咨詢
售后
建站咨詢
新聞中心
WCF編程工具是.NET Framework 3.5的重要組成部分，它獨(dú)特的統(tǒng)一性，安全性以及兼容性可以幫助開(kāi)發(fā)人員創(chuàng)造一個(gè)功能強(qiáng)大的企業(yè)級(jí)應(yīng)用解決方案。其中，WCF異步調(diào)用是基于消息交換(Message Exchange)來(lái)實(shí)現(xiàn)的，和我們通常使用委托來(lái)實(shí)現(xiàn)異步調(diào)用有所不同。
創(chuàng)新互聯(lián)專注骨干網(wǎng)絡(luò)服務(wù)器租用10年，服務(wù)更有保障！服務(wù)器租用，簡(jiǎn)陽(yáng)服務(wù)器托管 成都服務(wù)器租用，成都服務(wù)器托管，骨干網(wǎng)絡(luò)帶寬，享受低延遲，高速訪問(wèn)。靈活、實(shí)現(xiàn)低成本的共享或公網(wǎng)數(shù)據(jù)中心高速帶寬的專屬高性能服務(wù)器。
WCF異步調(diào)用步驟1. 創(chuàng)建服務(wù)契約。
- [ServiceContract(SessionModeSessionMode=SessionMode.Required)]
- public interface ICalculate
- {
- [OperationContract]
- int Add(int a, int b);
- }
WCF異步調(diào)用步驟2. 為契約方法添加異步版本。
我們?yōu)?Add 方法添加了 BeginAdd 和 EndAdd 兩個(gè)在 .NET SDK 中 "常見(jiàn)" 的異步操作方法。注意 BeginAdd 方法中我們添加了異步聲明，而 EndAdd 方法沒(méi)有。還有就是要注意異步版本方法的參數(shù)。
- [ServiceContract(SessionModeSessionMode=SessionMode.Required)]
- public interface ICalculate
- {
- [OperationContract]
- int Add(int a, int b);
- [OperationContract(AsyncPattern=true)]
- IAsyncResult BeginAdd(int a, int b, AsyncCallback callBack,
object state);- int EndAdd(IAsyncResult ar);
- }
WCF異步調(diào)用步驟3. 實(shí)現(xiàn)服務(wù)契約。
你可能注意到了，我們并沒(méi)有創(chuàng)建 Add 的委托原型，也沒(méi)有 "真正" 實(shí)現(xiàn) BeginAdd 和 EndAdd。這是因?yàn)橄⒔粨Q會(huì) "異步" 調(diào)用 Add 方法，所有的異步版本方法只是用來(lái)創(chuàng)建消息聲明而已。
- public class CalculateService : ICalculate
- {
- public int Add(int a, int b)
- {
- Thread.Sleep(5000);
- Console.WriteLine(OperationContext.Current.SessionId);
- return a + b;
- }
- public IAsyncResult BeginAdd(int a, int b, AsyncCallback
callBack, object state)- {
- throw new Exception("The method or operation is not implemented.");
- }
- public int EndAdd(IAsyncResult ar)
- {
- throw new Exception("The method or operation is not implemented.");
- }
- }
WCF異步調(diào)用步驟4. 我們給一個(gè)完整版本，看看執(zhí)行結(jié)果。
- [ServiceContract]
- public interface ICalculate
- {
- [OperationContract]
- int Add(int a, int b);
- [OperationContract(AsyncPattern = true)]
- IAsyncResult BeginAdd(int a, int b, AsyncCallback callBack,
object state);- int EndAdd(IAsyncResult ar);
- }
- public class CalculateService : ICalculate
- {
- public int Add(int a, int b)
- {
- Console.WriteLine("服務(wù)器方法 Add 開(kāi)始執(zhí)行: {0}", DateTime.Now);
- try
- {
- Thread.Sleep(5000);
- return a + b;
- }
- finally
- {
- Console.WriteLine("服務(wù)器方法 Add 執(zhí)行完成: {0}", DateTime.Now);
- }
- }
- public IAsyncResult BeginAdd(int a, int b, AsyncCallback
callBack, object state)- {
- throw new Exception("The method or operation is not implemented.");
- }
- public int EndAdd(IAsyncResult ar)
- {
- throw new Exception("The method or operation is not implemented.");
- }
- }
- public class WcfTest
- {
- public static void Test()
- {
- AppDomain.CreateDomain("Server").DoCallBack(delegate
- {
- ServiceHost host = new ServiceHost(typeof(CalculateService));
- host.AddServiceEndpoint(typeof(ICalculate), new WSHttpBinding(),
- "http://localhost:8080/calc");
- host.Open();
- });
- ICalculate channel = ChannelFactory
.CreateChannel
(new WSHttpBinding(),- new EndpointAddress("http://localhost:8080/calc"));
- using (channel as IDisposable)
- {
- Console.WriteLine("客戶端調(diào)用 BeginAdd: {0}", DateTime.Now);
- IAsyncResult ar = channel.BeginAdd(1, 2, delegate
{ Console.WriteLine("CallBack..."); }, null);- Console.WriteLine("客戶端調(diào)用 BeginAdd 完成: {0}", DateTime.Now);
- Console.WriteLine(channel.EndAdd(ar));
- Console.WriteLine("客戶端調(diào)用 EndAdd 完成: {0}", DateTime.Now);
- }
- }
- }
輸出：
- 客戶端調(diào)用 BeginAdd: 2007-4-1 20:56:47
- 客戶端調(diào)用 BeginAdd 完成: 2007-4-1 20:56:47
- 服務(wù)器方法 Add 開(kāi)始執(zhí)行: 2007-4-1 20:56:49
- 服務(wù)器方法 Add 執(zhí)行完成: 2007-4-1 20:56:54
- 3
- 客戶端調(diào)用 EndAdd 完成: 2007-4-1 20:56:55
- CallBack...
最后在WCF異步調(diào)用步驟中需要注意的是，我們必須使用支持 Session 的 Binding 對(duì)象 (BasicHttpBinding 會(huì)拋出異常)。
【編輯推薦】
- WCF集合類型各種限制于規(guī)則介紹
- WCF集合反序列化具體操作技巧分享
- WCF集合數(shù)據(jù)契約相關(guān)定制方法詳解
- WCF宿主環(huán)境基本概念詳解
- WCF序列化引擎具體應(yīng)用技巧分享
當(dāng)前文章：WCF異步調(diào)用正確實(shí)現(xiàn)方法講解
文章URL：http://m.5511xx.com/article/dhpccoi.html
