C# Queue与RabbitMQ的爱恨情仇(文末附源码):Q与MQ消息队列简单应用(一) 时间 2019-06-03 14:09:00 博客园
首先我们简单了解一下什么堆、栈、队列。
堆是在程序运行时,而不是在程序编译时,申请某个大小的内存空间。即动态分配内存,对其访问和对一般内存的访问没有区别。
栈就是一个容器,后放进去的先拿出来,它下面本来有的东西要等它出来之后才能出来。(先进后出or后进先出)
队列只能在队头做删除操作,在队尾做插入操作.而栈只能在栈顶做插入和删除操作。(先进先出)
注意:当前展示的是队列(Queue),下一章展示消息队列MQ(Message Queue)
队列(Queue)代表了一个 先进先出 的对象集合。当您需要对各项进行先进先出的访问时,则使用队列。
当您在列表中添加一项,称为 入队 ,当您从列表中移除一项时,称为 出队 。
- 入队 就是在队列的尾部添加数据,队列数据个数加一,尾指针后移;
- 出队 就是在队列的头部取数据,然后删除该数据,头指针后移。
常用的属性&描述
- Count:Count属性返回队列中元素个数。
- Enqueue:Enqueue()方法在队列一端添加一个元素。
- Dequeue:Dequeue()方法在队列的头部读取和删除元素。如果在调用Dequeue()方法时,队列中不再有元素,就抛出一个InvalidOperationException类型的异常。
- Peek:Peek()方法从队列的头部读取一个元素,但不删除它。
- TrimExcess:TrimExcess()方法重新设置队列的容量。Dequeue()方法从队列中删除元素,但它不会重新设置队列的容量。要从队列的头部去除空元素,应使用TrimExcess()方法。
- Clear:Clear()方法从队列中移除所有的元素。
- 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客户端进行引用,附带源码。
C# Queue与RabbitMQ的爱恨情仇(文末附源码):Q与MQ消息队列简单应用(一) 时间 2019-06-03 14:09:00 博客园相关推荐
- C# Queue与RabbitMQ的爱恨情仇(文末附源码):Q与MQ消息队列简单应用(一)
首先我们简单了解一下什么堆.栈.队列. 堆是在程序运行时,而不是在程序编译时,申请某个大小的内存空间.即动态分配内存,对其访问和对一般内存的访问没有区别. 栈就是一个容器,后放进去的先拿出来,它下面本 ...
- 「项目实战」有一说一这才是RabbitMQ实现分布式事务的正确姿势(附源码)
不懂就问 灵魂拷问之☞导盲犬禁止入内是给犬看的还是盲人看的? 各位巨佬们把答案留在评论区吧 分布式事务 随着互联网快速发展,微服务,SOA 等服务架构模式正在被大规模的使用,现在分布式系统一般由多个独 ...
- 计算机毕业设计SSM爱宝贝影楼管理系统【附源码数据库】
项目运行 环境配置: Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(IntelliJ IDEA,Eclispe,MyEclis ...
- 【Pygame小游戏】这款经典的炸弹人超能游戏上线,你爱了嘛?(附源码)
前言
- java毕业设计我爱短视频管理系统(附源码、数据库)
项目运行 环境配置: Jdk1.8 + Tomcat8.5 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(IntelliJ IDEA,Eclispe,MyEclis ...
- 同步通信和异步通信的爱恨情仇
前言 一开始在学习JMS的时候,心中一直有一个疑惑,由于那时候对JMS的了解还不够深入,我当时很不理解传统的RPC远程过程调用和java消息服务有什么区别,他们两不都是在两个不同的分布式或者集群系统传 ...
- nyist 第二次招新赛 I 董学姐与朱学姐的爱恨情仇
董学姐与朱学姐的爱恨情仇. - NYOJ 思路: 首先我们可以假定朱学姐一定是赢的,那么我们要保证朱学姐一定是第一个拿到最后一堆的,那么我们就考虑在前n个石头之后朱学姐能不能继续保持先手. 首先, ...
- Spring发展史! 和那些巨头的爱恨情仇!
** 码农的春天----------Spring来了 关于Spring的发展起源要回溯到2002年,当时正是Java EE和EJB大行其道的时候,很多知名公司都是采用此技术方案进行项目开发.这时候有一 ...
- 产品经理和程序员的爱恨情仇
产品经理跪求程序员,程序员跪求程序成功上线! 前几天纯银V在微博上发了一条微博「很多人吐槽"人人都是产品经理"这句话,其实在我看来,这句话的正确理解是"人人都应该学习产品 ...
最新文章
- linux 命令博客,Linux 命令
- 网络推广——网络推广优化基础问题必须明确
- JTable设置列宽、自动调整
- data transformation python_Python数据分析(方睿)
- 差距50倍!为什么Web API第一次执行这么慢?
- 将Java 8日期时间API与JSF和Java EE 7结合使用
- C++ string 介绍
- java 子类的同名方法_java 父类子类有同名方法时如何调用的实现
- 物理层传输介质(双绞线、光纤等)
- 使用SQLite数据库存储数据(4)-删除数据记录
- missingno库—缺失值可视化
- 推荐算法初探---CF、LR
- htmlcleaner+xpath抓取网页数据
- WINDOWS XP数字总线补丁 KB888111
- mic in和line in
- Vue3中点击箭头切换图片
- MinGW-w64没有bin文件解决方法
- 学生计算机教室怎么连接网络,计算机(网络)教室学生使用守则
- 使用Incapsula免费CDN加速godaddy空间
- Android8.0 WIFI ap Tethering 相关知识