本篇文章给大家谈谈rabbitmq可靠投递，以及rabbitmq可靠消息对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。
本文目录一览：
- 1、消息队列原理及选型
- 2、聊一聊rabbitMQ和kafka的应用场景
- 3、消息队列核心原理
- 4、MQ消费失败,自动重试思路,如何保证MQ消息正常被业务消费
- 5、RabbitMQ的持久化设置
- 6、RabbitMQ消费者性能优化相关配置说明
消息队列原理及选型
1、如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。 消息的收发处理支持事务，例如：在任务中心场景中，一次处理可能涉及多个消息的接收、处理，这应该处于同一个事务范围内，如果一个消息处理失败，事务回滚，消息重新回到队列中。
2、即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。
3、一般来说，消息队列有两种模式，一种是发布者订阅模式，另外一种是生产者和消费者模式。Redis的消息队列，也是基于这2种原理的实现。 发布者和订阅者模式：发布者发送消息到队列，每个订阅者都能收到一样的消息。
聊一聊rabbitMQ和kafka的应用场景
rabbitmq cluster消息的存储，一个队列只能在一台机器上存储，无法实现分片存储。kafka消息发送topic，topic可以多个分区，同一个topic的消息可以分片保存在不同的机器上，消息持久化存储在磁盘上，一个消息可以重复消费，不用像rabbitmq一样，有几个消费者来消费这个消息，就需要几个消息队列来存储这个消息。
kafka是Linkedin于2010年12月份开源的消息发布订阅系统，它主要用于处理活跃的流式数据，大数据量的数据处理上。常用日志采集，数据采集上。
Apache RocketMQ，阿里巴巴的杰作，凭借其分布式队列模型和异步通信机制，适用于解耦异步场景和流量控制。它结合了JMS和Kafka的优点，同时支持大规模消息堆积和与其他开源生态的集成。
每个中间件在部署时都有其特定考量，如ActiveMQ的单节点部署不支持高可用，而RabbitMQ的镜像集群模式提供了一种平衡性能和高可用性的选择。RocketMQ的多Master多Slave模式在处理多节点时需注意消息实时性，Kafka则通过replica机制增强容错能力。
消息队列核心原理
即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。
消息的收发处理支持事务，例如：在任务中心场景中，一次处理可能涉及多个消息的接收、处理，这应该处于同一个事务范围内，如果一个消息处理失败，事务回滚，消息重新回到队列中。
Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理大量的数据并且具备高并发能力。其核心思想是通过分布式的方式将消息发送给多个服务节点，从而实现高效的数据传输。Kafka是一个开源的项目，被广泛应用于互联网企业、金融等领域。
MQ消费失败,自动重试思路,如何保证MQ消息正常被业务消费
1、设计思路为：内置一个专门做重试的队列，这个队列是一个延迟队列，当业务队列消费失败时，将原始消息投递至重试队列，并设置延迟时间，当延迟时间到达后。
2、但是如果引入MQ组件，随之要考虑的问题就变多了，如何保证MQ消息能够正常被业务消费。所以引入MQ消费失败情况下，自动重试功能是非常重要的。这里不过细讲MQ有哪些原因会导致失败。MQ重试，网上有方案一般采用的是，本地消息表+定时任务。
3、消费失败后，不重试配置方式 集群消费方式下，消息失败后期望消息不重试，需要捕获消费逻辑中可能抛出的异常，最终返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS，此后这条消息将不会再重试。
4、如果您使用的是RabbitMQ，可以通过开启消费者手动应答机制来实现消息重试。
5、Consumer 保证消息成功消费的关键在于确认的时机，不要在收到消息后就立即发送消费确认，而是应该在执行完所有消费业务逻辑之后，再发送消费确认。因为消息队列维护了消费的位置，逻辑执行失败了，没有确认，再去队列拉取消息，就还是之前的一条。
RabbitMQ的持久化设置
交换器的持久化是通过在声明队列是将durable参数设置为true实现的。如果交换器不设置持久化，那么在RabbitMQ服务器重启之后，相关的交换器元数据会丢失，不过消息不会丢失，只是不能将消息发送到这个交换器中了。对于一个长期使用的交换器来说，建议将其设置为持久化的。
设置持久化有两个步骤：①创建queue的时候将其设置为持久化的，这样就可以保证rabbitmq持久化queue的元数据，但是不会持久化queue里面的数据。②发送消息的时候讲消息的deliveryMode设置为2，这样消息就会被设为持久化方式，此时rabbitmq就会将消息持久化到磁盘上。 必须要同时开启这两个才可以。
RabbitMQ 的消息默认存放在内存上面，如果不特别声明，消息不会持久化保存到硬盘上面，如果节点重启或者意外crash掉，消息就会丢失。
rabbitmq重启。创建的队列都是非持久化的，rabbitmq如果重启的话，该队列就会被删除掉，如果要队列实现持久化，需要在声明队列的时候把，durabl参数设置为持久化。当所有消费客户端断开连接时，而我们对RabbitMQ消息进行了持久化。
RabbitMQ 持久化中有三部分： 消息的持久化，在投递时指定 delivery_mode=2(1是非持久化)，消息的持久化，需要配合队列的持久，只设置消息的持久化，重启之后队列消失，继而消息也会丢失。所以如果只设置消息持久化而不设置队列的持久化意义不大。
RabbitMQ消费者性能优化相关配置说明
1、Gitee地址： https：//gitee.com/lemon_ant/os.git 新建SpringBoot项目 添加配置文件 添加pom文件 启动类 [图片上传失败...(image-3e7425-1591871192134)][图片上传失败...(image-e9beeb-1591871192134)]注意看时间，说明消息是轮询分发的，一个消息只由一个消费者消费。
2、安装RabbitMQ 首先，你需要在你的计算机上安装RabbitMQ。你可以从RabbitMQ的官方网站下载适用于你的操作系统的安装程序，并按照安装向导进行安装。安装完成后，你就可以启动RabbitMQ服务器了。配置RabbitMQ 在安装完成后，你需要对RabbitMQ进行一些基本的配置。
3、在cloudamqp中，我们将rabbitmq服务器配置为只接受快速但安全的加密密码并确定其优先级。 预取值用于指定多少条消息将同时被发送给消费者。它被用来从你的消费者那里得到尽可能多的东西(饱和工作)。
rabbitmq可靠投递的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于rabbitmq可靠消息、rabbitmq可靠投递的信息别忘了在本站进行查找喔。
