c# - 如何实现 MSMQ 触发器

Question

有人能解决我的问题吗？

我想在 MSMQ 队列中插入一些数据时触发一个事件，我该怎么做？

Answer 1

您创建消息队列的实例并开始异步查看它:

MessageQueue queue = new MessageQueue( @".\PRIVATE$\Queue" );
queue.BeginPeek( TimeSpan.Infinite, null, OnMessageAdded);

当消息被添加到队列时调用注册的回调。至于你没有解释你真正的问题是什么，我假设你想了解添加到队列中的新消息:

private void OnMessageAdded( IAsyncResult ar )
{
    Message peekedMessage = queue.EndPeek(ar);
    //Do whatever you want. Raise a new event, process the message, ...
}

消息没有从队列中取出。您可以使用该消息，但它仍保留在队列中。因此，如果您不需要 Message，您可以简单地调用 queue.EndPeek(ar); 而无需使用结果。