MSMQ接受时出现异常

两个应用程序，一个输入数据，另一个接受数据
如果在一个应用中同时发送接收能够收到数据，分开两个应用就会引发异常：“System.InvalidOperationException”类型的异常
代码如下：
msmq类
C# code

using System;
using System.Linq;
using System.Messaging;

namespace MSMQ
{
    public delegate void Deal(string msg);
    public class DbQueue
    {
        public MessageQueue mq;
        public Deal deal;
        public ReceiveCompletedEventHandler deal2;
        public DbQueue()
        {
            try
            {
                if (MessageQueue.Exists(@".\Private$\DBWrite"))
                    mq = new MessageQueue(@".\Private$\DBWrite");
                else
                    mq = MessageQueue.Create(@".\Private$\DBWrite");
            }
            catch (MessageQueueException e)
            {
                Console.WriteLine(e.Message);
            }
        }

        public void Send(string msg)
        {
            mq.Send(msg);
            Console.WriteLine("发送消息：" + msg);
        }
        public void Receive()
        {
            while (true)
            {
                while (mq.GetAllMessages().Count() > 0)
                {
                    Console.Write("共有" + mq.GetAllMessages().Count().ToString() + "条");
                    //Message msg = mq.Receive();       //同步接收
                    mq.BeginReceive();
                    mq.ReceiveCompleted += deal2;
                    //Object obj = msg.Body;
                    //deal(obj.ToString());
                }
                Console.WriteLine("等待中");
            }
        }

        public void ReadAll()
        {
            foreach (Message m in mq)
            {
                string result = m.Body.ToString();
                Console.WriteLine(result);
            }
        }
    }
}

发送
C# code

using System;

namespace MSMQ
{
    class Program
    {
        static void Main(string[] args)
        {
            DbQueue q = new DbQueue();
            while (true)
            {
                Console.Write("输入发送字符串：");
                string msg=Console.ReadLine();
                q.Send(msg);
                q.ReadAll();
            }
            Console.ReadKey();
        }        
    }    
}

接受，这里尝试了同步和异步接受，同步的已经注释
C# code

using System;
using MSMQ;
using System.Threading;
using System.Messaging;

namespace MSMQ_receiver
{
    class Program
    {
        static void Main(string[] args)
        {
            DbQueue db = new DbQueue();
            db.deal = new Deal(ConcentDeal);
            db.deal2 = new ReceiveCompletedEventHandler(MyAsyncReceiver);
            Thread me = new Thread(new ThreadStart(db.Receive));
            me.Start();
            //db.ReadAll();
        }

        public static void ConcentDeal(string msg)
        {
            Console.WriteLine("处理中……");
            Thread.Sleep(new Random().Next(1000));
            Console.WriteLine("收到消息：" + msg);
        }

        public static void MyAsyncReceiver(object resouce,ReceiveCompletedEventArgs args)
        {
            MessageQueue mq=resouce as MessageQueue;
            Message obj=mq.EndReceive(args.AsyncResult);          //就是这里异常了
            Console.WriteLine("收到的消息为："+obj.Body.ToString());   //这里报错：找不到能够读取此消息的格式化程序。
        }
    }

    
}

没有用过，但是帮你顶一块学习， 

最起码地，MSMQ需要把各级MSMQ服务器、客户端驱动都预先安装好，测试没有问题。不是在程序里写个语句就能行了。

其实所谓“消息中间件”是一种过气的“技术”，只是在一些比较陈旧的系统中需要维护，因为过去MQ的接口总是比socket编程要简单许多。今天的通讯技术很多、封装的也很简洁清爽，那么MQ这类东西就显得弊大于利了。

http://www.csharpwin.com/csharpspace/1659.shtml

http://msdn.microsoft.com/zh-cn/library/system.messaging.messagequeue(v=VS.85).aspx