我的WCF之旅 (11): 再谈WCF的双向通讯-基于Http的双向通讯 V.S. 基于TCP的双向通讯
在一个基于面向服务的分布式环境中,借助一个标准的、平台无关的Communication Infrastructure,各个Service通过SOAP Message实现相互之间的交互。这个交互的过程实际上就是Message Exchange的过程。WCF支持不同形式的Message Exchange,我们把这称之为Message Exchange Pattern(MEP), 常见的MEP包括: Request/Reply,Request/Forget(One-way)和Duplex。通过采用Duplex MEP,我们可以实现在Service端Callback Client的操作。虽然WCF为我们实现底层的通信细节,使得我们把精力转移到业务逻辑的实现,进行Transport无关的编程,但是对底层Transport的理解有利于我们根据所处的具体环境选择一个合适的Transport。说到Transport, WCF 经常使用的是以下4个:Http,TCP,Named Pipe,MSMQ。由于不同协议自身的差异,他们对具体MEP的支持方式也会不同,我们今天就来谈谈Http和TCP对Duplex的支持。
一、Sample
为了使大家对在WCF如何实现双向通信(Bidirectional Communication)有一个直观的理解,我们先来看一个简单的Sample。我们照例采用下面的4层结构和Calculator的例子:
1.Contract:Artech.DuplexWCF.Contract. ICalculator
using System;using System.Collections.Generic;using System.Text;using System.ServiceModel;namespace Artech.DuplexWCF.Contract{ [ServiceContract(CallbackContract = typeof(ICallback))] public interface ICalculator { [OperationContract(IsOneWay = true)] void Add(double x, double y); }}
由于模拟的是通过Callback来显示Add方法计算的结果,我把Add Operation设置成One-way。在Service Contract中设置了Callback Contract,Callback Contract定义在Interface Artech.DuplexWCF.Contract. ICallback中:
using System;using System.Collections.Generic;using System.Text;using System.ServiceModel;namespace Artech.DuplexWCF.Contract{ [ServiceContract] public interface ICallback { [OperationContract(IsOneWay = true)] void DisplayResult(double result); }}
2.Service: Artech.DuplexWCF.Service. CalculatorService
using System;using System.Collections.Generic;using System.Text;using Artech.DuplexWCF.Contract;using System.ServiceModel;namespace Artech.DuplexWCF.Service{ public class CalculatorService:ICalculator { ICalculator Members#region ICalculator Members public void Add(double x, double y) { double result = x + y; ICallback callback = OperationContext.Current.GetCallbackChannel<ICallback>(); callback.DisplayResult(result); } #endregion }}
在Service端,通过OperationContext.Current.GetCallbackChannel来获得Ciient指定的CallbackContext instance,进而调用Client的Operation。
3.Hosting:
Configuration:
<?xml version="1.0" encoding="utf-8" ?><configuration> <system.serviceModel> <services> <service name="Artech.DuplexWCF.Service.CalculatorService"> <endpoint address="net.tcp://localhost:9999/calculator" binding="netTcpBinding" contract="Artech.DuplexWCF.Contract.ICalculator" /> </service> </services> </system.serviceModel></configuration>
我们通过netTcpBinding来模拟基于TCP的双向通信。
Program:
using System;using System.Collections.Generic;using System.Text;using System.ServiceModel;using Artech.DuplexWCF.Service;namespace Artech.DuplexWCF.Hosting{ class Program { static void Main(string[] args) { using (ServiceHost calculatorHost = new ServiceHost(typeof(CalculatorService))) { calculatorHost.Opened += delegate { Console.WriteLine("The calculator service has begun to listen"); }; calculatorHost.Open(); Console.Read(); } } }}
4.Client:
Configuration:
<?xml version="1.0" encoding="utf-8" ?><configuration> <system.serviceModel> <client> <endpoint address="net.tcp://localhost:9999/calculator" binding="netTcpBinding" bindingConfiguration="" contract="Artech.DuplexWCF.Contract.ICalculator" name="defaultEndpoint" /> </client> </system.serviceModel></configuration>
Callback:Artech.DuplexWCF.Client. CalculatorCallback
using System;using System.Collections.Generic;using System.Text;using Artech.DuplexWCF.Contract;namespace Artech.DuplexWCF.Client{ public class CalculatorCallback:ICallback { ICallback Members#region ICallback Members public void DisplayResult(double result) { Console.WriteLine("The result is {0}", result); } #endregion }}
Callback的操作-显示计算结果,实现在Artech.DuplexWCF.Client. CalculatorCallback中,他实现了在Contract中定义的Callback Contract:Artech.DuplexWCF.Contract. ICallback。
Program:
using System;using System.Collections.Generic;using System.Text;using Artech.DuplexWCF.Contract;using System.ServiceModel;namespace Artech.DuplexWCF.Client{ class Program { static void Main(string[] args) { DuplexChannelFactory<ICalculator> channelFactory = new DuplexChannelFactory<ICalculator>(new InstanceContext(new CalculatorCallback()),"defaultEndpoint"); ICalculator calculator = channelFactory.CreateChannel(); Console.WriteLine("Try to invoke the Add method"); try { calculator.Add(1, 2); } catch (Exception ex) { Console.WriteLine("An Exception is thrown!nt:Type:{0}ntMessage:{1}", ex.GetType(), ex.Message); } Console.Read(); } }}
在创建DuplexChannelFactory< ICalculator>中,指定了Callback Context Instance: 一个实现了Callback Contract的CalculatorCallback 对象。该对象在Service中通过OperationContext.Current.GetCallbackChannel<ICallback>()获得。
通过运行程序:
2. 基于Http的双向通讯V.S.基于TCP的双向通讯
由于Http和TCP在各自协议上的差异,他们实现双向通信的发式是不同的。
Http是一个应用层的协议,它的主要特征就是无连接和无状态(connectless & stateless )。它采用传统的Request/Reply的方式进行通信,Client发送Http Request请求Server的某个资源,Server端接收到该Http Request, 回发对应的Http Response。当Client端接收到对应的Response,该Connection会关闭。也就是说Client和Server的Connection仅仅维持在发送Request到接收到Response这一段时间内。同时,每次基于Http的 connection是相互独立,互不相干的,当前connection无法获得上一次connection的状态。为了保存调用的的状态信息,ASP.NET通过把状态信息保存在Server端的方式实现了对Session的支持,具体的做法是:ASP.NET为每个Session创建一个Unique ID,与之关联一个HttpSessionState对象,并把状态信息保存在内存中或者持久的存储介质(比如SQL Server)中。而WCF则采用另外的方式实现对Session的支持:每个Session关联到某个Service Instance上。
回到我们WCF双向通信的问题上,当Client调用Service之前,会有一个Endpoint在Client端被创建,用于监听Service端对它的Request。Client对Service的调用会建立一个Client到Server的Connection,当Service在执行操作过程中需要Callback对应的Client,实际上会建立另一个Service到Client的Http connection。虽然我们时候说WCF为支持双向通信提供Duplex Channel,实际上这个Duplex channel是由两个Request/Reply Channel组成的。
而对于TCP/IP簇中的传输层协议TCP,它则是一个基于Connection的协议,在正式进行数据传输的之前,必须要在Client和Server之后建立一个Connection,Connection的建立通过经典的“3次握手”来实现。TCP天生就具有Duplex的特性,也就是说当Connection被创建之后,从Client到Sever,和从Server到Client的数据传递都可以利用同一个Connection来实现。对于WCF中的双向通信,Client调用Service,Service Callback Client使用的都是同一个Connection、同一个Channel。所以基于TCP的Duplex Channel才是真正意义上的Duplex Channel。
- 【学术】将吴恩达的第一个深度神经网络应用于泰坦尼克生存数据集
- 使用 HttpClient 调用 Restful 接口
- 元宵佳节:看Oracle技术粉们用SQL画团圆
- java 脚本引擎
- 不怕学不会 使用TensorFlow从零开始构建卷积神经网络
- 微信公众平台增加批量获取用户基本信息接口
- 谈网络适配器
- 【框架】为降低机器学习开发者门槛,苹果发布了Turi Create框架
- 新闻数据库分表案例
- 建立智能的解决方案:将TensorFlow用于声音分类
- Plugin Hook 设计与实现
- 数据与应用程序间通信·UDP Socket
- Java 数据类型转换
- Spring boot with Scheduling
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- PHP中__set()实例用法和基础讲解
- laravel框架分组控制器和分组路由实现方法示例
- 使用swoole 定时器变更超时未支付订单状态的解决方案
- Yii2 queue的队列使用详解
- ThinkPHP5+jQuery+MySql实现投票功能
- Smarty模板配置实例简析
- php利用ZipArchive类操作文件的实例
- Yii框架页面渲染操作实例详解
- PHP数据源架构模式之表入口模式实例分析
- PHP pthread拓展使用和注意点
- centos6.5下安装zabbix2.4的教程图解
- php经典趣味算法实例代码
- centos7 设置grub密码及单用户登录实例代码
- php面向对象基础详解【星际争霸游戏案例】
- Linux系统下Nginx支持ipv6配置的办法