博文纲领：
消息队列常见的使用场景
通过消息队列，可以将耗时操作异步化，从而避免阻塞主线程，提高系统的响应速度和吞吐量。削峰填谷：在高并发场景下，消息队列可以作为一个缓冲区，平滑瞬时流量高峰，保护后端系统不被压垮。同时，在低并发时，可以从队列中取出消息进行处理，实现资源的合理利用。日志处理：消息队列可以用于日志的收集和处理。
从而实现高性能、高可用与可扩展架构。常见的消息队列包括ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ与RocketMQ。接下来，我们将探讨消息队列在实际应用中的四大使用场景：异步处理、应用解耦、流量削峰以及日志处理。
消息队列在实际应用中有多种使用场景。其中，异步处理、应用解耦、流量削峰、日志处理和消息通讯是最常见的应用模式。异步处理场景中，消息队列允许我们将非关键业务逻辑异步处理。例如，用户注册后，需要发送注册邮件和短信，可以将注册信息写入数据库成功后，将任务写入消息队列。
消息队列的七种经典应用场景，涵盖异步解耦、消峰、消息总线、延时任务、广播消费、分布式事务以及数据中转枢纽。通过消息队列的运用，企业能在复杂系统中实现更高效、稳定和灵活的处理。在异步解耦场景中，如电商用户服务与短信发送，将新增用户操作与短信发送分隔，利用消息队列实现解耦，提高服务稳定性。
消息队列具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，因此逐渐成为企业IT系统内部通信的核心手段之一。
消息队列的常见使用场景 **商品秒杀**：在高并发场景下，消息队列可以缓解服务器压力。商品秒杀时的大量请求，通过先写入消息队列再处理，避免了同时处理多个请求导致的响应延迟和服务器超载。 **系统解耦**：通过消息队列，可以将业务逻辑模块化，实现各功能的独立部署和扩展。
分布式事务之可靠消息最终一致性、最大努力通知
可靠消息最终一致性方案在分布式事务中扮演重要角色，它确保消息发送至事务参与方后，最终数据达到一致状态。此方案通过引入本地消息表实现，以解决跨服务、跨数据库场景下的事务一致性问题。以订单服务与库存服务为例，订单服务执行本地事务后，会同时在本地消息表中记录订单创建事件。
MQ事务消息：基于MQ的事务消息方案利用MQ内部的事务提交接口，将本地消息表逻辑封装在MQ中，提高消息处理的可靠性。RocketMQ提供的事务消息接口支持在异常情况下进行二次确认，确保事务的一致性。
结合MQ消息中间件实现的可靠消息最终一致性 TCC补偿性事务解决方案 最大努力通知型方案 第一种方案：可靠消息最终一致性，需要业务系统结合MQ消息中间件实现，在实现过程中需要保证消息的成功发送及成功消费。
订单处理：本地事务 资金账户加款、积分账户增加积分：TCC型事务（或两阶段提交型事务），实时性要求比较高，数据必须可靠。
最大努力通知：适用于对最终一致性实时性要求不高的业务场景，如支付通知、短信通知。Seata：Seata是一个分布式事务调度系统，对业务无侵入，实现全局事务的一致性。Paxos算法：基于消息传递的高效容错一致性算法，广泛应用于分布式系统中。Raft算法：与Paxos类似，但更易于理解，用于选举Leader，实现一致性。
MQ什么意思
1、MQ（Message Queue）消息队列，是基础数据结构中“先进先出”的一种数据结构。一般用来解决应用解耦，异步消息，流量削峰等问题，实现高性能，高可用，可伸缩和最终一致性架构。MQ的缺点[3]系统可用性降低。依赖服务越多，服务越容易挂掉。需要考虑MQ瘫痪的情况 系统复杂性提高。
2、EQ代表情商，MQ代表心商。EQ，即Emotional Quotient，是指个人的情绪智力或情绪智商，它涉及自我情绪管理以及对他人情绪的调控能力，与智商(IQ)密切相关。情商的形成始于婴幼儿时期，并在儿童和青少年阶段得到巩固，主要通过人际交往的实践来培养。在青春期，提升情商的有效途径之一是心理训练。
3、MQ是Message Queue的缩写，翻译为消息队列。它是一种基于异步通信的消息传递模型，用于解决分布式系统中应用程序之间的数据传输与通信问题。通过MQ，消息生产者可以将消息发布到队列中，而消费者可以从队列中获取消息并进行处理。
Golang微服务框架Kratos应用Pulsar消息队列
需要注意的是，虽然Pulsar的接口与Kafka有所不同，但Kratos已经对Pulsar进行了封装，使得开发者可以像使用Kafka一样使用Pulsar。通过以上步骤，Golang微服务框架Kratos可以成功地应用Pulsar消息队列，实现微服务间的高效、可靠通信。
Kratos应用Pulsar封装Pulsar客户端为Kratos的transport.Server，实现Broker和Server层引用。在Data层引用Broker，注入至Wire的ProviderSet，创建Broker并在Service中调用。在Server层引用Server，调用kratos.Server注册到Kratos，完成消息处理。实例代码与接口定义在开源项目中提供，适用于Kafka接口，仅参数差异。
消息队列，一种异步服务间通信方式，对于无服务器和微服务架构至关重要。消息在处理前存储，并只能被一次处理。它们用于减轻高峰负载、缓冲和批处理任务。消息队列在大型分布式系统中不可或缺，是构建高并发系统的基础。
消息队列是构建大型分布式系统不可或缺的中间件，也是高并发系统基石，因此掌握MQ技术变得至关重要。本文将深入探讨消息队列的定义、Kafka作为MQ的实例，以及如何在微服务框架Kratos中应用Kafka进行业务开发。
在Golang微服务框架Kratos中，应用NSQ消息队列的方式和作用如下：角色与重要性：核心组件：NSQ在Kratos微服务框架中作为异步服务间通信的核心组件，适用于无服务器架构和微服务环境。任务解耦与负载均衡：通过消息队列，任务被存储在队列中直到被处理和删除，实现了任务的解耦和负载均衡。