消息队列

标签：style   http   color   io   os   ar   使用   for   sp   

一、消息处理中的主要概念  “消息”是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；也可以更复杂，可能包含嵌入对象。

消息被发送到队列中。“消息队列”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功地传递它。

“消息队列”是 Microsoft 的消息处理技术，它在任何安装了 Microsoft Windows 的计算机组合中，为任何应用程序提供消息处理和消息队列功能，无论这些计算机是否在同一个网络上或者是否同时联机。

“消息队列网络”是能够相互间来回发送消息的任何一组计算机。网络中的不同计算机在确保消息顺利处理的过程中扮演不同的角色。它们中有些提供路由信息以确定如何发送消息，有些保存整个网络的重要信息，而有些只是发送和接收消息。

“消息队列”安装期间，管理员确定哪些服务器可以互相通信，并设置特定服务器的特殊角色。构成此“消息队列”网络的计算机称为“站点”，它们之间通过“站点链接”相互连接。每个站点链接都有一个关联的“开销”，它由管理员确定，指示了经过此站点链接传递消息的频率。

“消息队列”管理员还在网络中设置一台或多台作为“路由服务器”的计算机。路由服务器查看各站点链接的开销，确定经过多个站点传递消息的最快和最有效的方法，以此决定如何传递消息。 
二、队列类型  有两种主要的队列类型：由您或网络中的其他用户创建的队列和系统队列。用户创建的队列可能是以下任何一种队列：

“公共队列”在整个“消息队列”网络中复制，并且有可能由网络连接的所有站点访问。  “专用队列”不在整个网络中发布。相反，它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。  “管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列（如果有的话）。  “响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列（如果有的话）。     系统生成的队列一般分为以下几类：

“日记队列”可选地存储发送消息的副本和从队列中移除的消息副本。每个“消息队列”客户端上的单个日记队列存储从该计算机发送的消息副本。在服务器上为每个队列创建了一个单独的日记队列。此日记跟踪从该队列中移除的消息。  “死信队列”存储无法传递或已过期的消息的副本。如果过期或无法传递的消息是事务性消息，则被存储在一种特殊的死信队列中，称为“事务性死信队列”。死信存储在过期消息所在的计算机上。  “报告队列”包含指示消息到达目标所经过的路由的消息，还可以包含测试消息。每台计算机上只能有一个报告队列。  “专用系统队列”是一系列存储系统执行消息处理操作所需的管理和通知消息的专用队列。  在应用程序中进行的大多数工作都涉及访问公共队列及其消息。但是，根据应用程序的日记记录、确认和其他特殊处理需要，在日常操作中很可能要使用几种不同的系统队列。

三、同步和异步通信  队列通信天生就是异步的，因为将消息发送到队列和从队列中接收消息是在不同的进程中完成的。另外，可以异步执行接收操作，因为要接收消息的人可以对任何给定的队列调用 BeginReceive 方法，然后立即继续其他任务而不用等待答复。这与人们所了解的“同步通信”截然不同。

在同步通信中，请求的发送方在执行其他任务前，必须等待来自预定接收方的响应。发送方等待的时间完全取决于接收方处理请求和发送响应所用的时间。 
四、消息安全性  可用如下方式帮助保护发送和接收的消息内容：

可使用身份验证验证应用程序接收的消息的来源。  可使用加密确保未经授权的人无法读取或使用您的消息。  可使用访问控制权限，用基于 ACL 的安全性限制用户和用代码访问安全性限制代码向计算机上的特定队列发送消息或从中读取消息。  可使用审核记录尝试访问“消息队列”对象的用户，尝试的操作类型，以及该访问成功还是失败。 
五、安装“消息队列”  如果要在代码或者服务器资源管理器中使用消息队列，必须在开发计算机上安装“消息队列”。在 Windows 2000 或 Windows NT 文档中可以找到有关如何安装“消息队列”的说明。在安装时，必须指定正在创建的新主“消息队列”服务器所起的作用：是充当新网络的集线器、现有网络的独立客户端还是现有网络的依赖客户端。多数情况下，不用创建新的网络，而是可以加入公司或工作组的现有“消息队列”网络。 
安装具有独立客户端功能的消息队列  打开 添加或删除程序。  单击“添加/删除 Windows 组件”。  在“Windows 组件向导”中，选中“消息队列”复选框。  如果要更改默认安装的可选子组件集，可单击“详细信息”，然后执行下述操作。  如果计算机属于某个域，而您希望它在工作组模式下运行，请清除“Active Directory 集成”复选框。  如果不希望安装消息队列触发器，请清除“触发器”复选框。  如果希望由 HTTP 传送程序发送消息，请选中“MSMQ HTTP 支持”复选框。 
----------------------------------------------------------------------------------------------------------------------------------------------------------  我们先简单的了解一下什么是消息队列(MSMQ)？消息队列是 Windows 2000（NT也有MSMQ，WIN95/98/me/xp不含消息队列服务但是支持客户端的运行）操作系统中通讯的基础，也是用于创建分布式、松散连接通讯应用程序的工具。这些应用程序可以通过不同种类的网络进行通讯，也可以与脱机的计算机通讯。消息队列分为用户创建队列和系统队列，用户队列分为： 
　　· "公共队列"在整个可传递消息的"消息队列"网络中复制并传输，并且有可能由网络连接的所有站点访问。 
　　· "专用队列"不在整个网络中发布。相反，它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。 
　　· "管理队列"包含确认在给定"消息队列"网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列 
　　· "响应队列"包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列。 
　　系统队列分为： 
　　· "日记队列"可选地存储发送消息的副本和从队列中移除的消息副本。 
　　· "死信队列"存储无法传递或已过期的消息的副本。 
　　· "专用系统队列"是一系列存储系统执行消息处理操作所需的管理和通知消息的专用队列。 
　　现在大家对消息队列有了简单的了解后，就该进入主题了。要使用msmq进行软件开发需要安装msmq。安装完后就该进入实际的开发阶段。先打开vs.net ide中的"服务起资源管理器"展开你想建立消息队列的计算机名，再展开"消息队列"右击它在弹出菜单中选择"新建"建立一个新的消息队列，并为它指定一个名字，这个名字可以随意。也可以通过编程来完成，代码如下： 
system.Messaging.MessageQueue.Create(".\Private$\MyPrivateQueue")‘建立专用队列  System.Messaging.MessageQueue.Create("myMachine\MyQueue")‘建立公共队列 
　　其实我认为使用那中方法并不重要，重要的是搞清楚专用队列和公共队列的差别（其他队列不是必须的）。在本例中是通过"服务器资源管理器"分别在服务器上建立了专用队列和公共队列。 
　　程序功能：本程序分为两部分包括服务器程序（安装在sql server服务器上）和客户端程序，客户端的作用是用来编写t-sql语句并将t-sql语句放在消息中，并将消息发送到sql server服务器上的消息队列中去。服务器程序检查指定的消息队列当发现有新消息到达时，就开始执行消息中的内容，由于消息中的内容是t-sql语句所以服务器端实际上是执行对数据库的操作。 
　　客户端程序： 

