SQL ServerWCF学习之旅—TCP双工情势(二十一)

                WCF学习之旅—请求与回复模式和单向形式(十九)

                WCF学习之旅—HTTP双工情势(二十)

 

5、TCP双工形式

    
上一篇小说中大家上学了HTTP的双工情势,大家前日就学习一下TCP的双工形式。

     
在三个依据面向服务的分布式环境中,借助二个正式的、平台非亲非故的通讯协议,使种种服务通过SOAP
Message实现互动的交互。那么些互动的进度实际上就是音讯置换的进度。WCF帮忙差别样式的消息置换,大家把那称为音讯置换格局(Message
Exchange Pattern(简称MEP),下同), 常见的MEP包罗:
请求/答复,单向格局和双工方式。通过运用双工的MEP,大家能够达成在服务端调用客户端的操作。即使WCF为我们贯彻底层的通讯细节,使得大家把精力转移到工作逻辑的落到实处,实行与通信协议非亲非故的编制程序,不过对通讯协议的精通有利于大家遵照所处的切实条件选取三个适度的通讯协议。说到通讯协议,
WCF 平日选用的是以下三个:Http,TCP,Named Pipe,MSMQ。

      大家用上一篇章( WCF学习之旅—HTTP双工形式(二十))中的示例,进行一下修改,变成二个TCP双向通讯的WCF服务应用程序。上面直接上代码。


1.Contract

 

using Contracts;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text; 

namespace Contracts
{

    // 注意: 使用“重构”菜单上的“重命名”命令,可以同时更改代码和配置文件中的接口名“IBookService”。
    [ServiceContract(CallbackContract = typeof(ICallback))]
    public interface IBookService
    {

       /// <summary>
       /// 请求与答复模式,默认模式
       /// </summary>
       /// <param name="Id">书籍ID</param>
       /// <returns></returns>
        [OperationContract]
        string GetBook(string Id);
        /// <summary>

        /// 单工模式,显示名称
        /// </summary>
        /// <param name="name">书籍名称</param>
        [OperationContract(IsOneWay = true)]
        void ShowName(string name);
        /// <summary>
        /// 双工模式,显示名称
        /// </summary>
        /// <param name="name">书籍名称</param>
        [OperationContract(IsOneWay = true)]
        void DisplayName(string name);


    }

}





using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text; 

namespace Contracts
{ 

    public interface ICallback
    {

        [OperationContract(IsOneWay = true)]
        void DisplayResult(string result);

    }
}

 

 

2.WcfServiceLib

using Contracts;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;


namespace WcfServiceLib
{

    // 注意: 使用“重构”菜单上的“重命名”命令,可以同时更改代码、svc 和配置文件中的类名“BookService”。

    // 注意: 为了启动 WCF 测试客户端以测试此服务,请在解决方案资源管理器中选择 BookService.svc 或 BookService.svc.cs,然后开始调试。
    public class BookService : IBookService
    {

        /// <summary>
        /// 请求与答复模式,默认模式
        /// </summary>
        /// <param name="Id">书籍ID</param>
        /// <returns></returns>
        public string GetBook(string Id)
        {

            System.Threading.Thread.Sleep(20000);
            int bookId = Convert.ToInt32(Id);
            Books book = SetBook(bookId);
            string xml = XMLHelper.ToXML<Books>(book);
            return xml; 

        }



        public Books SetBook(int Id)
        {

            Books book = new Books();
            book.BookID = Id;
            book.AuthorID = 1;
            book.Category = "IBM";
            book.Price = 39.99M;
            book.Numberofcopies = 25;
            book.Name = "DB2数据库性能调整和优";
            book.PublishDate = new DateTime(2015, 2, 23);
            return book;
        }

        /// <summary>
        /// 单工模式,显示名称
        /// </summary>
        /// <param name="name">名称</param>
        public void ShowName(string name)
        {

            string result = string.Format("书籍名称:{0},日期时间{1}", name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
            Console.WriteLine("\r\n" + result);          

        }

        /// <summary>
        /// 双工模式,回调显示结果
        /// </summary>
        /// <param name="name">名称</param>
        public void DisplayName(string name)
        {
            string result=string.Format("书籍名称:{0},日期时间{1}", name, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
            Console.WriteLine("\r\n" + result);
            ICallback call = OperationContext.Current.GetCallbackChannel<ICallback>();
            call.DisplayResult("回调客户端---"+result);

        }

    }

}

 

     
在服务端,通过OperationContext.Current.GetCallbackChannel来赢得客户端钦点的CallbackContext
实例,进而调用客户端的操作。

3.Hosting:

宿主配置文件:

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />

