MSMQ(3)创建、同步异步接收消息

一、创建一个队列

 if (!MessageQueue.Exists(".\\Private$\\newPublicQueue"))
        }

二、同步接收消息

1）接收消息，接受成功后删除

 MessageQueue queue = new MessageQueue(".\\Private$\\newPublicQueue");

        Message message = queue.Receive();// Receive message, 同步的Receive方法阻塞当前执行线程，直到一个message可以得到，接收之后就删除
 message.Body.ToString();

2）接受消息，接收成功后保留

  MessageQueue queue = new MessageQueue(".\\Private$\\newPublicQueue");

        Message message = queue.Peek();// 异步接收消息。接收之后不删除
 message.Body.ToString();

三、异步接收消息
1）接收消息，接受成功后删除

 MessageQueue queue = new MessageQueue(".\\Private$\\newPublicQueue");

        // queue.BeginReceive();// 异步接收消息。接收之后就删除
        // 给接收结束加一个委托
        queue.ReceiveCompleted +=
            new ReceiveCompletedEventHandler(MyReceiveCompleted);

        //开始接收
        queue.BeginReceive();
private static void MyReceiveCompleted(Object source, 
            ReceiveCompletedEventArgs asyncResult)
        }

2）接受消息，接收成功后保留

 MessageQueue queue1 = new MessageQueue(".\\Private$\\newPublicQueue");

        // queue.BeginReceive();// 异步接收消息。接收之后就删除
        // 给接收结束加一个委托
        queue1.PeekCompleted +=
            new PeekCompletedEventHandler(PeekMyReceiveCompleted);

        //开始接收
        queue1.BeginPeek();
private static void PeekMyReceiveCompleted(Object source,
           PeekCompletedEventArgs asyncResult)
    }

完整代码下载