WCF简单教程(6) 单向与双向通讯

1、服务端

契约接口中增加一个Sleep方法：

1. using System;  
2. using System.ServiceModel;  
3. using System.Text;  
4.   
5. namespace Server  
6. {  
7.     [ServiceContract(Namespace="WCF.Demo")]  
8.     public interface IData  
9.     {  
10.         [OperationContract]  
11.         string SayHello(string userName);  
12.  
13.         /// <summary> 
14.         /// IsOneWay = true 表明这是一个单向调用，注意返回值是void，因为既然是单向调用，客户端肯定不会等待接收返回值的 
15.         /// </summary> 
16.         [OperationContract(IsOneWay = true)] 
17.         void Sleep(); 
18.     }  
19. } 

对应的实现类中，我们来实现这个方法：

1. using System;  
2. using System.Text;  
3.   
4. namespace Server  
5. {  
6.     public class DataProvider : IData  
7.     {  
8.         public string SayHello(string userName)  
9.         {  
10.             return string.Format("Hello {0}.", userName);  
11.         }  
12.  
13.         /// <summary> 
14.         /// 实现Sleep方法，暂时不做任何事情，只是睡眠5秒 
15.         /// </summary> 
16.         public void Sleep() 
17.         { 
18.             Thread.Sleep(5000); 
19.         } 
20.     }  
21. }  

App.config就不再列出来了，里面用的是一个netTcpBinding的endpoint。

2、客户端

首先别忘了客户端的契约要与服务端保持一致，App.config也不列出来了，里面有对应的endpoint。主要是调用的代码：

1. using System;  
2. using System.ServiceModel;  
3. using System.ServiceModel.Channels;  
4.   
5. namespace Client  
6. {  
7.     class Program  
8.     {  
9.         static void Main(string[] args)  
10.         {  
11.             var proxy = new ChannelFactory<Server.IData>("DataService").CreateChannel();  
12.  
13.             //先调用SayHello方法  
14.             Console.WriteLine(proxy.SayHello("WCF"));  
15.             //调用一下Sleep方法，按我们的设想，它应该是异步的，所以不会阻塞后面的调用 
16.             proxy.Sleep(); 
17.             //再调用一次SayHello方法  
18.             Console.WriteLine(proxy.SayHello("WCF"));  
19.             //关闭连接  
20.             ((IChannel)proxy).Close();  
21.     }  
22. } 

按我们的设想，两次SayHello调用之间应该没有延迟，因为Sleep是异步的嘛，编译运行一下，结果……  中间卡住了5秒，这是为什么呢？

这其中涉及到一个并发模型的问题，默认情况下，WCF以单线程模型对外提供服务，也就是说，只能一个一个处理请求，即使是一个OneWay的单向调用，也只能等它处理完后才会接着处理后面的SayHello请求，所以会卡5秒。

并发模式有以下三种，MSDN上的介绍有点复杂，我给简化一下：

调置服务并发模型是在契约的实现类上，我们为DataService类加一个Attribute：

1. /// <summary> 
2. /// 用ServiceBehavior为契约实现类标定行为属性，此处指定并发模型为ConcurrencyMode.Multiple，即并发访问 
3. /// </summary> 
4. [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple)] 
5. public class DataProvider : IData 
6. { 
7.     //略 
8. } 

这回再编译运行一下，连续打出了2行 Hello WCF，中间不再阻塞了。

现在我们再来看看双向通讯的问题。双向通讯可以基于HTTP、TCP、Named Pipe、MSMQ，但要注意，basicHttpBinding和wsHttpBinding不行，要换用wsDualHttpBinding，它会创建两个连接来进行双向通讯。至于TCP，它天然就是双向通讯的。

1、服务端

服务契约要进行修改，增加关于回调的契约：

1. using System; 
2. using System.ServiceModel; 
3. using System.ServiceModel.Description; 
4.  
5. namespace Server 
6. { 
7.     /// <summary> 
8.     /// 增加了CallbackContract的标识，用于指明针对此服务契约的回调契约是IDataCallback 
9.     /// </summary> 
10.     [ServiceContract(Namespace = "WCF.Demo", CallbackContract = typeof(IDataCallback))] 
11.     public interface IData 
12.     { 
13.         [OperationContract] 
14.         string SayHello(string userName); 
15.  
16.         [OperationContract(IsOneWay = true)] 
17.         void Sleep(); 
18.     } 
19.  
20.     /// <summary> 
21.     /// 定义服务回调契约，注意它没有契约标识，只是个一般接口 
22.     /// </summary> 
23.     public interface IDataCallback 
24.     { 
25.         /// <summary> 
26.         /// 定义一个回调方法，由于回调不可能要求对方再响应，所以也标识成OneWay的调用，同样不需要有返回值 
27.         /// </summary> 
28.        [OperationContract(IsOneWay = true)] 
29.        void SleepCallback(string text); 
30.     } 
31. } 

对应的契约实现类要修改一下：

1. using System; 
2. using System.ServiceModel; 
3. using System.ServiceModel.Description; 
4. using System.Threading; 
5. using System.Net; 
6.  
7. namespace Server 
8. { 
9.     [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple)] 
10.     public class DataProvider : IData 
11.     { 
12.         public string SayHello(string userName) 
13.         { 
14.             string.Format("Hello {0}.", userName); 
15.         } 
16.  
17.         public void Sleep() 
18.         { 
19. //先睡5秒
20.             Thread.Sleep(5000); 
21.  
22. //用OperationContext.Current来获取指定类型的回调对象 
23.             var callback = OperationContext.Current.GetCallbackChannel<IDataCallback>(); 
24. //回调SleepCallback方法，并传递参数 
25.             callback.SleepCallback("睡醒了"); 
26.         } 
27.     } 
28. } 

2、客户端

仍然提醒一下别忘了把新的服务契约更新到客户端。客户端的调用要调整一下：

1. using System;  
2. using System.ServiceModel;  
3. using System.ServiceModel.Channels;  
4.   
5. namespace Client  
6. {  
7.     class Program  
8.     {  
9.         static void Main(string[] args)  
10.         {  
11.             //定义一个实现回调接口的类实例 
12.             var context = new DataCallbackImp(); 
13.             //创建代理的时候变了，要用DuplexChannelFactory，因为IData契约已经标识了有回调，所以必须要用支持双向通讯的ChannelFactory，传入刚才创建的回调实例 
14.             var proxy = new DuplexChannelFactory<Server.IData>(context, "DataService").CreateChannel();  
15.  
16.             //调用Sleep 
17.             proxy.Sleep(); 
18.             //调用SayHello方法  
19.             Console.WriteLine(proxy.SayHello("WCF"));  
20.  
21.             //等待按任意键，先不要关连接 
22.             Console.ReadKey(); 
23.             ((IChannel)proxy).Close();  
24.     }  
25.  
26.     /// <summary> 
27.     /// 实现回调接口中的类，图省事写到这里了 
28.     /// </summary> 
29.     class DataCallbackImp : Server.IDataCallback 
30.     { 
31.         /// <summary> 
32.         /// 实现SleepCallback方法 
33.         /// </summary> 
34.         public void SleepCallback(string text) 
35.         { 
36.             Console.WriteLine("收到回调了：" + text); 
37.         } 
38.     } 
39. } 

编译运行，屏幕先显示一行“Hello WCF.”，过5秒后显示“收到回调了：睡醒了”。

     本文转自 BoyTNT 51CTO博客，原文链接：http://blog.51cto.com/boytnt/803655，如需转载请自行联系原作者