RabbitMQ 如何实现消息发布后的确认机制？

本文共计2772个文字，预计阅读时间需要12分钟。

每日一句：军人天生就舍弃了战争的意义！概述：RabbitMQ发布确认，确保消息在磁盘上。前提条件：1.队列必须持久化+队列持久化+2.队列中的消息必须持久化+消息持久化+使用+三种发布方式“

每日一句

军人天生就舍弃了战斗的意义！

概述

RabitMQ 发布确认，保证消息在磁盘上。

前提条件

1。队列必须持久化 队列持久化

2。队列中的消息必须持久化 消息持久化

使用

三种发布确认的方式：

1。单个发布确认

2。批量发布确认

3。异步批量发布确认

开启发布确认的方法

//创建一个连接工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("127.0.0.1"); factory.setUsername("guest"); factory.setPassword("guest"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); ** //开启发布确认 channel.confirmSelect();** 单个确认

最简单的确认方式，它是一种同步发布确认的方式，也就是说发送一个消息后只有它被确认，后续的消息才能继续发布。

最大缺点是：发布速度特别的满。