基于WCF MSMQ 的企业应用解决方案
2013-11-06 17:24
288 查看
最近研究了一下基于MSMQ的WCF应用,从书上、网上查了很多资料,但始终没能彻底理解WCF-MSMQ的工作原理,也没能得到一个合理的应用解决方案。索性还是自己做个实验,探索一下吧。经过反复试验,颇有收获,现跟大家分享一下。
首先我的解释一下为什么查了那么多资料却未能理解WCF-MSMQ的工作原理,不是各位大牛没有把原理讲清楚,而是大多数给出的例子都是在单机上运行的,这就很难说明白离线工作的原理。
为了说明问题,我用了四台虚机来部署我的实验程序,首先我给大家看一下我的程序部署结构:
4台虚机(红线表示消息流向),它们的操作系统都是Windows2008 R2,并且都需要安装MSMQ服务,否则无法工作。也就是说,如果应用程序客户端发布出去以后,要想实现离线提交,在客户端机器上也必须安装MSMQ服务。
WCF Host (10.222.114.76):这台机器用来运行Service程序,它的主要任务是监听MSMQ Host这台机器上的队列。
MSMQ Host (10.222.114.78):这台机器用来提供消息服务;当然完全可以由这4台机器的任何一台作为MSMQ的消息服务器,我MSMQ Host这台机器是为了说明一个问题,稍后会提到。
WCF Client 1 (10.222.114.77),WCF Client 2 (10.222.114.79):用来运行客户端程序,当然我们可以有无数个客户端。
接下来看一下WCF程序的配置:
服务端
客户端
有一点需要指出,那就是Address。和其它绑定方式不同,使用MSMQ的WCF的地址并不是本机IP(大家可以看到我的WCF Host这台机器的IP是10.222.114.76,像我们常用的basicHttpBingding,WSHttpBingDing等地址指向都是本机地址),而是MSMQ Host那台虚机的IP地址。这就是我为什么把专门用MSMS Host单独拿出来作为消息服务器的原因。另外, queueTransferProtocol="Srmp"用的使用 SOAP 可靠消息传送协议 (SRMP),需要安装HTTP支持,可以直接把它删掉使用默认的Native方式。
这里代码我就不往上贴了,看一下执行过程吧,WCF Client 1,WCF Client 2往MSMQ Host这台机器上发送消息,WCF Host监控MSMQ Host这台机器上的private/myqueue对列,一旦有消息,则把消息提取出来进行处理。下面是我的程序运行结果,在运行程序之前,需要在MSMQ Host上创建一个私有队列private/myqueue。
我们接下来看下离线工作。我们把WCF Client 1的网卡禁用,或者停掉MSMQ Host,会看到以下结果,在Outgonging队列里堆积了很多发不出去的消息。这就是为什么在客户端需要安装MSMQ服务的原因。一旦WCF Client 1与MSMQ Host再次建立连接,在Outgoing队列里的消息就会被发送到MSMQ Host上去。
关闭WCF Host中我们运行的Service程序,这时会看到,在MSMQ Host这台机器上private/myqueue对列中的消息越积越多。等到再次启动Service后,它里面的消息就会被处理掉。
经过上面的实验,可以得到一下结论:WCF Host,MSMQ Host,WCF Client这三台机器任何一台发生故障,应用都是可恢复的,而且数据不会丢失。
接下来我还做了另一个实验,就是在另外一台机器上启动新建的WCF服务程序,发现两个Service都可以去处理同一队列中的消息,从这种意义上来说,这不失是一个负载均衡的一个解决方案。
最后,附上我的实验代码,供大家参考:Msmq.7z
首先我的解释一下为什么查了那么多资料却未能理解WCF-MSMQ的工作原理,不是各位大牛没有把原理讲清楚,而是大多数给出的例子都是在单机上运行的,这就很难说明白离线工作的原理。
为了说明问题,我用了四台虚机来部署我的实验程序,首先我给大家看一下我的程序部署结构:
4台虚机(红线表示消息流向),它们的操作系统都是Windows2008 R2,并且都需要安装MSMQ服务,否则无法工作。也就是说,如果应用程序客户端发布出去以后,要想实现离线提交,在客户端机器上也必须安装MSMQ服务。
WCF Host (10.222.114.76):这台机器用来运行Service程序,它的主要任务是监听MSMQ Host这台机器上的队列。
MSMQ Host (10.222.114.78):这台机器用来提供消息服务;当然完全可以由这4台机器的任何一台作为MSMQ的消息服务器,我MSMQ Host这台机器是为了说明一个问题,稍后会提到。
WCF Client 1 (10.222.114.77),WCF Client 2 (10.222.114.79):用来运行客户端程序,当然我们可以有无数个客户端。
接下来看一下WCF程序的配置:
服务端
<system.serviceModel> <bindings> <netMsmqBinding> <binding name="msmqBinding" queueTransferProtocol="Srmp"> <security mode="None" /> </binding> </netMsmqBinding> </bindings> <services> <service name="WCF.Msmq.MsmqService"> <endpoint address="net.msmq://10.222.114.78/private/myqueue" binding="netMsmqBinding" bindingConfiguration="msmqBinding" contract="WCF.Msmq.IMsmqService" /> </service> </services> </system.serviceModel>
客户端
<system.serviceModel> <bindings> <netMsmqBinding> <binding name="netMsmqBinding" queueTransferProtocol="Srmp"> <security mode="None" /> </binding> </netMsmqBinding> </bindings> <client> <endpoint address="net.msmq://10.222.114.78/private/myqueue" binding="netMsmqBinding" bindingConfiguration="netMsmqBinding" contract="WCF.Msmq.IMsmqService" name="msmqserivce" /> </client> </system.serviceModel>
有一点需要指出,那就是Address。和其它绑定方式不同,使用MSMQ的WCF的地址并不是本机IP(大家可以看到我的WCF Host这台机器的IP是10.222.114.76,像我们常用的basicHttpBingding,WSHttpBingDing等地址指向都是本机地址),而是MSMQ Host那台虚机的IP地址。这就是我为什么把专门用MSMS Host单独拿出来作为消息服务器的原因。另外, queueTransferProtocol="Srmp"用的使用 SOAP 可靠消息传送协议 (SRMP),需要安装HTTP支持,可以直接把它删掉使用默认的Native方式。
这里代码我就不往上贴了,看一下执行过程吧,WCF Client 1,WCF Client 2往MSMQ Host这台机器上发送消息,WCF Host监控MSMQ Host这台机器上的private/myqueue对列,一旦有消息,则把消息提取出来进行处理。下面是我的程序运行结果,在运行程序之前,需要在MSMQ Host上创建一个私有队列private/myqueue。
WCF Client 1执行结果 | WCF Client 2执行结果 | WCF Host 执行结果 |
关闭WCF Host中我们运行的Service程序,这时会看到,在MSMQ Host这台机器上private/myqueue对列中的消息越积越多。等到再次启动Service后,它里面的消息就会被处理掉。
经过上面的实验,可以得到一下结论:WCF Host,MSMQ Host,WCF Client这三台机器任何一台发生故障,应用都是可恢复的,而且数据不会丢失。
接下来我还做了另一个实验,就是在另外一台机器上启动新建的WCF服务程序,发现两个Service都可以去处理同一队列中的消息,从这种意义上来说,这不失是一个负载均衡的一个解决方案。
最后,附上我的实验代码,供大家参考:Msmq.7z
相关文章推荐
- 基于WCF MSMQ 的企业应用解决方案
- 基于WCF MSMQ 的企业应用解决方案
- 解读 --- 基于微软企业商务应用平台 (Microsoft Dynamics 365) 之上的人工智能 (AI) 解决方案
- 基于AgileEAS.NET企业应用开发平台的分布式解决方案
- spring security 一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架
- 基于AgileEAS.NET企业应用开发平台的分布式解决方案
- 树结构型数据在基于关系型数据库的分布式应用的解决方案
- 从架构设计到系统实施-基于.NET 3.0的全新企业应用之开发Vista边栏应用
- ios 企业应用"无法安装应用程序 因为证书无效"的解决方案
- 基于J2ME的移动商务应用层端到端安全解决方案(三)
- 基于Web服务的应用、解决方案和开发平台 [转]
- Terrocotta - 基于JVM的Java应用集群解决方案
- 有关苹果手机下载应用后提示不受信任的企业开发者解决方案:
- [导入]从架构设计到系统实施——基于.NET 3.0的全新企业应用系列课程(3):设计基于WF的工作流.zip(11.65 MB)
- [导入]从架构设计到系统实施——基于.NET 3.0的全新企业应用系列课程(4):设计基于IIS7和AJAX的网站.zip(7.53 MB)
- 基于企业私有云的统一通信解决方案-2
- 从架构设计到系统实施-基于.NET 3.0的全新企业应用之基于WCF的系统服务
- 从架构设计到系统实施-基于.NET 3.0的全新企业应用之设计基于AJAX和IIS7的网站
- 从架构设计到系统实施-基于Windows Server 2008的全新企业应用之Card Space身份验证
- 畅谈IBM基于企业云与服务的数据中心解决方案