消息队列（英语：Message queue）是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通常是来自使用者。消息队列提供了异步的通信协议，每一个贮列中的纪录包含详细说明的资料，包含发生的时间，输入装置的种类，以及特定的输入参数，也就是说：消息的发送者和接收者不需要同时与消息队列互交。消息会保存在队列中，直到接收者取回它。

简单的说队列就是贮存了我们需要处理的Command但是并不是及时的拿到其处理结果；

实际上，消息队列常常保存在链表结构中。拥有权限的进程可以向消息队列中写入或读取消息。

目前，有很多消息队列有很多开源的实现，包括JBoss Messaging、JORAM、Apache ActiveMQ、Sun Open Message Queue、Apache Qpid和HTTPSQS。

消息队列本身是异步的，它允许接收者在消息发送很长时间后再取回消息，这和大多数通信协议是不同的。例如WWW中使用的HTTP协议是同步的，因为客户端在发出请求后必须等待服务器回应。然而，很多情况下我们需要异步的通信协议。比如，一个进程通知另一个进程发生了一个事件，但不需要等待回应。但消息队列的异步特点，也造成了一个缺点，就是接收者必须轮询消息队列，才能收到最近的消息。

和信号相比，消息队列能够传递更多的信息。与管道相比，消息队列提供了有格式的数据，这可以减少开发人员的工作量。但消息队列仍然有大小限制。

主要有两种（1）服务端的推；（2）客户端的拉；

拉：主要是客户端定时轮询拿走消息处理；

推：通过事件订阅方式主动通知订阅者进行处理；

{public delegate void MessageQueueEventNotifyHandler(Message.BaseMessage message);public class MessageQueue:Queue<BaseMessage>{public static MessageQueue GlobalQueue = new MessageQueue();private Timer timer = new Timer();public MessageQueue() {this.timer.Interval = 5000;this.timer.Elapsed += Notify;this.timer.Enabled = true;}private void Notify(object sender, ElapsedEventArgs e) {lock (this) {if (this.Count > 0) {//this.messageNotifyEvent.GetInvocationList()[0].DynamicInvoke(this.Dequeue());var message = this.Dequeue();this.messageNotifyEvent(message);}}}private MessageQueueEventNotifyHandler messageNotifyEvent;public event MessageQueueEventNotifyHandler MessageNotifyEvent {add {this.messageNotifyEvent += value;}remove {if (this.messageNotifyEvent != null) {this.messageNotifyEvent -= value;}}}}
}

public const string OrderCodePrefix = "P";public void Submit(Message.BaseMessage message){Order order = message.Body as Order;if (order.OrderCode.StartsWith(OrderCodePrefix)){System.Console.WriteLine("这个是个正确的以({0})开头的订单:{1}", OrderCodePrefix,order.OrderCode);}else {System.Console.WriteLine("这个是个错误的订单，没有以({0})开头:{1}",OrderCodePrefix,order.OrderCode);}}

public class OrderServiceProxy:IOrderService{public void Submit(Message.BaseMessage message){MessageQueue.MessageQueue.GlobalQueue.Enqueue(message);}}

OrderService orderService = new OrderService();MessageQueue.MessageQueue.GlobalQueue.MessageNotifyEvent += orderService.Submit;var orders = new List<Order>() { new Order(){OrderCode="P001"},new Order(){OrderCode="P002"},new Order(){OrderCode="B003"}};OrderServiceProxy proxy = new OrderServiceProxy();orders.ForEach(order => proxy.Submit(new Message.BaseMessage() { Body=order}));Console.ReadLine();