wcf 双向 java_我的WCF之旅 (11): 再谈WCF的双向通讯-基于Http的双向通讯 V.S. 基于TCP的双向通讯...
在一个基于面向服务的分布式环境中,借助一个标准的、平台无关的Communication Infrastructure,各个Service通过SOAPMessage实现相互之间的交互。这个交互的过程实际上就是Message Exchange的过程。WCF支持不同形式的MessageExchange,我们把这称之为Message Exchange Pattern(MEP), 常见的MEP包括:Request/Reply,Request/Forget(One-way)和Duplex。通过采用DuplexMEP,我们可以实现在Service端CallbackClient的操作。虽然WCF为我们实现底层的通信细节,使得我们把精力转移到业务逻辑的实现,进行Transport无关的编程,但是对底层Transport的理解有利于我们根据所处的具体环境选择一个合适的Transport。说到Transport, WCF经常使用的是以下4个:Http,TCP,NamedPipe,MSMQ。由于不同协议自身的差异,他们对具体MEP的支持方式也会不同,我们今天就来谈谈Http和TCP对Duplex的支持。
一、Sample
为了使大家对在WCF如何实现双向通信(Bidirectional Communication)有一个直观的理解,我们先来看一个简单的Sample。我们照例采用下面的4层结构和Calculator的例子:
1.Contract:Artech.DuplexWCF.Contract. ICalculator
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingSystem.ServiceModel;
namespaceArtech.DuplexWCF.Contract
{
[ServiceContract(CallbackContract=typeof(ICallback))]
publicinterfaceICalculator
{
[OperationContract(IsOneWay=true)]
voidAdd(doublex,doubley);
}}
由于模拟的是通过Callback来显示Add方法计算的结果,我把Add Operation设置成One-way。在Service Contract中设置了CallbackContract,Callback Contract定义在Interface Artech.DuplexWCF.Contract.ICallback中:
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingSystem.ServiceModel;
namespaceArtech.DuplexWCF.Contract
{
[ServiceContract]
publicinterfaceICallback
{
[OperationContract(IsOneWay=true)]
voidDisplayResult(doubleresult);
}}
2.Service: Artech.DuplexWCF.Service. CalculatorService
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingArtech.DuplexWCF.Contract;
usingSystem.ServiceModel;
namespaceArtech.DuplexWCF.Service
{
publicclassCalculatorService:ICalculator
{
ICalculator Members#regionICalculator Members
publicvoidAdd(doublex,doubley)
{
doubleresult=x+y;
ICallback callback=OperationContext.Current.GetCallbackChannel();
callback.DisplayResult(result);
}
#endregion }}
在Service端,通过OperationContext.Current.GetCallbackChannel来获得Ciient指定的CallbackContext instance,进而调用Client的Operation。
3.Hosting:
Configuration:
<?xml version="1.0" encoding="utf-8"?>
我们通过netTcpBinding来模拟基于TCP的双向通信。
Program:
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingSystem.ServiceModel;
usingArtech.DuplexWCF.Service;
namespaceArtech.DuplexWCF.Hosting
{
classProgram
{
staticvoidMain(string[] args)
{
using(ServiceHost calculatorHost=newServiceHost(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"?> bindingConfiguration=""contract="Artech.DuplexWCF.Contract.ICalculator" name="defaultEndpoint"/>
Callback:Artech.DuplexWCF.Client. CalculatorCallback
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingArtech.DuplexWCF.Contract;
namespaceArtech.DuplexWCF.Client
{
publicclassCalculatorCallback:ICallback
{
ICallback Members#regionICallback Members
publicvoidDisplayResult(doubleresult)
{
Console.WriteLine("The result is {0}", result);
}
#endregion }}
Callback的操作-显示计算结果,实现在Artech.DuplexWCF.Client. CalculatorCallback中,他实现了在Contract中定义的CallbackContract:Artech.DuplexWCF.Contract. ICallback。
Program:
usingSystem;
usingSystem.Collections.Generic;
usingSystem.Text;
usingArtech.DuplexWCF.Contract;
usingSystem.ServiceModel;
namespaceArtech.DuplexWCF.Client
{
classProgram
{
staticvoidMain(string[] args)
{
DuplexChannelFactorychannelFactory=newDuplexChannelFactory(newInstanceContext(newCalculatorCallback()),"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!\n\t:Type:{0}\n\tMessage:{1}", ex.GetType(), ex.Message);
}
Console.Read();
} }}
在创建DuplexChannelFactory< ICalculator>中,指定了Callback Context Instance:一个实现了Callback Contract的CalculatorCallback对象。该对象在Service中通过OperationContext.Current.GetCallbackChannel()获得。
通过运行程序:
2. 基于Http的双向通讯V.S.基于TCP的双向通讯
由于Http和TCP在各自协议上的差异,他们实现双向通信的发式是不同的。
Http是一个应用层的协议,它的主要特征就是无连接和无状态(connectless & stateless)。它采用传统的Request/Reply的方式进行通信,Client发送HttpRequest请求Server的某个资源,Server端接收到该Http Request, 回发对应的HttpResponse。当Client端接收到对应的Response,该Connection会关闭。也就是说Client和Server的Connection仅仅维持在发送Request到接收到Response这一段时间内。同时,每次基于Http的connection是相互独立,互不相干的,当前connection无法获得上一次connection的状态。为了保存调用的的状态信息,ASP.NET通过把状态信息保存在Server端的方式实现了对Session的支持,具体的做法是:ASP.NET为每个Session创建一个Unique ID,与之关联一个HttpSessionState对象,并把状态信息保存在内存中或者持久的存储介质(比如SQLServer)中。而WCF则采用另外的方式实现对Session的支持:每个Session关联到某个Service Instance上。
回到我们WCF双向通信的问题上,当Client调用Service之前,会有一个Endpoint在Client端被创建,用于监听Service端对它的Request。Client对Service的调用会建立一个Client到Server的Connection,当Service在执行操作过程中需要Callback对应的Client,实际上会建立另一个Service到Client的Httpconnection。虽然我们时候说WCF为支持双向通信提供Duplex Channel,实际上这个Duplexchannel是由两个Request/Reply Channel组成的。
而对于TCP/IP簇中的传输层协议TCP,它则是一个基于Connection的协议,在正式进行数据传输的之前,必须要在Client和Server之后建立一个Connection,Connection的建立通过经典的“3次握手”来实现。TCP天生就具有Duplex的特性,也就是说当Connection被创建之后,从Client到Sever,和从Server到Client的数据传递都可以利用同一个Connection来实现。对于WCF中的双向通信,Client调用Service,Service CallbackClient使用的都是同一个Connection、同一个Channel。所以基于TCP的DuplexChannel才是真正意义上的Duplex Channel。
wcf 双向 java_我的WCF之旅 (11): 再谈WCF的双向通讯-基于Http的双向通讯 V.S. 基于TCP的双向通讯...相关推荐
- 我的WCF之旅 (11): 再谈WCF的双向通讯-基于Http的双向通讯 V.S. 基于TCP的双向通讯...
在一个基于面向服务的分布式环境中,借助一个标准的.平台无关的Communication Infrastructure,各个Service通过SOAP Message实现相互之间的交互.这个交互的过程实 ...
- WCF后续之旅(11): 关于并发、回调的线程关联性(Thread Affinity)
对于一般的多线程操作,比如异步地进行基于文件系统的IO操作:异步地调用Web Service:或者是异步地进行数据库访问等等,是和具体的线程无关的.也就是说,对于这些操作,任意创建一个新的线程来执行都 ...
- WCF探索之旅(五)——WCF与WebService的异同
前几篇文章我们简单的介绍了WCF以及怎样使用它,今天我们来讨论一下WCF和WebService的异同. 相信大多数同学跟我一样,对于WebService有所了解.并且应该说你是先听说WebServic ...
- 多线程之旅之四——浅谈内存模型和用户态同步机制
用户态下有两种同步结构的 volatile construct: 在简单数据类型上原子性的读或者写操作 interlocked construct:在简单数据类型上原子性的读和写操作 (在这里还 ...
- 基于ANSYS 2019R1全解一款双吸泵的双向流固耦合方法
作者:李雷 一.导读 对于旋转机械来说,传统设计从理论计算到手工木模图,再到模型泵的加工制造,最后进行相关性能试验.当性能试验与预期效果差距较大的时候还需要修改水力模型.这种传统的设计不仅设计周期长, ...
- Linux 之旅 11:Linux 账号管理与 ACL 权限设置
Linux 之旅 11:Linux 账号管理与 ACL 权限设置 Linux 的账号与用户组 使用者识别码:UID与GID 关于Linux的账号管理,有两个数字最为重要: UID:(User ID), ...
- WCF系列之.net(4.0) 在网站使用Js调用Wcf Rest
上一篇,我们介绍了如何使用JS去调用WCF.但实际开发中,各大网站的API都是REST风格,那我们也REST下,顺便用JS调用. 废话不多说,我就把几个比较重要的代码贴下: 接口: using Sys ...
- IOS调用WCF提供的服务方法,但是方法的参数是WCF那边自定义的对象,这样有办法调用么,如果可以IOS应该怎么传参呢?请问有了解的么,...
最近做一个项目后端使用WCF接收Android手机拍照并带其它参数保存到服务器里:刚好把最近学习的WCF利用上,本以为是个比较简单的功能应该很好实现,没想到其中碰到不少问题,在网上搜索很久一直没有想到 ...
- 骑士 java_在递归骑士之旅中正确声明变量(Java作业)
我在学年的最后一个项目(我作为CS学生的第一年)的代码中找不到错误.在执行骑士巡回赛问题时,我一直坚持递归.这是有问题的文件: https://github.com/sheagunther/tsp16 ...
- c#物联网_基于C#实现日志记录与SQL SERVER的双向存储工控数字化之旅
↑ 点击上方 "智能制造之家" 关注我们 写在前面 我们在做一些PLC设备联网改造.SCADA项目.MES项目等的时候,我们经常需要做日志记录,这样便于后续做日志分析及错误追踪.比 ...
最新文章
- COS 访谈第 19 期:张志华教授
- 程序员修炼之道-笔记
- jstat 内存泄漏_基于Java内存dump文件分析解决内存泄漏问题
- Divan and Kostomuksha (easy version) dp,gcd(2100)
- springboot链接MySQL线程池_SpringBoot中的数据库连接池
- python gil锁存在的意义_关于python的GIL全局解释器锁的简单理解
- lora模块在牛联网和智慧农业中的应用案列
- python数据运算
- django批量修改table_python中Django视图(view)的详解(附示例)
- 为什么环境变量中设置了JDK版本为1.7,但是在cmd中java -version 是1.8版本
- 从排序开始(三)归并排序
- dotween的数值变化_Unity-Dotween
- e580显卡驱动_联想e580显卡驱动下载-联想e580笔记本显卡驱动v25.20.15012.2005 官方版 - 极光下载站...
- 如何在产品经理工作面试中回答估算问题
- TypeScript查缺补漏
- 进不了字节,腾讯等大厂没学历的程序员应该如何生存?
- 树莓派4B简单使用内容(以移植QT应用为例)
- ESP32-C3——专为物联网应用场景设计
- JAVA个人博客系统毕业设计,个人博客系统设计与实现,个人博客网页设计毕设作品
- 计算机磁盘的卷是什么意思,新加卷和本地磁盘有什么区别