.net 中的 MSMQ 即服务

Question

我们有一个 Java WebService，它使用 MSMQ 发送消息（带有一组记录的 XML 文件）。

我需要使用 VB.net 在 .net 中构建一个小型应用程序，它应该选择这些消息并读取它们并将其插入 SQL 数据库。

你们有什么建议吗？ 我们如何实时读取MSMQ消息。

任何资源或链接都会有很大帮助。

Answer 1

系统中的 .NET 提供了 MSMQ 的完全托管实现.Messaging 命名空间。 您可以在消息队列上调用 BeginReceive，然后该队列将异步等待消息到达。 一旦完成，您就可以调用 EndReceive， 处理消息并再次调用 BeginReceive 以等待下一条消息（或处理队列中的下一条消息）。

Answer 2

在 .NET 中处理 MSMQ 消息的最佳方法是使用 WCF。 Justin Wilcox 在此处提供了很棒的教程。

但我强烈建议你尝试MSMQ + WCF。 它非常好，您将了解有关 WCF 的更多信息，这是很棒的东西。

更简单的方法是像 JustinD 建议的那样做。 System.Messaging 命名空间非常易于使用。 我要做的唯一不同是调用 Receive 方法而不指定超时。 这会导致线程等待，直到消息出现在队列中，此时将收到消息。

Answer 3

这里有一些示例 C# .NET 代码，可以帮助您开始从队列中读取数据...

using System.Messaging;
using System.IO;


MessageQueue l_queue = new MessageQueue(this.MessageQueuePath);
        l_queue.Formatter = new XmlMessageFormatter(new Type[] { typeof(System.String) });

        if (!l_queue.CanRead)
        {
            e.Result = MessageQueueError.InsufficientPermissions;
            return;
        }

        while (true)
        {
            // sleep 2 seconds between checks to keep this from overloading CPU like a madman
            System.Threading.Thread.Sleep(2000);

            Message l_msg = null;
            string l_msgID = String.Empty;

            // try and receive the message - a IOTimeout exception just means that there aren't any messages - move on
            try { l_msg = l_queue.Receive(TimeSpan.FromSeconds(5)); }
            catch (MessageQueueException ex)
            {
                if (ex.MessageQueueErrorCode != MessageQueueErrorCode.IOTimeout)
                    // log error
                else
                    continue;
            }
            catch (Exception ex) { // log error 
            }

            if (l_msg == null)
            {
                //log error
                continue;
            }

            // retrieve and log the message ID
            try { l_msgID = l_msg.Id; }
            catch (Exception ex) { // log error
            }

            // do whatever with the message...
        }