以前收集的一些资料---在ASP中使用MSMQ解决进程死锁问题。

80酷酷网    80kuku.com

  解决|进程|问题            在ASP中使用MSMQ
当ASP程序因为某个进程花费了过长的时间而导致在客户端过期时,
当访问者已经放弃了对你的网站的访问而离开去了别的网站时。
或则你的服务器上阻塞了大量的死队列时,错误"Server is too busy"
发生了。
当你在设计网站的过程中碰到这些问题时,一个解决办法就是使用
Microsoft Message Queue (MSMQ)来结束这些进程。

Microsoft Message Queue 的基本介绍:
MSMQ (代号又叫"Falcon") 是运行在Windows NT的服务,它提供运用程序之间
的异步通讯。你可以在NT4 Option Pack中找到它。
MSMQ的基本概念非常的简单:它可以被看成是运用程序之间的email.
一个消息被打包到一个特定类型的容器中,并把这个消息保存到一个用与特别
作用的队列中直到收信者接受该消息为止。
这些队列能够确保MSMQ的传送,而不管当前网络连接的状况如何。
象所有的电子邮件一样,MSMQ消息有一个发送者和一个接收者,其中的接收者
应该能够访问队列。一个单一队列中的一个单独消息,它拥有
多个接受者例如respinder。而消息的发送者通常是Web Server(IIS) 。

MSMQ也能够和其他消息系统进行通讯。例如:
Sun Solaris, HP-UNIX,OS/2, VMS, AS/400平台
象其他的BackOffice服务一样,MSMQ有一个COM API ( mqoa.dll ) 提供给开发者开发
程序。其中最常用的三个类为: MSMQQueueInfo, MSMQQueue, MSMQMessage.

MSQMQueueInfo
MSMQQueueInfo允许你新建,打开,删除队列中的消息.要和队列建立联系首先需要设置
PathName,这是一个命名队列的属性,它告诉MSQM是哪台机器上的队列。
    <%
     Dim objQueueInfo
     Dim objQueue
     Set objQueueInfo=Server.CreateObject("MSMQ.MSMQQueueInfo")
     objQueue.PathName = ".\MyQueue"
     Set objQueue = objQueueInfo.Open(MQ_SEND_ACCESS, MQ_DENY_NONE)
    %>
上面的代码打开一个叫MyQueue的本地队列.如果队列在另外一台服务器上,代码应该是这样的
    objQueue.PathName = "SomeOtherComputer\MyQueue"
打开队列中有两个参数:Access和ShareMode. Access表示将要对队列执行什么操作。
一般有三个操作:
MQ_PEEK_ACCESS (32), MQ_RECEIVE_ACCESS (1), MQ_SEND_ACCESS (2).
MQ_PEEK_ACCESS用来在特定的队列中查找消息。但对该消息不进行操作。
MQ_RECEIVE_ACCESS 用来在读取队列中的消息后删除它。
MQ_SEND_ACCESS is 用来在队列中发送消息,但不接收消息.
注意的是使用打开操作后返回了一个MSMQQueue对象.
下面是一个典型的新建和删除操作:
    <%
     Dim objQueue
     Set objQueue = Server.CreateObject("MSMQ.MSMQQueueInfo")
     objQueue.PathName = ".\MyQueue"
     objQueue.Create
    %>

    <%
     Dim objQueue
     Set objQueue = Server.CreateObject("MSMQ.MSMQQueueInfo")
     objQueue.PathName = ".\MyQueue"
     objQueue.Delete
    %>

MSMQQueue
MSMQQueue类用来描述一个在MSMQ服务中打开的队列。该类提供了一个用来
在指针队列中的消息进行循环的功能。你不能够打开一个使用了MSMQQueue类的队列
要这么干只能够使用MSQMQueueInfo,见上
虽然许多ASP运用程序通常使用MSMQ来发消息,但是很多时候也需要ASP来显示这个消息的具体内容。
获取消息的方式有两种:同步方式,异步方式,但是ASP只能够使用同步方式。
这是因为ASP不能够在服务端申明一个WithEvents变量。
下面先举一个异步方式使用MSMQ的例子(仅VB中)
  Option Explicit
  Dim m_objQueueInfo As New MSMQQueueInfo
  Dim m_objQueue As MSMQQueue
  Dim WithEvents m_objMSMQEvent As MSMQEvent

  Private Sub Form_Load()
    m_objQueueInfo.PathName = ".\MyQueue"
    m_objQueueInfo.Label = "My Sample Queue"
    On Error Resume Next
    m_objQueueInfo.Create
    On Error GoTo 0
    Set m_objQueue = m_objQueueInfo.Open(MQ_RECEIVE_ACCESS, MQ_DENY_NONE)

    Set m_objMSMQEvent = New MSMQEvent
    m_objQueue.EnableNotification m_objMSMQEvent, MQMSG_CURRENT, 1000
  End Sub

  Private Sub m_objMSMQEvent_Arrived(ByVal Queue As Object, ByVal Cursor As Long)
    Dim m_objMessage As MSMQMessage
    Set m_objMessage = Queue.PeekCurrent
    MsgBox "Message Received: " & m_objMessage.Label
    m_objQueue.EnableNotification m_objMSMQEvent, MQMSG_NEXT, 10000
  End Sub

  Private Sub m_objMSMQEvent_ArrivedError(ByVal Queue As Object, ByVal ErrorCode As Long, ByVal Cursor As Long)
    MsgBox "Error accorded: " & ErrorCode
  End Sub
这段代码首先建立一个队列(如果它还不存在的话)。
然后m_objMSMQEvent对象通过调用EnableNotification连接到MSMQQueue对象.
一旦连接到MSMQEvent对象,接下来需要做的仅仅是完成Arrived和Arrived_Error (可选的)事件.
Arrived事件当一个新的消息到达队列时将被触发
该事件返回两个指针,一个是指向队列中应该从来开始读消息的位置,另外一个是当前的位置。
如果发生错误,将触发ArrivedError事件
当同步获取消息时,会一直等到消息可获取或则超时时程序才会不被挂起。
代码如下:

分享到
  • 微信分享
  • 新浪微博
  • QQ好友
  • QQ空间
点击: