MSMQ浅析.pptVIP

MSMQ消息队列浅析 gaolei 消息队列介绍 为什么要用消息队列 消息队列的安装 消息队列的路径声明 消息队列的消息封装 消息队列的发送 消息队列的接收 AutoSense的应用 消息队列介绍 消息队列（MSMQ——Microsoft Message Queue）是运行在 Windows操作系统上的一个服务 ,它提供了运用程序之间的异步消息处理。是消息应用程序的基础。 消息队列的思想见文知意，就是在操作系统之间将相同格式的消息体互相传递，而且消息在接受方按照队列（先进先出的原则）方式进行顺序处理的技术。 MSDN地址：/zh-cn/library/system.messaging(VS.80).aspx 为什么要用消息队列 处理并发的负荷较高的业务，将并发的事件顺序执行。 处理不需要立即响应的业务，分散处理时间，缓解处理压力。 跨服务器传递支持分布式并行处理方式，为无限制扩大处理能力提供保证。 可恢复模式在传送过程的每一步骤中，都把消息写入物理磁盘中，以得到较好的故障恢复能力。即使接收方已经关机亦不妨碍。 队列的顺序处理保证了有关联关系的业务处理逻辑是正确的。 更紧急或更重要的消息可在相对不重要的消息之前接收，因此可以为关键的应用程序保证足够的响应时间。 消息体事先约定，相当于对数据进行加密。 采用自己定义的格式可以节省通信的传递量 。 消息可以含有时间戳，可做时间一致和过期作废等处理。 消息队列类型 公共队列 MachineName\QueueName 能被别的机器所访问，如果你的多个项目中用到消息队列，那么你可以把队列定义为公共队列 专用队列 MachineName\Private$\QueueName 只针对于本机的程序才可以调用的队列，有些情况下为了安全起见定义为私有队列。 日志队列 MachineName\QueueName\Journal$ 消息队列的安装 消息队列属于Windows组件可以在，组件安装中找到并快速安装。 消息队列的路径声明 !—Autosense MSMQ的地址-- add key=MsmqPath value=FormatName:DIRECT=OS:ceshi3\private$\AutoSenseMsmq/ 消息队列的消息封装 消息队列在.Net框架中得到了很好的支持，开发简便。它使用的命名空间是System.Messaging。需要项目引用DLL。 消息队列经过序列化将消息发送出去，这一过程由系统自动完成了，程序开发人员不必为此编写代码，然而在接收到消息后就面临着消息序列化的问题。 消息的序列化可以通过.Net附带的三个预定义的格式化程序来完成：XMLMessageFormatter 对象（ MessageQueue 组件的默认格式化程序设置）、BinaryMessageFormatter 对象、ActiveXMessageFormatter 对象。 消息队列的发送 消息队列的发送方法很简单，根据消息体是否为类型可分为两种： 简单类型： Mq.Send(1000); //发送整型数据 Mq.Send(“This is a test message!”); //发送字符串 引用类型： MsgTest Msg=new MsgTest(); Msg.Label=”This is the label”; Msg.Level=2; Mq.Send(Msg); 消息队列的接收 同步接收消息，接收消息的代码很简单： Mq.Receive(); Mq.Receive(TimeSpan timeout); //设定超时时间 Mq.ReceiveById(ID); Mq.Peek(); Receive方法接收消息同时永久性地从队列中删除消息； Peek方法从队列中取出消息而不从队列中移除该消息。 异步接受消息，利用委托机制（autosense采用） MessQueue.ReceiveCompleted +=new ReceiveCompletedEventHandler(mq_ReceiveCompleted); AutoSense的应用 各台WEB服务器使用自己的消息队列 消息队列处理利用sqlBulkCopy实现大批量数据一次入库 异常情况下对消息二次硬盘保存。