欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-03-06 22:42:34
首先我们简单了解一下什么堆、栈、队列。 堆是在程序运行时,而不是在程序编译时,申请某个大小的内存空间。即动态分配内存,对其访问和对一般内存的访问没有区别。 栈就是一个容器,后放进去的先拿出来,它下面本来有的东西要等它出来之后才能出来。(先进后出or后进先出) 队列只能在队头做删除操作,在队尾做插入操 ......

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

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

就是一个容器,后放进去的先拿出来,它下面本来有的东西要等它出来之后才能出来。(先进后出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("\n单号:{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("\n队列中有{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与RabbitMQ的爱恨情仇(文末附源码):Q与MQ消息队列简单应用(一)

 

总结:

c#中提供了队列类,用queue类来表示,该类表示表示对象的先进先出集合,其位于system.collections命名空间下。

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

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

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

下面我们讲解消息队列mq(message queue),

这个就需要下载rabbitmq、erlang环境并安装,下载rabbitmq.client客户端进行引用,附带源码。