C# Queue与RabbitMQ的爱恨情仇（文末附源码）：Q与MQ消息队列简单应用（一）

首先我们简单了解一下什么堆、栈、队列。

堆是在程序运行时，而不是在程序编译时，申请某个大小的内存空间。即动态分配内存，对其访问和对一般内存的访问没有区别。

栈就是一个容器，后放进去的先拿出来，它下面本来有的东西要等它出来之后才能出来。（先进后出or后进先出）

队列只能在队头做删除操作,在队尾做插入操作.而栈只能在栈顶做插入和删除操作。（先进先出）

---

注意：当前展示的是队列（Queue），下一章展示消息队列MQ（Message Queue）

队列（Queue）代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时，则使用队列。

当您在列表中添加一项，称为入队，当您从列表中移除一项时，称为出队。

1. 入队就是在队列的尾部添加数据，队列数据个数加一，尾指针后移； 
2. 出队就是在队列的头部取数据，然后删除该数据，头指针后移。

---

常用的属性&描述

1. Count：Count属性返回队列中元素个数。
2. Enqueue：Enqueue()方法在队列一端添加一个元素。
3. Dequeue：Dequeue()方法在队列的头部读取和删除元素。如果在调用Dequeue()方法时，队列中不再有元素，就抛出一个InvalidOperationException类型的异常。
4. Peek：Peek()方法从队列的头部读取一个元素，但不删除它。
5. TrimExcess：TrimExcess()方法重新设置队列的容量。Dequeue()方法从队列中删除元素，但它不会重新设置队列的容量。要从队列的头部去除空元素，应使用TrimExcess()方法。
6. Clear：Clear()方法从队列中移除所有的元素。
7. ToArray：ToArray()复制队列到一个新的数组中。

---

下面我们结合一个实例进行简单讲解：

实例：将用户下单信息加入到队列中并读取队列。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace QueueConsoleApplication
{
   
   public class Program
    {

        //实例：将用户下单信息加入到队列中并读取队列。
       static void Main(string[] args)
       {
           //创建一个队列
           Queue<UserInfo> queue = new Queue<UserInfo>();

           //获取用户下单列表
           List<UserInfo> userList = GetUserList();

           //使用Enqueue()方法将用户下单信息加入到队列中（入列）
           foreach (var user in userList)
           {
               queue.Enqueue(user);
           }

           //使用Count属性获取队列中元素个数
           int queueCount = queue.Count;
           Console.WriteLine(string.Format("队列中有{0}个用户下单信息。", queueCount));  //输出

           //使用Dequeue()方法从队列的头部读取和删除元素（出列）
           for (int i = 0; i < queueCount; i++)
           {
               UserInfo user = queue.Dequeue();
               Console.WriteLine(string.Format("
单号：{0}；用户名称：{1}；手机号：{2}；收货地址：{3}；商品名称：{4}；价格：{5}",
                   user.ID, user.Name, user.Phone, user.Address, user.Commodity, user.Price));
           }

           //使用Count属性获取队列中元素的格式
           queueCount = queue.Count;
           Console.WriteLine(string.Format("
队列中有{0}个用户下单信息。", queueCount));  //输出

       }

       /// <summary>
       /// 获取用户列表
       /// </summary>
       /// <returns></returns>
        public static List<UserInfo> GetUserList()
        {
            List<UserInfo> userList = new List<UserInfo>();
            userList.Add(new UserInfo("201906031010", "王母", "1821234****", "昆仑山玉虚宫", "9万年蟠桃", 136.00));
            userList.Add(new UserInfo("201906031011", "喜洋洋", "1821235****", "青青草原羊村", "狼堡牌无毒除虫剂", 198.00));
            userList.Add(new UserInfo("201906031012", "光头强", "1821236****", "狗熊岭光头强家", "捕兽夹", 346.00));
            userList.Add(new UserInfo("201906031013", "孙悟空", "1821237****", "花果山", "去虱粉", 245.00));
            return userList;
        }
    }

    /// <summary>
    /// 用户下单信息实体类
    /// </summary>
    public class UserInfo
    {
        public UserInfo(string id, string name, string phone, string address, string commodity, double price)
        {
            this.ID = id;  
            this.Name = name;
            this.Phone = phone;
            this.Address = address;
            this.Commodity = commodity;
            this.Price = price;
                
        }
        public string ID { get; set; }   //单号
        public string Name { get; set; }  //姓名
        public string Phone { get; set; }  //手机号
        public string Address { get; set; }  //收货地址
        public string Commodity { get; set; }  //商品名称
        public double Price { get; set; }  //价格
    }

    
}

首先准备一个有内容的队列，结合先进先出的原则，我们读取队列里面的消息进行打印。

入队的信息可以动态插入，我们这里演示就写入指定数据。

运行代码后我们在控制台打印相关信息，如下图：

总结：

C#中提供了队列类，用Queue类来表示，该类表示表示对象的先进先出集合，其位于System.Collections命名空间下。

队列在按接收顺序存储消息方面非常有用，以便于进行顺序处理。Queue类将队列作为循环数组实现，存储在Queue类中的对象在一端插入，从另一端移除。

这种方式不需其他花里胡哨的东西，新建好项目直接编写代码即可。

 这个的源码已经在上的代码里面了，直接拷贝运行就可以的，

下面我们讲解消息队列MQ（Message Queue），

这个就需要下载RabbitMQ、Erlang环境并安装，下载RabbitMQ.Client客户端进行引用，附带源码。

欢迎关注订阅我的微信公众平台【熊泽有话说】，更多好玩易学知识等你来取
作者：熊泽-学习中的苦与乐
公众号：熊泽有话说
出处：https://www.cnblogs.com/xiongze520/p/10967270.html
创作不易，任何人或团体、机构全部转载或者部分转载、摘录，请在文章明显位置注明作者和原文链接。