消息队列\Message Queue\MQ

消息队列就是我们常说的MQ，英文叫Message Queue，是作为一个单独的中间件产品存在的，独立部署。

系统A->MQ->系统B

解耦

系统A通过MQ向多个子系统传输数据。

系统A写完消息后，不用等待系统B响应。

将某一段时间的超高流量分摊到更长的一段时间内去消化，避免了流量洪峰击垮系统。

Message Queue即消息队列，是一种在计算机系统中用于异步通信的重要技术，以下是关于它的详细介绍：

消息队列是一种数据结构，通常用于在不同的软件组件或系统之间传递消息。它基于先进先出（FIFO）的原则，就像一个排队系统，先进入队列的消息会先被处理。发送者将消息放入队列，而接收者从队列中获取消息进行处理，这样可以实现发送者和接收者之间的解耦，使它们能够独立地进行操作。

消息生产：消息的产生者（也称为生产者或发布者）创建消息，并将其发送到消息队列中。这些消息可以是各种类型的数据，如文本、JSON对象、二进制数据等，通常包含了需要传递的信息和相关的元数据。
消息存储：消息队列负责存储接收到的消息，它会按照消息到达的顺序将它们排列在队列中。消息队列通常会提供一定的持久化机制，以确保即使在系统故障或重启的情况下，消息也不会丢失。
消息消费：消息的消费者（也称为订阅者）从消息队列中获取消息并进行处理。消费者可以是一个或多个，它们会不断地监听消息队列，一旦有新消息到达，就会立即获取并进行相应的业务逻辑处理。

解耦：在一个大型的分布式系统中，不同的组件可能有不同的部署和运行节奏。消息队列允许这些组件之间通过消息进行通信，而不需要直接依赖对方。
异步处理：在一些业务场景中，某些操作可能比较耗时，如果采用同步处理，会导致系统的响应速度变慢。通过使用消息队列，这些耗时的操作可以被异步处理。
流量削峰：在系统面临高并发请求时，消息队列可以作为一个缓冲，将大量的请求暂时存储在队列中，然后按照系统能够处理的速度逐步处理这些请求，避免系统因瞬间高流量而崩溃。

电商系统：在电商系统中，下单、支付、库存更新等操作可能涉及多个不同的服务。使用消息队列可以将这些操作解耦，提高系统的稳定性和可扩展性。
日志处理：系统中的各个模块通常会产生大量的日志信息，将这些日志消息发送到消息队列中，然后由专门的日志处理服务从队列中获取日志进行存储、分析和可视化展示。
消息推送：在社交媒体、即时通讯等应用中，消息队列可以用于实现消息推送功能。当用户发送一条消息或进行某个操作时，相关的消息会被发送到消息队列，然后由推送服务从队列中获取消息并推送给相应的用户。

RabbitMQ：基于AMQP协议实现，具有丰富的插件生态系统，支持多种语言客户端，可靠性高，常用于企业级应用的消息通信。
Kafka：最初由LinkedIn开发，后成为Apache开源项目。它具有高吞吐量、可扩展性强的特点，主要用于处理大规模的实时数据，常用于日志收集、数据监控等场景。
RocketMQ：由阿里巴巴开源，具有低延迟、高并发、高可靠性等特点，在分布式事务消息、顺序消息等方面有很好的支持，广泛应用于电商、金融等领域。