MQ都叫Message Queue，即消息队列。MQ是在消息传输期间存储消息的容器。这是典型的：生产者、消费者模式。我们如何将它用于项目的一般作用和那些场景，这封信将给你带来MQ概念和使用从无到有的过程。
和RabbitMQ的结局？
消息队列（MQ）是应用对应用的通信方法。RabbitMQ是使用Erlang语言开发的消息中间件，协议采用AMQP协议（稍后将描述AMQP协议）。AMQP协议为数据的完整性、稳定性和可靠性提供了出色的支持，牺牲了其性能和吞吐量。
一种常见的线索？
消息队列是在分布式应用之间交换信息的重要组件，并且独立地处理消息而不干扰队列中的每个服务。一般来说，可以使用队列来解决解锁、业务截止峰值、异步消息等的应用。现在一般的主流队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ等。
Kafka位于分布式架构中，RabbitMQ是基于AMQP协议实现的，RocketMQ采用主从结构，在交易可靠性方面具有一定的保障。如果交易有要求，考虑RabbitMQ或RocketMQ，如果性能要求高，考虑Kafka。
安装方式采用Docker方式，如果有不知道Docker的学生，强烈推荐大家赶紧学习。现在Docker和K8s等容器技术越来越受欢迎。不管面试和日常工作，这是我们需要的开发技能之一。
安装RabbitMQ：
启动RabbitMQ：
访问地址http://linuxip:15672啊，这里的用户名和密码默认为guest。
这里可能有学生还没有理解RabbitMQ，这个git正在从零开始学习RabbitMQ。这个部分看了很多次，可以更好地理解并使用RabbitMQ。接下来，理解队列中的专业术语。
Broker：消息队列服务器实体。Exchange：指定消息在哪个规则中路由到哪个队列的消息开关。Queue：在消息队列向量中，每一条消息都会被投入到一个或多个队列中。Binding：起到将exchange和queue绑定到路由规则的作用。Routing Key：路由关键字，exchange根据这个关键字进行消息传送。在虚拟主机中，您可以在一个braker上开设多个vhost，作为不同用户的权限分离使用。producter：消息生产者是发送消息的程序。信息消费者是接受信息的程序。channeel：在客户端的每个连接上建立多个channeel，每个channeel代表会话任务的消息信道。RabbitMQ执行流程图（熟悉原理时可组合查看）
1：当生产者向Exchange发送信息时，Routing Key指定信息流。2：使用Binding将Exchange与Que相关联，生产者可以通过指定routing key向Exchange发送信息来决定消息流向哪个Queue（Routing Key必须与Exchange Type合作使用）。3：消费者通过basic。订阅或basic。get命令（激活获取）获取并消耗消息。4：消费者在消费了消息之后，可以通过Ack或Reject来通知服务器的消息消费的结果。ack和Reject不同的是，ack通知服务器可以安全删除消息。basic.reject命令拒绝消息，如果是真的，则消息服务器将向下一个子置乱器重新发送消息。如果是假，信件将被直接删除。关于实行原理，我相信大家也有一定的理解。有ack还没来，返回到消息服务器怎么做，消息的重复消费等问题。大家的这些疑问在最后的总结部分会一一回答大家。
RabbitMQ中经常使用的Exchange Type，除了执行流程图的3种以外，headers、system、自定义等，基本上这里不怎么介绍。
fanout：fanout类型的Exchange路由规则非常简单，将发送到其Exchange的所有邮件路由到绑定的Quee。Direct：将信件路由至完全匹配的Queue。topic:direct类型的Exchange路由规则将binding key和routing key完全一致。topic虽然相似，但是通过匹配规则被扩展。topic的binding key存在两个特殊字符*和#，用于进行模糊匹配，*用于匹配一个单词，#用于匹配多个单词（也可以是零）。根据发送的信件内容的headers属性进行匹配。1.依赖引进
2.增加配置（博主在这里使用的Nacos，可以直接通过管理接口构成）
3.RabbitMQ配置类的配置（仅参考demo）
4.生产者
5.消费者
RabbitMQ的适用场景
服务间异步通信、序列消耗、业务截止峰值、定时任务。
为什么需要信息队列？
从常规单体项目到微服务架构，每个服务之间的相互呼叫和依赖是为了解决服务之间的耦合关系并控制业务资源高速缓存业务的峰值。简单来说，就是异步处理、业务截止峰值以及服务解联。
怎样保证生产者消息被发送到RabbitMQ服务器？如何保证消费者消费信息？
发送者将信道设置为确认模式，该消息在发送到信道的同时包括唯一的id，消费者在消费该消息之后携带消息id回呼叫MQ服务器确认消息。之后，MQ删除消息。
消费者在接收到消息后，确认各消息，仅在MQ接收到消费者确认消息请求的情况下删除服务器对应的消息，当然也携带唯一的消息id。
怎样才能避免重复发送和重复消费信息呢？
MQ在发布消息的同时为每个消息生成inner-msg-id，以避免消息作为递送依据被重复递送在消息消费时，一般以业务上唯一的id（订单号码、交易流程号码等）作为消息接收递送的依据，避免消息的重复消费。
怎么做才能不让信息丢失呢？（MQ的持续化）
实现RabbitMQ持久化的方法是将诸如消息队列之类的信息写入到其持久化日志文件中，RabbitMQ在发出持久化消息时，相应地提交到永久化日志文件中。当消费者消费该消息时，RabbitMQ被标记为等待该消息的垃圾回收处理。如果RabbitMQ在消息消耗前重新启动或瘫痪，RabbitMQ重新启动后会自动重建队列和开关，最后通过永续记录文件将信件重新发行到相应的队列。">。
欢迎在线观看电影《队列之末》，本视频由 2022手机版高清影视在线-众电影院https://www.zd-sh.com收集自网络。 如果你喜欢《队列之末》，请把它分享给的朋友，有您们的支持我们会做的更好。祝亲观影愉快！
Copyright © 2022 2022手机版高清影视在线-众电影院 Inc.All Rights reserved.
