1、在选择消息队列技术时，Kafka、RabbitMQ 和 RocketMQ 都有其独特之处。本文将重点对比 Kafka 和 RabbitMQ，以帮助开发者做出更适合业务场景的选择。我们通过六个业务场景来分析 Kafka 和 RabbitMQ 的优劣，以期为读者提供直观的决策依据。首先，我们探讨消息的顺序。
2、推荐使用：推荐使用死信队列方式，因其灵活性较高，且易于理解和实现。注意事项：注意延迟队列的使用场景和频率，避免过度使用导致系统性能下降。确保交换机使用Direct模式，以保证消息的准确投递。建议：在安装RabbitMQ时一并安装延迟插件，以备不时之需。
3、性能表现差异 RabbitMQ在处理大量并发连接时表现出良好的性能，但在处理大量小消息的场景下，其性能表现相对较弱。而RocketMQ在高并发环境下表现出更高的吞吐量和更低的延迟，尤其适用于大数据实时处理的场景。
4、消息队列（MQ）则主要用于异步处理任务和处理离线消息。这类系统允许生产者将消息放入队列中，消费者则从队列中获取消息进行处理。MQ提供了一个缓冲机制，使得任务可以按照需求进行处理，而不是实时同步进行。
1、面对消息丢失或积压，应采取以下策略： 异常处理：在消息发送前加入异常处理逻辑，确保消息发送过程的稳定性。 数据持久化：将消息存储在数据库中，定期重新发送失败的消息，保证消息不丢失。 交换机确认：使用生产者确认机制（Confirm， Return）确保消息成功送达队列。
2、生产端可靠性投递，即生产端要确保将消息正确投递到RabbitMQ中。生产端投递的消息丢失的原因有很多，比如消息在网络传输的过程中发生网络故障消息丢失，或者消息投递到RabbitMQ时RabbitMQ挂了，那消息也可能丢失，而我们根本不知道发生了什么。针对以上情况，RabbitMQ本身提供了一些机制。
3、提高系统可扩展性：通过MQ，可以将任务异步处理，使得系统能够处理更多的并发请求，提高系统的吞吐量。增强容错性：即使部分服务出现故障，MQ也可以保证消息不丢失，等待服务恢复后继续处理，从而增强系统的容错性和稳定性。
4、方案二： 可以使用RocketMQ提供的延迟消息机制。往MQ发一个延迟1min的消息，消费这个消息后去检查订单的支付状态，如果订单已经支付，就往下游发送订单的通知，而如果没有支付，就再发一个延迟1min的消息。最终在第10个消息时把订单回收。这个方案就不用对全部的订单表进行扫描，而只需要每次处理一个单独的订单消息。
5、RabbitMQ： 简介：基于AMQP协议实现的，可复用的企业消息系统，是当前最主流的消息中间件之一。 优点：可靠性高，支持消息持久化、发布/订阅、路由、负载均衡等功能；社区活跃，文档完善。 缺点：性能相比Kafka等可能稍逊一筹，特别是在高吞吐量场景下。
6、这个短暂的高峰期积压是 ok 的，因为高峰期过了之后，每秒钟就 50 个请求进 MQ，但是 A 系统依然会按照每秒 2k 个请求的速度在处理。所以说，只要高峰期一过，A 系统就会快速将积压的消息给解决掉。优点上面已经说了，就是 在特殊场景下有其对应的好处 ， 解耦 、 异步 、 削峰 。
基于 Redis key 过期通知的延时队列 利用 Redis key 的过期通知特性，当一个 key 过期时，Redis 可以发布一个消息到特定的 Channel，应用程序可以订阅这个 Channel 来接收过期事件，从而触发相应的业务逻辑。实现步骤如下：在 Redis 配置文件 redis.conf 中增加 notify-keyspace-events 配置项。
RabbitMQ消息丢失问题主要由生产者与消费者速度不匹配、队列满载、确认机制处理不当以及网络问题等原因导致，解决方案包括以下几点：启用消息持久化：确保消息存储在磁盘上：通过配置RabbitMQ将消息持久化到磁盘，即使在服务器故障的情况下，消息也不会丢失。
RabbitMQ死信队列 死信队列的概念：死信队列是专门接收死信的交换机。死信可能因各种原因产生，如消息在队列中过期、队列达到最大长度等。设置死信队列：在配置RabbitMQ时，可以通过设置xdeadletterexchange参数来指定死信交换机。
摘要：RabbitMQ是广泛应用的消息队列中间件，解决应用程序异步通信需求。但消息丢失问题对其可靠性构成威胁。本文剖析了消息丢失原因并提供应对方案。消息丢失原因：生产者与消费者速度不匹配：过快的生产速度超过消费能力，导致消息积压丢失。
功能：RabbitMQ提供了REST API，用于自动化创建队列和交换器，简化部署流程。调用方式：一旦启用Web管理插件，REST API也随之可用。任何支持HTTP的编程语言或脚本都能调用这些API。通过调用REST API，可以获取所有队列的信息，返回一个包含队列属性的JSON数组。
RabbitMQ是一个由Erlang语言构建的消息队列系统，用于异步应用间的协作。它主要由几个关键组件组成：Message：由头部和体部构成，头部包含路由键、优先级等属性，体部是不透明的。Publisher：消息生产者，负责发送消息到交换器。Exchange：消息的接收者，根据路由规则将消息发送到队列。
RocketMQ通过预测机制优化容错性能，避免消息重试时的失败Broker过滤，以及在不开启容错的情况下，通过轮询队列进行消息发送，确保高可用性。这种机制结合了高效存储和智能预测，使得RocketMQ在实际应用中表现出色。
然而，现在的情况有所变化。随着市场需求的变化，IT行业面临挑战，公司需要真正掌握底层技术的程序员。这种变化导致了面试风格的转变，不再只关注于“八股文”的背诵，而是更看重对底层原理的理解。了解Android进程间通信机制，如Binder与Handler，对开发者来说至关重要。
使用消息队列的主要原因有三点：解耦、异步和削峰。解耦方面，例如用户下单后，订单系统需要通知库存系统。若库存系统无法访问，订单减库存操作将失败。利用消息队列，订单系统可返回成功信息，消息持久化后，库存系统恢复时能正常处理减库存操作。