系列文章導航：

WCF從理論到實踐(1)：揭開神秘面紗

WCF從理論到實踐(2)：決戰紫禁之巔

WCF從理論到實踐(3)：八號當鋪之黑色契約

WCF從理論到實踐(4)：路在何方

WCF從理論到實踐(5)：Binding細解

WCF從理論到實踐(6)：WCF架構

WCF從理論到實踐(7)：消息交換模式

WCF從理論到實踐(8)：事件廣播

WCF從理論到實踐(9):實例模式和對象生命周期

WCF從理論到實踐(10)：異常處理

WCF從理論到實踐(11)-異步

WCF從理論到實踐(12):事務

WCF從理論到實踐(13):事務投票

WCF從理論到實踐(14):WCF解決方案模板

WCF從理論到實踐(15):響應變化

WCF從理論到實踐(16):操作重載（帶視頻+ppt+源碼）

WCF從理論到實踐(17):OO大背離（帶視頻+ppt+源碼）

本文的出發點

通過閱讀本文，您能理解以下知識：

1. WCF定義了哪幾種消息交換模式？
2. One-Way Calls
3. Request/Reply
4. Duplex
5. 用示例來解析WCF的消息交換模式

本文適合的讀者

本文涉及到了SOA中的消息交換的基礎概念，需要一些初級的Xml Web Service和分布式系統開發的經驗,最好理解WCF架構

WCF定義了哪幾種消息交換模式？

WCF定義了三種消息交換方式 ,分別為：

1. One-Way Calls
2. Request/Reply
3. Duplex

One-Way Calls

在幾種消息交換模式中，one-way calls是最沒良心的，對于客戶端，one-way calls就如肉包子打狗，有去無回。下面的圖示給出這種交換模型的特征：

在這種交換模式中，存在著如下的特征

1. 沒有返回值，返回類型只能為void
2. 不能包含ref或者out類型的參數
3. 只有客戶端發起請求，服務端并不會對請求進行回復。

通過設置OperationContract的IsOneWay=True可以將滿足要求的方法設置為這種消息交換模式，方法如下：

[OperationContract(IsOneWay=true)]

void Test(int intVal);

上面的代碼，就是將方法Test設置成為了one-way call的消息交換模式，注意如果Test方法的返回類型不是void或者帶有ref或者out類型的參數，都會拋出異常InvalidOperationException，如下面列表中的方法均不能被聲明為one-way模式

int Test(int intVal);

int Test();

int Test();

void Test(ref int intVal);

void Test(out int intVal);

Request/Reply

request/reply比起one-way來說，就更懂得禮尚往來，它是缺省的消息交換模式，類似于http協議中的請求/響應模型。下面的圖示給出這種交換模式的特征：

這種交換模式是使用最多的一中，它有如下特征：

1. 調用服務方法后需要等待服務的消息返回，即便該方法返回 void 類型
2. 相比Duplex來講，這種模式強調的是客戶端的被動接受，也就是說客戶端接受到響應后，消息交換就結束了。
3. 在這種模式下，服務端永遠是服務端，客戶端就是客戶端，職責分明。

它是缺省的消息交換模式，設置OperationContract便可以設置為此種消息交換模式

[OperationContrac]

void Test(int intVal);

注意，盡管Test方法返回為void，但Server也會生成reply響應并發送給client.有來有往是這種模式的特征。

Duplex

這種交換模式比起上面兩種，比較復雜，它和request/reply模式類似，也是有來有往，但處理過程卻比request/reply要復雜，因為它可以在處理完請求之后，通過請求客戶端中的回調進行響應操作，這種模式的圖示為：

注意，這種方式和request/reply方式的圖示也很類似，當二者存在著至關重要的不同，它在客戶端也有監聽節點，在callback的時候，服務器和客戶端的角色會進行交換，服務端此時成了嚴格意義上的客戶端，而客戶端此時能接受服務端的callback請求,所以成為了服務端。呵呵，辯證法，都拗口死了，當事實就是這種，就像對與錯一樣，會相互轉換，失敗是成功之母，而成功是失敗之源。廢話少說，Duplex的特征主要包括

1. 消息交換過程中，服務端和客戶端角色會發生調換
2. 服務端處理完請求后，返回給客戶端的不是reply，而是callback請求。

打個比方，Reqeust/Reply方式像是搓澡，1個管搓，1個被搓

而duplex像是拳擊，兩個人都會出拳

Duplex模式對Bindding有特殊的要求，它要求支持Duplex MEP(Message Exchange Pattern),如WSDualHttpBinding和NetTcpBinding，有關Binding的介紹請參見http://www.cnblogs.com/jillzhang/archive/2008/02/03/1063406.html

用示例來解析WCF的消息交換模式

建立示例的步驟不做具體闡述，下面看一下項目的最終結構：

下表說明各個項目的作用

下面就看下如何定義消息交換模式為one-way的Contract接口

而IOneWayJob的實現類代碼為：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Jillzhang.Messaging.Contract;

namespace Jillzhang.Messaging.Service
{
    public class OneWayJob : IOneWayJob
    {
        public void Do(string jobName)
        {
            System.Diagnostics.Stopwatch watcher = new System.Diagnostics.Stopwatch();
            watcher.Start();
            System.Threading.Thread.Sleep(1000);
            Console.WriteLine("服務" + AppDomain.CurrentDomain.FriendlyName + "執行任務:" + jobName);
            watcher.Stop();
        }
    }
}

