WCF TCP双工模式详解介绍

        }

    }

}
在服务端，通过OperationContext.Current.GetCallbackChannel来获得客户端指定的CallbackContext 实例，进而调用客户端的操作。

3 ． Hosting ：

宿主配置文件:

 
 
   
              logMessagesAtServiceLevel="true" logMessagesAtTransportLevel="true" />
              messageFlowTracing="true" />
   
 

   
     
                contract="Contracts.IBookService" />

     
   
 

我们通过netTcpBinding来模拟基于TCP的双向通信。代码如下：

using Contracts;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Text;
using System.Threading.Tasks;
using WcfServiceLib;

namespace ConsoleHosting
{

    class Program
    {

        static void Main(string[] args)
        {
            Console.WriteLine("输入启动方式，C--Code A -- App.config方式！");
            string key = Console.ReadLine();
            switch (key)
            {
                case "C":
                    StartByCode();
                    break;
                case "A":
                    StartByConfig();
                    break;
                default:
                    Console.WriteLine("没有选择启动方式，使用默认方式");
                    StartByCode();
                    break;

            }
        }

        private static void StartByCode()
        {

            //创建宿主的基地址
            Uri baseAddress = new Uri("http://localhost:8080/BookService");
            //创建宿主
            using (ServiceHost host = new ServiceHost(typeof(BookService), baseAddress))
            {

                //向宿主中添加终结点
                host.AddServiceEndpoint(typeof(IBookService), new WSDualHttpBinding(), baseAddress);
                if (host.Description.Behaviors.Find() == null)

                {
                    //将HttpGetEnabled属性设置为true
                    ServiceMetadataBehavior behavior = new ServiceMetadataBehavior();
                    behavior.HttpGetEnabled = true;
                    behavior.HttpGetUrl = baseAddress;
                    //将行为添加到Behaviors中

                    host.Description.Behaviors.Add(behavior);
                    //打开宿主

                    host.Opened += delegate
                    {
                        Console.WriteLine("BookService控制台程序寄宿已经启动，HTTP监听已启动....，按任意键终止服务！");
                    };

                    host.Open();
                    //print endpoint information                 

                    Console.ForegroundColor = ConsoleColor.Yellow;
                    foreach (ServiceEndpoint se in host.Description.Endpoints)
                    {
                        Console.WriteLine("[终结点]: {0}rnt[A-地址]: {1} rnt [B-绑定]: {2} rnt [C-协定]: {3}",
                     se.Name, se.Address, se.Binding.Name, se.Contract.Name);
                    }
                    Console.Read();
                }
            }

        }

        private static void StartByConfig()
        {
            using (ServiceHost host = new ServiceHost(typeof(BookService)))
            {
                host.Opened += delegate
                {

                    Console.WriteLine("BookService控制台程序寄宿已经启动，TCP监听已启动....，按任意键终止服务！");
                };

                host.Open();
                //print endpoint information                

                Console.ForegroundColor = ConsoleColor.Yellow;
                foreach (ServiceEndpoint se in host.Description.Endpoints)
                {
                    Console.WriteLine("[终结点]: {0}rnt[A-地址]: {1} rnt [B-绑定]: {2} rnt [C-协定]: {3}",
                 se.Name, se.Address, se.Binding.Name, se.Contract.Name);
 
                }

                Console.Read();
            }

        }

    }

}

 
4 ．客户端：

配置文件中的信息进行修改:

                 bindingConfiguration="" contract="Contracts.IBookService"

                 name="BookServiceEndpoint" />
       
   
接下来实现对双工服务的调用，下面是相关的配置和托管程序。在服务调用程序中，通过 DuplexChannelFactory创建服务代理对 象，DuplexChannelFactory和ChannelFactory的功能 都是一个服务代理对象的创建工厂，不过DuplexChannelFactory专门用于基于双工通信的服务代理的创 建。在创建DuplexChannelFactory之前，先创建回调对象，并通过InstanceContext对回 调对象进行包装。代码如下：

private void btnTcpDuplex_Click(object sender, EventArgs e)
        {

            DuplexChannelFactory channelFactory = new DuplexChannelFactory(instanceContext, "BookServiceEndpoint");
            IBookService client = channelFactory.CreateChannel();

            //在BookCallBack对象的mainThread(委托)对象上搭载两个方法，在线程中调用mainThread对象时相当于调用了这两个方法。

            textBox1.Text += string.Format("开始调用wcf服务：{0}rnrn", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));

            client.DisplayName("TCP---科学可以这样看丛书");

            textBox1.Text += string.Format("rnrn调用结束：{0}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
        }
在创建 DuplexChannelFactory< IBookService >中，指定了Callback Context Instance: 一个实现了Callback Contract的BookCallBack对象。该对象在Service中通过 OperationContext.Current.GetCallbackChannel()获得。

通过运行程序之后的结果如下图:

  2. 基于 Http 的双向通讯 V.S. 基于 TCP 的双向通讯

由于Http和TCP在各自协议上的差异，他们实现双向通信的发式是不同的。

Http是一个应用层的协议，它的主要特征就是无连接和无状态。它采用传统的“请求/回复”的方式进行通信，客户端发送Http Request请求服务端的某个资源，服务端接收到该Http Request, 回发对应的Http Response。当客户端接收到对应的Response，该连接就会关闭。也就是说客户端和服务端的 连接仅仅维持在发送Request到接收到Response这一段时间内。同时，每次基于Http的 连接是相互独立，互不相干的，当前连接无法获得上一次连接的状态。为了保存调用的的状态信 息，ASP.NET通过把状态信息保存在服务端的Session之中，具体的做法是：ASP.NET为每个Session创建一个 Unique ID，与之关联一个HttpSessionState对象，并把状态信息保存在内存中或者持久的存储介质（比如SQL Server）中。而WCF则采用另外的方式实现对Session的支持：每个Session关联到某个Service Instance上。

我们来讲一下HTTP双向通信的过程，当客户端通过HTTP请求调用WCF服务之前，会有一个终结点在客户端被创建，用于监听服务端对它的Request。客户端对 WCF服务的调用会建立一个客户端到服务端的连接，当WCF服务在执行操作过程中需要回调对应的客户端，实际上会建立另一个服务端到客户端的Http 连接。虽然我们时候说WCF为支持双向通信提供一个双工通道，实际上这个双工通道是由两个HTTP连接组成的。

再来看一下TCP的双向通信的过程，对于TCP传输层协议，它则是一个基于连接的协议，在正式进行数据传输的之前，必须要在客户端和服务端之间建立一个连接，连接的建立通过经典的“3次握手”来实现。TCP天生就具有双工的特性，也就是说当连接 被创建之后，从客户端到服务端，和从服务端到客户端的数据传递都可以利用同一个连接来实现。对于WCF中的双向通信，客户端调用服务端，服务端回调客户端的操作使用的都是同一个连接、同一个通道。所以基于TCP的双工通信模式才是真正意义上的双工通信模式。