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客户端进行引用,附带源码。

相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
11月前
|
存储 监控 算法
基于 C# 时间轮算法的控制局域网上网时间与实践应用
在数字化办公与教育环境中,局域网作为内部网络通信的核心基础设施,其精细化管理水平直接影响网络资源的合理配置与使用效能。对局域网用户上网时间的有效管控,已成为企业、教育机构等组织的重要管理需求。这一需求不仅旨在提升员工工作效率、规范学生网络使用行为,更是优化网络带宽资源分配的关键举措。时间轮算法作为一种经典的定时任务管理机制,在局域网用户上网时间管控场景中展现出显著的技术优势。本文将系统阐述时间轮算法的核心原理,并基于 C# 编程语言提供具体实现方案,以期深入剖析该算法在局域网管理中的应用逻辑与实践价值。
275 5
|
10月前
|
消息中间件 存储 大数据
阿里云消息队列 Kafka 架构及典型应用场景
阿里云消息队列 Kafka 是一款基于 Apache Kafka 的分布式消息中间件,支持消息发布与订阅模型,满足微服务解耦、大数据处理及实时流数据分析需求。其通过存算分离架构优化成本与性能,提供基础版、标准版和专业版三种 Serverless 版本,分别适用于不同业务场景,最高 SLA 达 99.99%。阿里云 Kafka 还具备弹性扩容、多可用区部署、冷热数据缓存隔离等特性,并支持与 Flink、MaxCompute 等生态工具无缝集成,广泛应用于用户行为分析、数据入库等场景,显著提升数据处理效率与实时性。
|
消息中间件 存储 监控
深度写作:深入源码理解MQ长轮询优化机制
【11月更文挑战第22天】在分布式系统中,消息队列(Message Queue, MQ)扮演着至关重要的角色。MQ不仅实现了应用间的解耦,还提供了异步消息处理、流量削峰等功能。而在MQ的众多特性中,长轮询(Long Polling)机制因其能有效提升消息处理的实时性和效率,备受关注。
602 12
|
存储 安全 物联网
C# 在物联网 (IoT) 应用中的应用
本文介绍了C#在物联网(IoT)应用中的应用,涵盖基础概念、优势、常见问题及其解决方法。重点讨论了网络通信、数据处理和安全问题,并提供了相应的代码示例,旨在帮助开发者更好地利用C#进行IoT开发。
687 3
|
消息中间件 存储 Java
深入源码理解MQ长轮询优化机制
【11月更文挑战第22天】在分布式系统中,消息队列(MQ)作为一种重要的中间件,广泛应用于解耦、异步处理、流量削峰等场景。其中,延时消息和定时消息作为MQ的高级功能,能够进一步满足复杂的业务需求。为了实现这些功能,MQ系统需要进行一系列优化,长轮询机制便是其中的关键一环。本文将深入探讨MQ如何设计延时消息和定时消息的优化机制,特别是长轮询机制的实现原理及其在Java中的模拟实现。
314 2
|
消息中间件 存储 Kafka
MQ 消息队列核心原理,12 条最全面总结!
本文总结了消息队列的12个核心原理,涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
|
编译器 C#
c# - 运算符<<不能应用于long和long类型的操作数
在C#中,左移运算符的第二个操作数必须是 `int`类型,因此需要将 `long`类型的位移计数显式转换为 `int`类型。这种转换需要注意数据丢失和负值处理的问题。通过本文的详细说明和示例代码,相信可以帮助你在实际开发中正确使用左移运算符。
236 3
|
编译器 C#
c# - 运算符<<不能应用于long和long类型的操作数
在C#中,左移运算符的第二个操作数必须是 `int`类型,因此需要将 `long`类型的位移计数显式转换为 `int`类型。这种转换需要注意数据丢失和负值处理的问题。通过本文的详细说明和示例代码,相信可以帮助你在实际开发中正确使用左移运算符。
376 2
|
消息中间件 负载均衡 算法
聊聊 RocketMQ中 Topic,Queue,Consumer,Consumer Group的关系
本文详细解析了RocketMQ中Topic、Queue、Consumer及Consumer Group之间的关系。文中通过图表展示了Topic可包含多个Queue,Queue分布在不同Broker上;Consumer组内多个消费者共享消息;并深入探讨了集群消费与广播消费模式下Queue与Consumer的关系,以及Rebalancing机制在实例增减时如何确保负载均衡。理解这些关系有助于更好地掌握RocketMQ的工作原理,提升系统运维效率。
3426 2
|
编译器 C#
c# - 运算符<<不能应用于long和long类型的操作数
在C#中,左移运算符的第二个操作数必须是 `int`类型,因此需要将 `long`类型的位移计数显式转换为 `int`类型。这种转换需要注意数据丢失和负值处理的问题。通过本文的详细说明和示例代码,相信可以帮助你在实际开发中正确使用左移运算符。
346 0
下一篇
开通oss服务