WCF雙工通信

在WCF通信中，如果實作要得到服務端處理的結果，一種方式是在契約中指定調用方法帶傳回值（IsOneWay=false），但這種方式是有缺陷的，如果服務端處理時間過長，則用戶端也需要長時間等待。

另一種方式是通過雙工通信，使用回調來實作。但回調的時候，回調方法中不應該有耗時操作，否則當服務端處理完成退出的時間，回調消息會丢失。

目前WCF支援雙工的綁定方式有：WSDualHttpBinding，NetTcpBinding與NetNamedPipeBinding三種，其它綁定方式不支援雙工。

下面以一個簡短的例子說明雙工通信。

1、定義契約

[ServiceContract(Namespace = "http://cnblog.com/zhili/", CallbackContract = typeof(ICallback))]
    public interface ICalculator
    {
        [OperationContract(IsOneWay = true)]
        void Multiple(double a, double b);
        [OperationContract(IsOneWay = true)]
        void DisplayString(string name);
    }           

其中指定了回調契約是ICallback。

// 回調契約的定義，此時回調契約不需要應用ServiceContractAttribute特性
    public interface ICallback
    {
        [OperationContract(IsOneWay = true)]
        void DisplayResult(double x, double y, double result);

        [OperationContract(IsOneWay = false, ProtectionLevel = ProtectionLevel.EncryptAndSign)]
        string DisplayStringResult(string retStr);
    }           

我們看到，回調第二個方法有傳回值。這個在服務行為配置中要有特殊配置，否則會卡死。

2、服務端實作

實作服務契約：

// 服務契約的實作
    [ServiceBehavior(IncludeExceptionDetailInFaults = true,ConcurrencyMode = ConcurrencyMode.Multiple)]
    public class CalculatorService : ICalculator
    {
        #region ICalculator Members

        public void Multiple(double a, double b)
        {
            for (int i = 1; i < 100; i++)
            {
                double result = a * b;

                // 通過用戶端執行個體通道
                ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>();

                // 對用戶端操作進行回調
                callback.DisplayResult(a, b, result);
                Console.WriteLine("Callback Times {0} at time {1}", i, DateTime.Now.ToString("hh:mm:ss tt zz"));
            }
            Program.ExitFlag = true;
        }

        public void DisplayString(string name)
        {
           
            for (int i = 1; i < 100; i++)
            {
                // 通過用戶端執行個體通道
                ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>();
               
                // 對用戶端操作進行回調
                string retStr = callback.DisplayStringResult("Hello " + name);
                Console.WriteLine("Callback Times {0} at time {1}, ret={2}", i, DateTime.Now.ToString("hh:mm:ss tt zz"), retStr);
            }
            Program.ExitFlag = true;
        }

        #endregion
    }           

其中ServiceBehavior屬性的ConcurrencyMode = ConcurrencyMode.Multiple配置就是配置回調方法帶傳回值問題（IsOneWay=false），如果不設定這個屬性，或者設定為Single，上述回調方法調用時會卡死。

主程式如下：

class Program
    {
        public static bool ExitFlag = false;
        static void Main(string[] args)
        {
            using (ServiceHost host = new ServiceHost(typeof(CalculatorService)))
            {
                host.Opened += delegate
                {
                    Console.WriteLine("Service start now....");
                };

                host.Open();
                while (!ExitFlag)
                {
                    Thread.Sleep(500);
                }
            }
        }
    }           

主程式配置（App.Config）：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
    <system.serviceModel>
        <behaviors>
            <serviceBehaviors>
                <behavior>
                    <serviceMetadata httpGetEnabled="true" httpGetUrl="http://localhost:8080/Metadata"/>
                </behavior>
            </serviceBehaviors>
        </behaviors>
        <services>
            <service name="NMS.WCFDemo.Server.CalculatorService">
                <endpoint address="net.tcp://localhost:9003/CalculatorService" binding="netTcpBinding" contract="NMS.WCFDemo.Contract.ICalculator"/>
            </service>
        </services>
    </system.serviceModel>
</configuration>           

3、用戶端

建立完用戶端程式後，添加一個服務引用，指向上面配置檔案的位址

http://localhost:8080/Metadata

擷取服務引用。（添加服務引用時服務程式必須已經在運作）

實作回調契約：

// 用戶端中對回調契約的實作
    public class CallbackWCFService : ICalculatorCallback
    {
        private int i = 1;
        public void DisplayResult(double a, double b, double result)
        {
            Console.WriteLine("{4}  :  {0} * {1} = {2}  ====== AT Time {3}", a, b, result, DateTime.Now.ToString("hh:mm:ss tt zz"), i++);
            Thread.Sleep(1000);
        }

        public string DisplayStringResult(string retStr)
        {
            Console.WriteLine("{0}  :  recevie msg  {1} ====== AT Time {2}", i++, retStr, DateTime.Now.ToString("hh:mm:ss tt zz"));
            Thread.Sleep(1000);
            return i.ToString();
        }
    }           

用戶端主程式：

// 用戶端實作，測試回調操作
    class Program
    {
        static void Main(string[] args)
        {
            InstanceContext instanceContex = new InstanceContext(new CallbackWCFService());
            CalculatorClient proxy = new CalculatorClient(instanceContex);
            if (args[0] == "1")
            {
                proxy.Multiple(2, 3);
            }
            else
            {
                Console.WriteLine("Call string ...");
                proxy.DisplayString("Client");
            }
            Console.Read();
        }
    }           

用戶端配置檔案（App.Config）

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
    <startup>
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
    </startup>
    <system.serviceModel>
        <bindings>
            <netTcpBinding>
                <binding name="NetTcpBinding_ICalculator" />
                <binding name="NetTcpBinding_ICalculator1" />
            </netTcpBinding>
        </bindings>
        <client>
            <endpoint address="net.tcp://localhost:9003/CalculatorService"
                binding="netTcpBinding" bindingConfiguration="NetTcpBinding_ICalculator"
                contract="NMS.WCFDemo.Contract.ICalculator" name="NetTcpBinding_ICalculator" />
            <endpoint address="net.tcp://localhost:9003/CalculatorService"
                binding="netTcpBinding" bindingConfiguration="NetTcpBinding_ICalculator1"
                contract="ServiceReference1.ICalculator" name="NetTcpBinding_ICalculator1">
                <identity>
                    <userPrincipalName value="DESKTOP-4D9M16H\wangcc" />
                </identity>
            </endpoint>
        </client>
    </system.serviceModel>
</configuration>           

然後運作程式就能看到效果了。