WCFMSMQ-2.队列与事务.docVIP

[WCF MSMQ] 2. 队列与事务 [ 2007-05-04 11:45:03 | 作者: yuhen ] 字号: 大 | 中 | 小 MSMQ 支持两种类型的队列，事务性队列(transactional queue)会将消息持久(persiste)存储到磁盘中，即便服务器当机(shutdown)、重启(reboot)或崩溃(crash)，消息依然可以在系统恢复后被读取。同时，消息发布、获取和删除都在环境事务范围内，从而确保消息的可靠性。我们还可以使用 TransactionScope 将环境事务传递给队列，否则队列会自动创建一个内部事务。非事务性队列(nontransactional volatile queues)只是将消息存在内存，不会使用磁盘进行持久存储，且不会使用事务来保护对消息的操作。一但服务器发生问题，或者调用方出现异常，消息都会丢失。 // 创建事务性队列MessageQueue.Create(@.\private$\myqueue, true);// 创建非事务性队列MessageQueue.Create(@.\private$\myqueue); 通过下面的例子我们会看到事务失败时，没有任何消息被写入队列。 [ServiceContract]public interface IService{??[OperationContract(IsOneWay = true)]??void Test(int i);}[ServiceBehavior]public class MyService : IService{??[OperationBehavior]??public void Test(int i)??{????Console.WriteLine(i);??}}public class WcfTest{??public static void Test()??{????if (!MessageQueue.Exists(@.\private$\myqueue))????{??????MessageQueue.Create(@.\private$\myqueue, true);????}????IService client = ChannelFactoryIService.CreateChannel(??????new NetMsmqBinding(NetMsmqSecurityMode.None),??????new EndpointAddress(net.msmq://localhost/private/myqueue));????try????{??????using (TransactionScope scope = new TransactionScope())??????{????????using (client as IDisposable)????????{??????????for (int i = 0; i 10; i++)??????????{????????????client.Test(i);????????????if (i 5) throw new Exception();??????????}????????}????????scope.Complete();??????}????}????catch????{ ????}????AppDomain.CreateDomain(Server).DoCallBack(delegate????{??????ServiceHost host = new ServiceHost(typeof(MyService), ????????new Uri(net.msmq://localhost/private/myqueue));??????host.AddServiceEndpoint(typeof(IService), new NetMsmqBinding(NetMsmqSecurityMode.None), );??????host.Open();????});??}} 这里需要对 消息 做一个澄清，当客户端发出调用(call)时，调用会被转换成 WCF Message，然后被包装到 MSMQ Message 中。如果客户端事务完成提交，那么 MSMQ Message 会被传递到队列并存储起来。相反，如果事务失败，消息会被丢弃。上面的例子中，我们将多个调用放到一个环境事务中，也可以将多个服务调用放到一个事务当中。如果队列服务不在当前机器上，也就是说使用 Public Queue 时，客户端的消息队列