C# RabbitMQ（一）介绍

什么是消息队列

顾名思义，这是一个消息按顺序排列的集合，遵循的是先进先出原则，队列中存放的是Message。
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。
目前在生产环境，使用较多的消息队列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ等。
消息队列应用场景：异步处理、应用解耦、流量削锋、日志处理和消息通讯。
首先消息队列的应用场景：

异步处理：
其中提及串行方式和并行方式，这两者本身在效率方面就是并行方式效率高一些。那为啥异步处理能比并行方式处理效率还高呢？？明明人家都并行处理的说呢，哭唧唧。在理解消息队列后，顿悟！原来加入消息队列以后，直接将有用的信息写入消息队列，就直接返回执行结果啦，个人理解就是先将信息放在消息队列中，不-用等到真的接收到实时的操作返回结果，这种情况下只消耗了将消息写进消息队列的时间，那是板上钉钉的快多啦！！（也许到这里有人会有疑问，那返回结果可咋办呢，哈哈哈哈，好巧，我也有这个疑问。后来了解到，可以在消息队列中设置规则，比如消息队列里消息过期时间啊，设置一个标志用来接收订阅方返回的消息呀啥的，真鸡智！）

应用解耦：
这个大家应该很容易理解，因为爱网购的网狗们就比较熟悉这个。我们在淘宝下单应该都没失败过吧，如果失败了就是心里大骂180遍，想花钱都不行！！！仔细想想，万一我们下单的时候马爸爸的库存系统崩了，是不是真的下不了单呢，那肯定不能，那损失可大了。所以顺着原作者思路走，确实是这个理儿，下单归下单，库存归库存。用户下单以后，即使当时库存系统崩了，但是订单信息我们写入消息队列啦，不用管库存啥的啦，马爸爸一点都不方的，咱再从消息队列多转储几次就好啦！！等到库存系统正常减少以后，返回一个信息到消息队列就好啦！！多完美的剁手旅程！！

流量削锋
马爸爸搞秒杀活动啦！！但是相信大家都会经历过进不了购物页面，或者进去了不小心退出来就再也进不去的场景吧，嗯，是的，痛心疾首！！现在我算是知道了商家的小九九。原来可能利用了消息队列直接拒绝了我们的消息请求呢！这个仇我记住了！！服务器在接收我们这些小白用户的请求后，将我们的请求写入了消息队列，如果消息队列中消息数量超过最大数量，不幸运的我们就被直接拒绝啦，或者直接跳到错误界面。。。不过现在想想好像还没有直接进入过错误界面，可能是出于用户体验的考虑，直接跳转到空白页面了吧。。。太惨了，每一次抢不到的秒杀都是人间悲剧！！

日志处理
大量日志传输的情况我是真的没有遇到过，毕竟人家还太小没遇到过这种大风大浪。不过顺着上面这几种情况的思路想想，无非就是，先把信息找个仓库先存着呗，以后再让仓库再慢慢转发，这个仓库就是消息队列啦！！此处解释堪称完美！！

消息通讯
没想到消息队列这么好用，原作者提到消息队列一般都内置了高效的通信机制，因此可以用在纯的消息通讯（ps:我是真的没理解纯的是啥意思！！一脸问号！）。实现点对点消息队列、聊天室等。
点对点通讯：两个人共用一个消息队列。
聊天室通讯：好多人共用一个消息队列。

为什么要用RabbitMQ消息队列

消息队列是啥：消息队列（Message Queue），一种先进先出的队列结构，用于处理Message。
消息队列解决的问题：在处理大量并发请求时，同步处理往往会发生阻塞，特别是在更新数据库或者调用其他组件时。消息队列能够实现请求的异步处理、应用解耦、流量削锋和消息通讯，同时能够有效防止阻塞导致的消息丢失。
消息队列系统，一般都包含3个角色：队列服务端，队列的生产者，队列的消费者。这种架构与当下流行的分布式架构极为契合。

在使用RabitMQ之前，先对几个概念做一下说明

RabbitMQ是一个消息代理。他从消息生产者(producers)那里接收消息，然后把消息送给消息消费者（consumer）在发送和接受之间，他能够根据设置的规则进行路由，缓存和持久化。

一般提到RabbitMQ和消息，都用到一些专有名词。

生产(Producing)意思就是发送。发送消息的程序就是一个生产者(producer)。我们一般用"P"来表示：
在这里插入图片描述
队列(queue)就是邮箱的名称。消息通过你的应用程序和RabbitMQ进行传输，它们只能存储在队列（queue）中。队列（queue）容量没有限制，你要存储多少消息都可以——基本上是一个无限的缓冲区。多个生产者（producers）能够把消息发送给同一个队列，同样，多个消费者（consumers）也能从同一个队列（queue）中获取数据。队列可以画成这样（图上是队列的名称）：
在这里插入图片描述
消费（Consuming）和获取消息是一样的意思。一个消费者（consumer）就是一个等待获取消息的程序。我们把它画作"C"：
在这里插入图片描述
####　通常，消息生产者，消息消费者和消息代理不在同一台机器上。