消息队列MQ(Message Queue)
消息(Message)：服务间通信的数据；
队列(Queue)：一种先进先出的数据结构；
消息队列：消息的传输过程中保存消息的容器，使用消息将应用程序连接起来。
生产者：把数据放到消息队列的一方；
消费者：从消息队列里边取数据的一方。
一般来说，消息队列是一种异步的服务间通信方式，是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题，实现系统的高性能，高可用，可伸缩，使用较多的消息队列有RocketMQ、RabbitMQ、Kafka等。
使用场景
消息队列在实际应用中包括如下三个场景：解耦，异步，削峰
应用耦合：多应用间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败；
例如：电商之间的各系统，订单系统、库存系统、物流系统、支付系统。
异步处理：多应用对消息队列中同一消息进行处理，应用间并发处理消息，相比串行处理，减少处理时间；不需要立即处理请求的场景下，可以将请求放入消息系统。
例如：服务间调用是异步的
限流削峰：广泛应用于秒杀或抢购活动中，避免流量过大导致应用系统挂掉的情况；
消费者怎么从消息队列里边得到数据？
有两种办法：
- 生产者将数据放到消息队列中，消息队列有数据了，主动叫消费者去拿(俗称push)
- 消费者不断去轮训消息队列，看看有没有新的数据，如果有就消费(俗称pull)
消息的可靠传输
生产者弄丢数据
生产者将数据发送到MQ的时候，因为网络啥的问题，可能数据就在半路给搞丢了。
①事务：生产者发送数据之前开启事务(channel.txSelect)，发送消息丢失后返回异常报错，执行回滚事务(channel.txRollback)，事务机制一搞，基本上吞吐量会下来，因为太耗性能。
②confirm模式：设置开启confirm模式，消息分配一个唯一的id，消息队列回传一个ack消息，告诉你说这个消息ok了。没能处理这个消息，会回调你一个nack接口，告诉你这个消息接收失败，你可以重试。如果超过一定时间还没接收到这个消息的回调，那么你可以重发。
优先使用confirm模式
MQ弄丢数据
MQ自己弄丢了数据，需要开启MQ的持久化，就是消息持久化到磁盘，
消费者弄丢数据
MQ提供的ack机制，可以通过一个api来调用，然后每次代码里确保处理完的时候，再程序里ack一把。这样的话，如果还没处理完，是没有ack的。
消息的重复问题
分为两大类情况：1、生产者消息重复发送； 2.MQ向消费者投递时重复投递
终极解决办法：幂等性
标签：知识点,异步,队列,基础,处理,MQ,消息,数据 来源： https://blog.csdn.net/qq_42410605/article/details/122517789
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。