RabbitMQ提供了几种机制来确保消息的可靠传递简单介绍

RabbitMQ是一个开源的消息队列中间件，用于在分布式系统中存储和转发消息。然而，由于网络和硬件问题，消息仍可能在消息队列中丢失，这对于许多应用程序来说是不可接受的。下面web建站小编给大家简单介绍一下关于RabbitMQ提供了几种机制来确保消息的可靠传递示例！

消息持久化:将消息标记为持久化,那么消息会被写入磁盘,即使 RabbitMQ 服务重启,消息也不会丢失。

channel.basicPublish(exchange, routingKey, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());

高可用性队列:将队列定义为 HA queue,它会在多个节点上进行备份,保证即使某个节点不可用,消息也不会丢失。

Map<String, Object> args = new HashMap<>();
args.put("x-ha-policy", "all"); 
channel.queueDeclare(queueName, true, false, false, args);

镜像队列:将队列定义为镜像队列,它会将消息同步到备份节点的镜像队列上,保证消息不丢失。

Map<String, Object> args = new HashMap<>();
args.put("x-queue-type", "quorum");
channel.queueDeclare(queueName, true, false, false, args);

事务:生产者与 RabbitMQ 之间的交互在一个事务内,要么全部成功要么全部失败。如果在事务中发布消息失败,那么消息不会进入队列。

channel.txSelect();  // 选择事务模式
// 发布多条消息  
channel.txCommit(); // 提交事务,消息进入队列

确认机制:生产者在发布消息后会等待 RabbitMQ 的确认 ack,如果一段时间内没有收到 ack,生产者会重新发布这条消息。这可以防止网络等原因导致的消息丢失。

channel.basicPublish(exchange, routingKey, properties, body);
// 等待确认
channel.waitForConfirmsOrDie(5_000);