WCF学习笔记(2)消息交换模式

WCF是基于消息的开发框架。其中，消息交换的模式一共有三种，分别为：数据报、请求/应答和双工。

数据报交换模式：     用于单向的消息发送。即发即弃。

请求/应答交换模式： 也叫半双工。一方请求，另一方应答。 类似于对讲机。

双工交换模式：        也叫全双工，发送者和接收者可以互发消息。类似于电话。 

 示例代码：

契约：

 1     [ServiceContract(CallbackContract = typeof(IExampleCallbackClass))]

 2     public interface IExampleClass

 3     {

 4         [OperationContract(IsOneWay = true)]

 5         void SendMessage(string message);

 6 

 7         [OperationContract()]

 8         string RequestMessage();

 9 

         [OperationContract(IsOneWay = true)]

         void SendMessageAgain(string message);

     }

 

     public interface IExampleCallbackClass

     {

         [OperationContract(IsOneWay= true)]

         void CallBack(string message);

     } 

 实现：

 1     [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Reentrant)]

 2     public class ExampleClass : IExampleClass

 3     {

 4         public void SendMessage(string message)

 5         {

 6             Console.WriteLine("Send Message: " + message);

 7         }

 8         public string RequestMessage()

 9         {

             return "Request and Response!";

         }

         public void SendMessageAgain(string message)

         {

             Console.WriteLine("Send message again: " + message);

             var callBack = OperationContext.Current.GetCallbackChannel<IExampleCallbackClass>();

             callBack.CallBack("Send Callback: " + message);

         }

     }

 

     public class ExampleCallbackClass : IExampleCallbackClass

     {

         public void CallBack(string message)

         {

             Console.WriteLine("Print Callback :" + message);

         }

     } 

调用：

 1         static void Main(string[] args)

 2         {

 3             // 启动服务

 4             WSDualHttpBinding dualBinding = new WSDualHttpBinding(WSDualHttpSecurityMode.None);

 5             dualBinding.MessageEncoding = WSMessageEncoding.Text;

 6 

 7             Uri address = new Uri("http://localhost:8000/Datapram", UriKind.Absolute);

 8             ServiceHost svc = new ServiceHost(typeof(ExampleClass));

 9             svc.AddServiceEndpoint(typeof(IExampleClass), dualBinding, address);

             svc.Open();

 

             Console.WriteLine("WCF服务已经启动!");

 

             // 调用服务

             WSDualHttpBinding remoteBinding = new WSDualHttpBinding(WSDualHttpSecurityMode.None);

             EndpointAddress remoteAddress = new EndpointAddress(

                 new Uri("http://localhost:8000/Datapram", UriKind.Absolute));

 

             IExampleCallbackClass callBack = new ExampleCallbackClass();

             IExampleClass proxy = DuplexChannelFactory<IExampleClass>.CreateChannel(callBack, remoteBinding, remoteAddress);

 

             //数据报交换模式

             proxy.SendMessage("some message");

 

             // 请求应答模式

             string responseString = proxy.RequestMessage();

             Console.WriteLine("收到服务器的应答：" + responseString);

 

             // 双工

             proxy.SendMessageAgain("message");

 

             Console.WriteLine("服务调用成功!");

             Console.ReadLine();

         }

     } 

数据报和请求/调用的绑定，可以使用 WSHttpBinding 来做，因为，三种方式都写入到一个示例里，所以用了 WSDualHttpBinding。 

需要注意的部分：在IExampleClass 的实现中，需要声明特性：[ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Reentrant)].如果不声明，运时的时候会报"操作将死锁..."的异常。出现这个异常的原因是：在默认的情况下，服务的执行按Single并发模式进行，也就是说在服务执行全程，服务对象只能被一个线程访问。WCF通过加锁机制保证服务对象的独占性使用，也就是说在服务执行开始会对服务对象加锁，该锁在服务操作结束之后释放。