WCF笔记--MSMQ的使用

好久好久没有写过日志了,,多是遗忘了,也多是明白了些什么..
 
趁着此次工做的机会算是把WCF进行了完整再学习,其中一些不足的遗忘的点都零零碎碎的拼接在了一块儿
为避免再次遗失,仍是记录以下...




1、为何要使用MSMQ

在一个分布式的环境中，咱们每每须要根据具体的状况采用不一样的方式进行数据的传输。好比在一个Intranet内，咱们通常经过TCP进行高效的数据通讯；而在一个Internet的环境中，咱们则一般使用Http进行跨平台的数据交换。而这些通讯方式具备一个显著的特色，那就是他们是基于Connection的，也就是说，交互双方在进行通讯的时候必须保证有一个可用的Connection存在于他们之间。而在某些时候，好比那些使用拨号链接的用户、以及使用便携式计算机的用户，咱们不能保证在他们和须要访问的Server之间有一个的可靠的链接，在这种状况下，基于Messaging Queue的链接就显得尤其重要了。咱们今天就来谈谈在WCF中如何使用MSMQ。
MSMQ不只仅是做为支持客户端链接工具而存在，合理的使用MSMQ能够在很大程度上提高系统的Performance和Scalability。咱们先来看看MSMQ能给咱们带来怎样的好处：
1．MSMQ是基于Disconnection
MSMQ经过Message Queue进行通讯，这种通讯方式为 离线工做 成为了可能。好比在介绍MSMQ时都会提到的Order Delivery的例子：在一个基于B2C的系统中，订单从各类各样的客户传来，因为 客户的各异性，不能保证每一个客户在每时每刻都和用于接收订单的Server保持一个可靠的链接，咱们有时候甚至容许客户即便在 离线 的状况下也能够递交订单（虽然订单不能发送到订单的接收方，可是咱们能够经过某种机制保证先在本地保存该订单，一旦链接创建，则立刻向接收方递交订单），而MSMQ则有效地提供了这样的机制：Server端创建一个Message Queue来接收来个客户的订单，客户端经过向该Message Queue发送承载了订单数据的Message实现订单的递交。若是在客户离线的状况下，他仍然能够经过客户端程序进行订单递交的操做，存储着订单数据的Message会被暂时保存在本地的Message Queue中，一旦客户联机，MSMQ将Message从中取出，发送到真正的接收方，而这个动做对于用户的透明的。
2．MSMQ天生是One-way、异步的
在MSMQ中，Message始终以One-way的方式进行发送，因此MSMQ具备天生的异步特性。因此MSMQ使用于那些对于用户的请求，Server端 无需当即响应 的场景。也就是说Server 对数据的处理无需和Client的数据的发送进行同步 ，它能够独自地按照本身的Schedule进行工做。这能够避免峰值负载。好比Server端能够在一个相对低负载的时段（好比深夜）来对接收到的Order进行批处理，而无需一天24小时一直进行Order的监听、接收和处理。
3．MSMQ可以提供高质量的Reliable Messaging
咱们知道，在通常的状况下，若是Client端以异步的方式对Service进行调用就意味着：Client没法获知Message是否成功抵达Service端；也不会得到Service端执行的结果和出错信息。可是咱们仍然说MSMQ为咱们提供了可靠的传输（Reliable Messaging），这主要是由于MSMQ为咱们提供一些列Reliable Messaging的机制：

• 
  超时机制（Timeout）：能够设置发送和接收的时间，超出该时间则被认为操做失败。
  
• 
  确认机制（Acknowledgement）：当Message成功抵达Destination Queue，或者被成功接收，向发送端发送一个Acknowledgement message用以确认操做的状态。
  
• 
  日志机制（Journaling）：当Message被发送或接收后，被Copy一份存放在Journal Queue中。
  

此外，MSMQ还提供了 死信队列 （Dead letter Queue）用以保存发送失败的message。这一切保证了保证了Reliable Messaging。
2、 MSMQ在WCF的运用
在WCF中，MSMQ提供的数据传输功能被封装在一个 Binding 中，提供 WCF Endpoint之间 、以及Endpoint和现有的基于MSMQ的Application进行通讯的实现。为此WCF为咱们提供了两种不一样的built-in binding：

• 
  NetMsmqBinding：从提供的功能和使用 方式上看，NetMsmqBinding和通常使用的binding，好比basicHttpBinding，netTcpBinding没有什么区别：在两个Endpoint之间实现了数据的通讯，所不一样的是，它提供的是基于MSMQ的Reliable Messaging。从变成模式上看，和通常的binding彻底同样。
  
• 
  MsmqIntegrationBinding：从命名上咱们能够看出，MsmqIntegrationBinding主要用于须要将咱们的WCF Application和现有的基于MSMQ的Application集成的状况。MsmqIntegrationBinding实现了WCF Endpoint和某个Message Queue进行数据的通讯，具体来讲，就是实现了单一的向某个Message Queue 发送Message，和从某个Message Queue中接收Message的功能。从编程模式上看，也有所不一样，好比Operation只接收一个MsmqMessage<T>的参数。
  

这是Client和Service通讯的图示：


3、MSMQ和Transaction
MSMQ提供对Transaction的支持。在通常的状况下，MSMQ经过 Message Queue Transaction 实现对Transaction的原生的支持，借助Message Queue Transaction，能够把基于一个或多个Message Queue的相关操做归入同一个Transaction中。
Message Queue Transaction仅仅限于基于Message Queue的操做，假若操做涉及到另一些资源，好比SQL Server, 则可使用基于DTC的 分布式Transaction 。
对于WCF中MSMQ，因为Client和Service的相对独立（可能Client发送Message到Service处理Message会相隔很长一段时间），因此Client和Service的操做只能归入不一样的Transaction中，以下图。



代码: 
1.终结点配置
<endpoint address="net.msmq://localhost/private/orders" binding="netMsmqBinding"

bindingConfiguration ="msmqBinding" contract="Contract.IOrderProcessor" />


2.托管建立MSMQ队列


string path = @".\private$\orders";

if(!MessageQueue.Exists(path))
{
MessageQueue.Create(path,true);
}


3.客户端使用


ChannelFactory<IOrderProcessor> channelFactory = new ChannelFactory<IOrderProcessor>("defaultEndpoint");

IOrderProcessor channel  = channelFactory.CreateChannel();
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))

{ 
       channel.Submit(order);
       scope.Complete();
}


自然断开异步事务集于一身,,使用简单方便更乃王道...