2个本地应用程序之间的c＃MSMQ未收到所有发送的消息

Question

我创建了自己的 MSMQ 包装器 class，如下所示：

public class MsgQueue
{
    private MessageQueue messageQueue;

    public delegate void ReadMessageDelegate(string message);
    public event ReadMessageDelegate NewMessageAvailable;

    public MsgQueue(string queueName)
    {
        var queuePath = @".\Private$\" + queueName;

        if (!MessageQueue.Exists(queuePath)) MessageQueue.Create(queuePath);

        messageQueue = new MessageQueue(queuePath);
        messageQueue.Label = queueName;
        messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string)});

        messageQueue.ReceiveCompleted += new ReceiveCompletedEventHandler(MsgReceivedHandler);
        messageQueue.BeginReceive();
    }

    private void MsgReceivedHandler(object sender, ReceiveCompletedEventArgs e)
    {
        try
        {
            MessageQueue mq = (MessageQueue)sender;
            var message = mq.EndReceive(e.AsyncResult);

            NewMessageAvailable(message.Body.ToString());

            mq.BeginReceive();
        }
        catch (MessageQueueException)
        {
            // Handle sources of MessageQueueException.
        }

        return;
    }

    public void SendMessage(string message)
    {
        messageQueue.Send(message);
    }
}

我在两个单独的 WinForms 应用程序上对其进行了测试。

第一个应用在点击按钮时发送短信：

private void btn_Click(object sender, EventArgs e)
{          
   var queue = new MsgQueue.MsgQueue("GBMqueue");
   queue.SendMessage("some message text");
}

第二个应用程序正在侦听任何传入的消息，然后尝试处理它：

// declaration
private MsgQueue queue;

// preparation of the queue
private void Form1_Load(object sender, EventArgs e)
{
    queue = new MsgQueue.MsgQueue("GBMqueue");
    queue.NewMessageAvailable += Queue_NewMessageAvailable;
}

// Handler for the incoming messages
private void Queue_NewMessageAvailable(string message)
{
     // Hits here very rarely!!!
}

问题是我可以多次从 App1 发送消息，但是 Queue_NewMessageAvailable 处理程序只捕获一条随机消息，而不是第一条 - 只是其中一条已发送。

没有抛出异常，只是没有捕获传入的消息。

我做错了什么？

Answer 1

我觉得第一个App不应该监听新消息。它可能会带走第二个应用程序的消息。它应该只发送消息。

拆分功能后它应该可以工作。

2个本地应用程序之间的c＃MSMQ未收到所有发送的消息

c# MSMQ between 2 local apps not receiving all messages sent

c#

msmq