confirm机制
参考demo:G:\学习资料\java\java学习文档\java技术文档\消息队列文档\rabbimitmq\cd-xufei-rabbiitmq-parent\cd-xufei-rabbitmq-01 => confirm
Confirm机制 说白了 就是 用来 确定我们的消息发送到队列的是否是成功的
生产者核心示例代码:
// 开启 confirm 回调的监听
channel.confirmSelect();
// 添加confirm监听
channel.addConfirmListener(new ConfirmListener() {
@Override
public void handleAck(long l, boolean b) throws IOException {
// 如果回调的是这个方法 那么说明发送到队列是成功的
System.out.println("发送成功");
}
@Override
public void handleNack(long l, boolean b) throws IOException {
// 如果回调了这个方法说明发送是失败的
System.out.println("发送失败");
}
});
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
最近更新: 2025/07/30, 15:37:56