在对远程的MSMQ访问的时候，发现一个奇怪的现象

static string path = @"FormatName:DIRECT=TCP:sha-db\private$\mt1";

//check is existed and create 
           if (MessageQueue.Exists(path) == false) 
           { 
               MessageQueue.Create(path,false); 
           }

就如下代码，会报错，队列路径非法类似的错误，google了很多，都没有个解决方法。后来查到篇个回帖

http://stackoverflow.com/questions/1914885/cannot-determine-whether-a-queue-with-the-specified-format-name-exists

说 MessageQueue.Exists 文档中说：Exists方法不支持FormatName 前缀。Exists 方法不能验证远程队列。参考：http://msdn.microsoft.com/zh-cn/library/system.messaging.messagequeue.exists.aspx

文中还提供了其他可以实现的方法。

虽然Exists方法会失败，但是不影响它发送消息，只要路径写对，照样可以发送出去。

---------------------------------------------------------------------------------

还有一个奇怪的现象。

使用for语句插入2000条消息，在消息队列的窗口最多只能看到1000条，当你取出一条后，才能看到后一条。

估计是设计使然。

---------------------------------------------------------------------------------

下面的方法是一些示例代码，主要是多线程发消息和去消息

多线程

//watch.Restart(); 
           //Thread t1 = new Thread(send); 
           //Thread t2 = new Thread(send); 
           //Thread t3 = new Thread(send); 
           //Thread t4 = new Thread(send); 
           //t1.Start(); 
           //t2.Start(); 
           //t3.Start(); 
           //t4.Start();

//t4.Join(); 
           //t1.Join(); 
           //t2.Join(); 
           //t3.Join(); 
           //t4.Join(); 
           //watch.Stop(); 
           //SaveFile(@"c:\msmqlog.txt", "多线程发送" + j + "条消息,每条大小约40k，时间：" + watch.Elapsed.ToString());

委托异步执行

// Action a = new Action(() => 
           // { 
           //     for (int i = 0; i < 5000; i++) 
           //     { 
           //         Console.WriteLine(i); 
           //         queue.Send(s, transactionType); 
           //     } 
           //     queue.Close(); 
           // });

//watch.Restart(); 
           //IAsyncResult ia= a.BeginInvoke((ar) => { 
           //     SaveFile(@"c:\msmqlog.txt", "异步发送" + j + "条消息,每条大小约40k，时间：" + watch.Elapsed.ToString()); 
           // }, null); 
           // a.EndInvoke(ia);

同步的读取消息

//int index = 0; 
           //MessageEnumerator me = queue.GetMessageEnumerator2(); 
           //watch.Restart(); 
           //while (me.MoveNext()) 
           //{ 
           //    Console.Write(me.Current.Id + "-"); 
           //    Console.WriteLine(++index); 
           //    me.RemoveCurrent(); 
           //    me.Reset(); 
           //} 
           //watch.Stop(); 
           //SaveFile(@"c:\msmqlog.txt", "删除" + index + "条消息,每条大小约40k，时间：" + watch.Elapsed.ToString());

多线程读取消息

Thread t1 = new Thread(() =&gt; receive("1"));//使用拉姆达表达式往线程中传参数 
           Thread t2 = new Thread(() =&gt; receive("2")); 
           Thread t3 = new Thread(() =&gt; receive("3")); 
           Thread t4 = new Thread(() =&gt; receive("4"));

t1.Start(); 
           t2.Start(); 
           t3.Start(); 
           t4.Start();

t1.Join(); 
           t2.Join(); 
           t3.Join(); 
           t4.Join();

Console.WriteLine(); 
       }

//GetMessageEnumerator2()方式取消息，

//在并发情况下，可能游标所指定的消息被其他线程删除，抛异常。

static public void GetMessage(string i) 
       { 
           MessageQueue queue = new System.Messaging.MessageQueue(path); 
           MessageEnumerator me = queue.GetMessageEnumerator2(); 
           int index = 0; 
           while (me.MoveNext()) 
           { 
               try 
               { 
                   Console.Write(me.Current.Id + "-"); 
                   Console.WriteLine(++index); 
                   string s = me.Current.Id + "-"; 
                   SaveFile(@"c:\" + i + ".txt", s + index); 
                   me.RemoveCurrent(); 
                   me.Reset(); 
               } 
               catch (Exception ex) 
               { 
                   SaveFile(@"c:\" + i + ".txt", ex.Message); 
               } 
           } 
       }

//Receive方式取消息

static public void receive(string i) 
       { 
           MessageQueue queue = new System.Messaging.MessageQueue(path);

while (true) 
           { 
               try 
               { 
                   Message me= queue.Receive(new TimeSpan(0,0,1)); 
                   me.Formatter = new System.Messaging.XmlMessageFormatter((new Type[] { typeof(string) })); 
                   Console.WriteLine(me.Id + "-"); 
                   SaveFile(@"c:\" + i + ".txt", me.Id); 
               } 
               catch (MessageQueueException ex1) 
               { 
                   if (ex1.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout) 
                   { 
                       Console.WriteLine("MessageQueueErrorCode.IOTimeout"); 
                       SaveFile(@"c:\" + i + ".txt", "MessageQueueErrorCode.IOTimeout"); 
                       Thread.Sleep(5000); 
                   } 
               } 
               catch (Exception ex) 
               { 
                   Console.WriteLine(ex.Message); 
                   SaveFile(@"c:\" + i + ".txt", ex.Message); 
               } 
           } 
       }

static public void send() 
       { 
           string s = ReadFile(@"c:\pp.txt"); 
           MessageQueueTransactionType transactionType = MessageQueueTransactionType.None; 
           MessageQueue queue = new System.Messaging.MessageQueue(path); 
           //int j = 10000; 
           for (int i = 0; i &lt; 1250; i++) 
           { 
               Console.WriteLine(i); 
               queue.Send(s, transactionType); 
           } 
           queue.Close(); 
       }