MSMQ接受时出现错误-ASP.NET教程-爱易网页

MSMQ接受时出现错误

日期：2014-05-17　浏览次数：20556 次

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服务器、客户端驱动都预先安装好，测试没有问题。不是在程序里写个语句就能行了。
------解决方案--------------------
http://www

免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。

MSMQ接受时出现错误

相关资料更多>

推荐阅读更多>