  </startup>
  <system.serviceModel>
    <diagnostics>
      <messageLogging logEntireMessage="true" logKnownPii="false" logMalformedMessages="true"
        logMessagesAtServiceLevel="true" logMessagesAtTransportLevel="true" />
      <endToEndTracing propagateActivity="true" activityTracing="true"
        messageFlowTracing="true" />
    </diagnostics>


    <services>
      <service  name="WcfServiceLib.BookService">
        <endpoint address="net.tcp://127.0.0.1:9999/BookService" binding="netTcpBinding"
        contract="Contracts.IBookService" />

      </service>
    </services>
  </system.serviceModel>
</configuration>

 

 

     
咱们通过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<ServiceMetadataBehavior>() == 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}\r\n\t[A-地址]: {1} \r\n\t [B-绑定]: {2} \r\n\t [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}\r\n\t[A-地址]: {1} \r\n\t [B-绑定]: {2} \r\n\t [C-协定]: {3}",
                 se.Name, se.Address, se.Binding.Name, se.Contract.Name);

                }

                Console.Read();
            }

        }

    }

}

 

 

4.客户端:

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

  <system.serviceModel>
        <client>
           <endpoint address="net.tcp://localhost:9999/BookService" binding="netTcpBinding"

                 bindingConfiguration="" contract="Contracts.IBookService"

                 name="BookServiceEndpoint" />
        </client>
    </system.serviceModel>

 

     
接下去贯彻对双工服务的调用,上面是不非亲非故系的配置和托管程序。在服务调用程序中,通过
DuplexChannelFactory<TChannel>制造服务代办对
象,DuplexChannelFactory<TChannel>和ChannelFactory<TChannel>的法力
都以1个劳动代办对象的创办工厂,可是DuplexChannelFactory<TChannel>专门用于基于双工通讯的劳务代办的创设。在成立DuplexChannelFactory<TChannel>在此之前,先创建回调对象,并透过InstanceContext对回
调对象开始展览打包。代码如下:

private void btnTcpDuplex_Click(object sender, EventArgs e)
        { 

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



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

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

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

            textBox1.Text += string.Format("\r\n\r\n调用结束:{0}", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
        }

 

       在创建 DuplexChannelFactory<
IBookService >中,钦赐了Callback Context Instance: 三个贯彻了Callback
Contract的BookCallBack对象。该目的在Service中经过
OperationContext.Current.GetCallbackChannel<ICallback>()获得。

因而运行程序之后的结果如下图:

 SQL Server 1

 

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

      
由于Http和TCP在分别协议上的差异,他们完毕双向通讯的发式是见仁见智的。

      
Http是一个应用层的情商,它的严重性特征就是无连接和无状态。它选取守旧的“请求/回复”的不二法门展开通讯,客户端发送Http
Request请求服务端的某部财富,服务端接收到该Http Request, 回发对应的Http
Response。当客户端接收到对应的Response,该连接就会倒闭。也正是说客户端和服务端的
连接仅仅维持在发送Request到接受到Response这一段时间内。同时,每趟基于Http的
连接是相互独立,互不相干的,当前连连不能够赢得上3回接二连三的景观。为了保留调用的的图景新闻,ASP.NET通过把景况音信保存在服务端的Session之中,具体的做法是:ASP.NET为各样Session创设三个Unique
ID,与之提到七个HttpSessionState对象,并把状态音信保存在内部存款和储蓄器中恐怕持久的存款和储蓄介质(比如SQL
Server)中。而WCF则运用其余的办法贯彻对Session的支撑:种种Session关联到有个别ServiceInstance上。

      
大家来讲一下HTTP双向通讯的历程,当客户端通过HTTP请求调用WCF服务以前,会有三个终结点在客户端被创制,用于监听服务端对它的Request。客户端对
WCF服务的调用会建立二个客户端到服务端的连接,当WCF服务在实践操作进程中须要回调对应的客户端,实际上会树立另一个服务端到客户端的Http
连接。纵然大家时候说WCF为支撑双向通讯提供三个双工通道,实际上那个双工通道是由三个HTTP连接组成的。

     
再来看一下TCP的双向通讯的经过,对于TCP传输层协议,它则是2个依据连接的协商,在专业实行数量传输的前头,必须求在客户端和服务端之间确立二个老是,连接的确立通过经典的“三次握手”来贯彻。TCP天生就全数双工的特点,约等于说当连接
被创制之后,从客户端到服务端,和从服务端到客户端的数额传递都能够选择同1个连连来兑现。对于WCF中的双向通讯,客户端调用服务端,服务端回调客户端的操作使用的都以同一个老是、同八个通路。所以据说TCP的双工通信格局才是的确意义上的双工通讯情势。

 

相关文章