1. 程式人生 > >C# Queue與RabbitMQ的愛恨情仇(文末附原始碼):Q與MQ訊息佇列簡單應用(一)

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("\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類來表示,該類表示表示物件的先進先出集合,其位於System.Collections名稱空間下。

佇列在按接收順序儲存訊息方面非常有用,以便於進行順序處理。Queue類將佇列作為迴圈陣列實現,儲存在Queue類中的物件在一端插入,從另一端移除。

這種方式不需其他花裡胡哨的東西,新建好專案直接編寫程式碼即可。

 這個的原始碼已經在上的程式碼裡面了,直接拷貝執行就可以的,

下面我們講解訊息佇列MQ(Message Queue),

這個就需要下載RabbitMQ、Erlang環境並安裝,下載RabbitMQ.Client客戶端進行引用,附帶原始碼。