　　服务端程序： 

　　我为什么要使用消息队列来处理数据库的操作这个问题我一直没回答，现在我就来回答这个问题。在本程序中你会发现在sub client（）中我并没连接数据库和请求数据，而是通过发消息来操作数据库的，这个好处是节省了两部分时间： 
　　1、对数据库连解请求数据的时间。 
　　2、从数据库返回数据的时间。 
　　在很多情况下其实我们并不需要看见具体的数据就知道该怎么修改数据库中的数据。例如要删除张三的记录，就可以将一条简单的删除语句放入消息中，发给服务器让服务器程序去处理对数据的更改。 
　　此外消息队列的另一个主要用途也就是当前erp软件中必不可少的，就是在断开连接时保存信息，当连接恢复时发送消息。消息在如下两种情况中无法迅速地传递到它们的队列：当队列驻留的计算机无法工作时，或当路由消息所需的域控制器无法工作时。"消息队列"可让您应对这些情况，使得在从网络上断开连接或必要的计算机或控制器无法工作时，仍可以继续发送消息。在这些情形下，消息暂时存储在本地计算机或传递路由上的某个计算机的队列中，直到完成传递所需的资源重新联机。 
　　例如，假设有一个记录所有在出差的销售人员发送的订单的中央队列。这些销售人员每天的大部分时间都以断开连接的方式工作，记录来自客户站点的订单信息，并且每天拨号连接一次，将所有这些信息传输到中央队列中。因为消息在发送方断开连接时仍可发送到队列，所以销售人员可以在记录客户信息时立即发送他们的消息，但系统会缓存这些消息直到晚间进行拨号连接为止。 
　　在断开连接时要怎么保存消息呢？向断开连接的队列发送消息同向可用队列发送消息的过程几乎完全相同。当要向其发送的队列不可用时，不必进行任何特殊的配置以使组件将消息存储在临时队列中。在client代码的tM.Path = ".\Private$\jk"后面有一条注释语句，其实这条语句就是实现向断开连接的队列发送消息的功能。只要将tM.Path = ".\Private$\jk"这条语句换成tM.Path = "FORMATNAME:PUBLIC=3d3dc813-c555-4fd3-8ce0-79d5b45e0d75"其中PUBLIC后面的数字是要发送到计算机的guid数字。这个数字可以打开那台计算机的消息队列的属性看见。使用这种方法就可以在断开连接的情况下保证对服务器的操作是有效。现在运行这个程序后，打开win2000中的"开始"-》"程序"-》"管理工具"-》"计算机管理"。在"计算机管理"窗口中展开"服务和应用程序"-》"消息队列"-》"传出队列"，你将在右边的窗口中看见你建立的消息。（如果你使用tM.Path = ".\Private$\jk"语句，在"计算机管理"窗口中展开"服务和应用程序"-》"消息队列"-》"专用队列"可以看见你建立的队列。） 
　　其实消息队列的编程并不复杂，但它在网络环境的程序开发中是非常有用的，可以简化大量的开发过程和节省开发时间。 
　　其实消息队列的编程有很大的灵活性，几乎可以解决网络编程的大部分问题。比如聊天程序，远程控制程序。 
　　本文针对消息队列做了一个简单的介绍，并举了一个例来说明怎么在.net下使用消息编程，达到快速高效稳定的对数据库进行操作。最后补充要说的是在internet中也一样可以使用消息队列，只需要将tM.Path = "FORMATNAME:PUBLIC=3d3dc813-c555-4fd3-8ce0-79d5b45e0d75语句后面的数字变成消息队列所在服务器的数字就可以了。但是要提醒大家的是使用消息在传输时将占有大量的带宽，所以在不是必须的时候，internet下的编程不要使用消息。

消息队列

标签：style   http   color   io   os   ar   使用   for   sp   

原文地址：http://www.cnblogs.com/azzhang/p/4044498.html