RabbitMQ消息中间件技术精讲11 高级篇四 confirm

RabbitMQ消息中间件技术精讲11 高级篇四 confirm 确认消息

理解Confirm消息确认机制：

消息的确认，是指生产者投递消息后，如果broker收到消息，则会给生产者一个应答；

生产者经行接收应答，用来确定这条消息是否正常的发送到broker，这中方式也是消息的可靠性投递的核心保障!

确认机制流程图：

如何实现Confirm确认消息？

第一步：在channel上进行开启确认模式：channel.confirmSelect();

第二步：在channel上添加监听：addConfirmListener,监听成功和失败的返回结果，根据具体的结果对消息进行重新发送，或记录日志等后续操作。

代码实现：

添加确认消息监听是在生产端处理的，所以生产端代码如下：

在channel上添加确认模式：

添加监听的，我们可以看到还有返回监听，关闭shutdown的监听。这里我们选择确认监听：

说明：

在添加确认监听时候，需要一个ConfirmListener listener的参数。这里我们就使用了内部类。其中要实现两个方法：handleAck和handleNack.

handleAck:成功监听，handleNack失败监听。

其中两个产生：long 类型的消息唯一标签，boolean类型的是否批量。

我们在来看看消费者端：

启动服务：

启动消费者，我们在管控台查看：

路由exchanges列表：

队列和路由都已经创建了。接下来，我们启动生产者，观察控制是否接收到应答:

我们可以看到，生产者已经打印出投递成功的确认消息。

本节总结：

相关代码已发布在git上，欢迎大家下载查看

系列教程持续更新中~~。欢迎大家一起学习

下节预告：

在下节中，我们将讲解return消息机制。

git地址欢迎关注凯哥公众号：凯哥Java(kaigejava)

或访问凯哥个人博客：www.kaigejava.com 获取