Request/reply的Contract接口定義如下：

而INormalJob的實現代碼如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Jillzhang.Messaging.Contract;

namespace Jillzhang.Messaging.Service
{
    public class NormalJob:INormalJob
    {
        public string Do(string jobName)
        {
            try
            {              
                System.Diagnostics.Stopwatch watcher = new System.Diagnostics.Stopwatch();
                watcher.Start();
                System.Threading.Thread.Sleep(1000);
                Console.WriteLine("服務" + AppDomain.CurrentDomain.FriendlyName + "執行任務:" + jobName);
                watcher.Stop();              
                return "成功";
            }
            catch
            {
                return "失敗";
            }
        }
    }
}

Duplex的交換模式需要現定義Callback的Contract接口，如下：

而服務端的Contract接口為：

Duplex的Contract實現為：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Jillzhang.Messaging.Contract;
using System.ServiceModel;

namespace Jillzhang.Messaging.Service
{
   [ServiceBehavior(ConcurrencyMode=ConcurrencyMode.Multiple)]
    public class Job:IJob
    {
        public string Do(string jobName)
        {
            try
            {
                ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>();
                System.Diagnostics.Stopwatch watcher = new System.Diagnostics.Stopwatch();
                watcher.Start();
                System.Threading.Thread.Sleep(1000);
                Console.WriteLine("服務" + AppDomain.CurrentDomain.FriendlyName + "執行任務:" + jobName);
                watcher.Stop();
                callback.Done((int)watcher.ElapsedMilliseconds);
                return "成功";
            }
            catch 
            {
                return "失敗";
            }
        }
    }
}

下面，我們來看一下，如何創建承載服務的應用程序，首先在app.config做如下配置

而Host的代碼如下：

而客戶端的配置文件，如下：

xml version="1.0" encoding="utf-8" ?>
<configuration>
    <system.serviceModel> 
      <bindings>
            <netTcpBinding>
                <binding name="netTcpBinding" />
            netTcpBinding>
        bindings>
        <client>
            <endpoint address="net.tcp://localhost:6987/Service/duplex" binding="netTcpBinding"
                bindingConfiguration="netTcpBinding" contract="Jillzhang.Messaging.Contract.IJob"
                name="NetTcpBinding">
                <identity>
                    <dns value="localhost" />
                identity>
            endpoint>
            <endpoint address="net.tcp://localhost:6987/Service/oneway" binding="netTcpBinding"
                bindingConfiguration="netTcpBinding" contract="Jillzhang.Messaging.Contract.IOneWayJob"
                name="NetTcpBinding">
                <identity>
                    <dns value="localhost" />
                identity>
            endpoint>
          <endpoint address="net.tcp://localhost:6987/Service/normal" binding="netTcpBinding"
          bindingConfiguration="netTcpBinding" contract="Jillzhang.Messaging.Contract.INormalJob"
          name="NetTcpBinding">
            <identity>
              <dns value="localhost" />
            identity>
          endpoint>
        client>
    system.serviceModel>
configuration>

需要注意的是:在設定Duplex模式時，如果服務端采用的是WsDualHttpBinding,而不是本文中的NetTcpBinding，最好指定以下clientBaseAddress,默認情況下，clientBaseAddress會嘗試用８０端口，可通常情況８０端口都是被占用，你需要設置一個其他端口。

因為回調的Contract實現是在客戶端的，所以需要在客戶端實現１個ICallback實現，代碼如下：

下面是客戶端調用的代碼：

客戶端代碼
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Jillzhang.Messaging.Contract;

namespace Jillzhang.Messaging.Client
{
    class Program
    {
        static void Main(string[] args)
        {
            Program p = new Program();
            p.OneWayCall();
            p.NormalCall();
            p.DuplexCall();
            Console.Read();
        }

        void DuplexCall()
        {
            try
            {
                MyCallback callback = new MyCallback();
                IJob ws = new JobClient(new System.ServiceModel.InstanceContext(callback));
                Console.WriteLine("--------------------Duplex Calls ---------------------------");
                Console.WriteLine("開始調用服務");
                string result = ws.Do("duplex job");
                Console.WriteLine("收到返回信息：" + result);
                Console.WriteLine("-------------------------------------------------------------");
                Console.WriteLine("\r\n\r\n\r\n");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        void OneWayCall()
        {
            try
            {
                Console.WriteLine("-----------------------One-Way Calls-----------------------");
                IOneWayJob ws = new OneWayJobClient();
                ws.Do("one-way job");
                Console.WriteLine("請求完成！");
                Console.WriteLine("-------------------------------------------------------------");
                Console.WriteLine("\r\n\r\n\r\n");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        void NormalCall()
        {
            try
            {
                Console.WriteLine("-----------------------Request/Reply Calls-----------------------");
                INormalJob ws = new NormalJobClient();
                string result = ws.Do("request/reply job");
                Console.WriteLine("請求完成,返回結果："+result);
                Console.WriteLine("-------------------------------------------------------------");
                Console.WriteLine("\r\n\r\n\r\n");
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
    }
}

首先運行服務承載程序Jillzhang.Messaging.Host,然后運行客戶端

會產生如下的結果：

服務端運行解圖

客戶端運行解圖：

本文參考資料　

1. http://msdn.microsoft.com/msdnmag/issues/06/10/wcfessentials/default.aspx
2. http://www.rainsts.net/article.asp?id=428

本文相關示例文件

示例項目：/Files/jillzhang/Jillzhang.Messaging.rar