SQL ServerWCF学习之旅—TCP双工形式(二十一)

                WCF学习之旅—请求与应对方式和单向情势(十九)

                WCF学习之旅—HTTP双工格局(二十)

 

五、TCP双工形式

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

     
在一个依据面向服务的分布式环境中,借助一个正经的、平台毫无干系的通信协议,使各种服务通过SOAP
Message落成互相之间的互动。这一个互动的进程实际上就是音讯交流的进度。WCF帮忙不相同方式的音讯沟通,大家把这称为音信置换方式(Message
Exchange Pattern(简称MEP),下同), 常见的MEP包涵:
请求/答复,单向情势和双工形式。通过使用双工的MEP,大家得以兑现在服务端调用客户端的操作。就算WCF为大家得以实现底层的通信细节,使得大家把精力转移到事情逻辑的贯彻,举行与通信协议无关的编程,可是对通信协议的接头有利于我们按照所处的实际条件采纳一个相宜的通信协议。说到通信协议,
WCF 日常选拔的是以下4个: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>的功能都是一个劳务代办对象的创导工厂,然则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)(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的
连接是互为独立,互不相干的,当前总是不可以获取上四遍屡次三番的情形。为了保留调用的的情事新闻,ASP.NET通过把情形音讯保存在服务端的Session之中,具体的做法是:ASP.NET为各样Session创立一个
Unique
ID,与之提到一个HttpSessionState对象,并把状态信息保存在内存中或者持久的存储介质(比如SQL
Server)中。而WCF则利用其它的主意贯彻对Session的支持:每个Session关联到某个瑟维斯(Service)(Service)Instance上。

      
我们来讲一下HTTP双向通信的历程,当客户端通过HTTP请求调用WCF服务以前,会有一个终结点在客户端被创建,用于监听服务端对它的Request。客户端对
WCF服务的调用会建立一个客户端到服务端的连日,当WCF服务在实施操作进度中须求回调对应的客户端,实际上会成立另一个服务端到客户端的Http
连接。虽然我们时候说WCF为支撑双向通信提供一个双工通道,实际上这些双工通道是由四个HTTP连接组成的。

     
再来看一下TCP的双向通信的经过,对于TCP传输层协议,它则是一个依据连接的磋商,在业内开展多少传输的事先,必必要在客户端和服务端之间确立一个接连,连接的创建通过经典的“3次握手”来贯彻。TCP天生就具备双工的特色,也就是说当连接
被创建之后,从客户端到服务端,和从服务端到客户端的多少传递都得以行使同一个总是来已毕。对于WCF中的双向通信,客户端调用服务端,服务端回调客户端的操作使用的都是同一个接连、同一个大路。所以按照TCP的双工通信格局才是真的含义上的双工通信情势。

 

相关文章