找代理做网站网站域名归属谁,设计网站教程,网站建设维护协议,吴忠住房和城乡建设局网站MQ是一种企业服务的消息中间节技术#xff0c;这种技术常常伴随着企业服务总线相互使用#xff0c;构成了企业分布式开发的一部分#xff0c;如果考虑到消息的发送和传送之间是可以相互不联系的并且需要分布式架构#xff0c;则可以考虑使用MQ做消息的中间价技术#xff0…MQ是一种企业服务的消息中间节技术这种技术常常伴随着企业服务总线相互使用构成了企业分布式开发的一部分如果考虑到消息的发送和传送之间是可以相互不联系的并且需要分布式架构则可以考虑使用MQ做消息的中间价技术MQ的功能已经足够开发使用。
MSMQ 原理
MSMQ的实现原理是消息的发送者把自己想要发送的信息放入一个容器然后把它保存到一个系统公用空间的消息队列中本地或异地的消息接收程序再从该队列中取出发给它的消息进行处理。
消息队列是一个公用存储空间它可以存在于内存中或物理文件中因此消息以两种方式发送即快递方式和可恢复模式。它们的区别是消息存储位置的不同快递方式为了消息的快速传递所以把消息放置在内存中而不放在物理磁盘上以获得较高的处理能力而可恢复模式在传送过程的每一步骤中都把消息写入物理磁盘上这样当保存消息队列的机器发生故障而重新启动后可以把发送的消息恢复到故障发送之前的状态以获得更好的消息恢复能力。消息队列可以放在发送方、接收方所在的机器上也可以单独放置在另外一台机器上。另外采用消息队列机制发送方不必要担心接收方是否启动是否发生故障等因素只要消息成功发送出去就可以认为处理完成而实际上对方可能甚至未开机或者实际消息传递到对方可能在第二天。MSMQ机制类似QQ消息传递机制。下图演示了MSMQ的实现原理。
公共队列在整个消息队列网络中复制有可能由网络连接的所有站点访问。 路径格式为 机器名称\队列名称
专用队列或叫私有队列不在整个网络中发布它们仅在所驻留的本地计算机上可用专用队列只能由知道队列的完整路径名称或标签的应用程序访问。 路径格式为 机器名称\Private$\队列名称
日志队列包含确认在给定“消息队列中发送的消息回执消息”。
路径格式为机器名称\队列名称\Journal$
响应队列包含目标应用程序接收到消息时返回给发送应用程序的响应消息包括机器日志队列、机器死信队列和机器事务死信队列。其中
机器信道死信队列对应的格式为机器名称\XactDeadletterKaTeX parse error: Undefined control sequence: \Deadletter at position 20: …死信队列对应的格式为机器名称\̲D̲e̲a̲d̲l̲e̲t̲t̲e̲r̲ 机器日志队列对应的格式为机器名称\Journal$
优点:稳定、消息优先级、脱机能力以及安全性,有保障的消息传递和执行许多业务处理的可靠的防故障机制。
缺点:MSMQ不适合于Client需要Server端实时交互情况.大量请求时候,响应延迟.
工作组模式或域模式 MSMQ可以安装为工作组模式或域模式。如果安装程序没有找到一台运行提供目录服务的消息队列的服务器则只可以安装为工作组模式此计算机上的“消息队列”只支持创建专用队列和创建与其他运行“消息队列”的计算机的直接连接。
《安装与启动服务》 我的电脑 管理 服务和应用程序 消息队列 。出现消息队列则说明安装成功
MSMQ 客户端
using System;
using System.Messaging; // 需要添加System.Messaging引用namespace MSMQClient
{class Program{static void Main(string[] args){//私有队列 、专用队列if (MessageQueue.Exists(.\Private$\AresWangMSMQ)){// 创建消息队列对象using (MessageQueue mq new MessageQueue(.\Private$\AresWangMSMQ)){// 设置消息队列的格式化器mq.Formatter new XmlMessageFormatter(new string[] { System.String });foreach (Message msg in mq.GetAllMessages()){Console.WriteLine(Received Private Message is: {0}, msg.Body);}if(mq.CanRead){//mq.Peek() // 获得消息队列中第一条消息,但删除第一条记录Message firstmsg mq.Receive(); // 获得消息队列中第一条消息,且删除第一条记录Console.WriteLine(Received The first Private Message is: {0}, firstmsg.Body);}}}Console.Read();}}
}
MSMQ 服务端
using System;
using System.Messaging;namespace MSMQServer
{class Program{ static void Main(string[] args){// 创建一个公共队列,公共队列只能创建在域环境里//if (!MessageQueue.Exists(.\AresWangMSMQ)) // 判断此路径下是否已经有该队列//{// using (MessageQueue mq MessageQueue.Create(.\AresWangMSMQ))// {// mq.Label AresWangMSMQ; // 设置队列标签// Console.WriteLine(已经创建了一个公共队列);// Console.WriteLine(路径为:{0}, mq.Path);// Console.WriteLine(队列名字为:{0}, mq.QueueName);// mq.Send(MSMQ Message, Leaning Hard); // 发送消息// }//}//if (MessageQueue.Exists(.\Private$\AresWangMSMQ))//{// // 删除消息队列// MessageQueue.Delete(.\Private$\AresWangMSMQ);//}// 创建一个私有消息队列if (!MessageQueue.Exists(.\Private$\AresWangMSMQ)){using (MessageQueue mq MessageQueue.Create(.\Private$\AresWangMSMQ)){mq.Label AresWangMSMQ; Console.WriteLine(已经创建了一个私有队列);Console.WriteLine(路径为:{0}, mq.Path);Console.WriteLine(私有队列名字为:{0}, mq.QueueName);mq.Send(MSMQ Private Message, AresWangMSMQ); // 发送消息}}// 遍历所有的公共消息队列//foreach (MessageQueue mq in MessageQueue.GetPublicQueues())//{// mq.Send(Sending MSMQ public message DateTime.Now.ToLongDateString(), Learning Hard);// Console.WriteLine(Public Message is sent to {0}, mq.Path);//}if (MessageQueue.Exists(.\Private$\AresWangMSMQ)) {// 获得私有消息队列MessageQueue mq new MessageQueue(.\Private$\AresWangMSMQ);if(mq.CanWrite){mq.Send(Sending MSMQ private message DateTime.Now.ToLongDateString(), AresWangMSMQ);}Console.WriteLine(Private Message is sent to {0}, mq.Path);}Console.Read();}}
}
