rabbitmq-ConfirmListener
当broker开启confirm时,可以添加此监听器。
public void testWaitForConfirms()
throws IOException, InterruptedException
{
// 创建Channel时开启:channel.confirmSelect();
// 记录客户端发送消息的序号1、2、3、4、。。。
final SortedSet<Long> unconfirmedSet = Collections.synchronizedSortedSet(new TreeSet<Long>());
channel.addConfirmListener(new ConfirmListener() {
public void handleAck(long seqNo, boolean multiple) {
if (!unconfirmedSet.contains(seqNo)) {
fail("got duplicate ack: " + seqNo);
}
// 这里multile=true时,我理解为broker批量发送ack确认。
// 客户端就把此次消息序号之前的记录全删除,代表这个消息值钱的消息broker都已接收到
if (multiple) {
unconfirmedSet.headSet(seqNo + 1).clear();
} else { // broker单个返回ack确认
unconfirmedSet.remove(seqNo);
}
}
public void handleNack(long seqNo, boolean multiple) {
fail("got a nack");
}
});
for (long i = 0; i < NUM_MESSAGES; i++) {
unconfirmedSet.add(channel.getNextPublishSeqNo());
publish("", "confirm-test", true, false);
}
channel.waitForConfirmsOrDie();
if (!unconfirmedSet.isEmpty()) {
fail("waitForConfirms returned with unconfirmed messages");
}
}
- 深入学习RabbitMQ:channel的confirm模式
- RabbitMQ之消息确认机制(事务+Confirm)
- 深入学习RabbitMQ(三):channel的confirm模式
- 深入学习RabbitMQ(四):channel的confirm模式
- RabbitMQ之消息确认机制(事务+Confirm)
- RabbitMQ 之消息确认机制(事务+Confirm)
- RabbitMQ之消息确认机制(事务+Confirm) - 朱小厮的博客 - CSDN博客
- RabbitMQ的@RabbitListener不起作用
- RabbitMQ-消息确认机制(事务+confirm)
- RabbitMQ使用场景练习:监听器Listener(九)
- RabbitMQ之消息确认机制(事务+Confirm)
- RabbitMq09——confirm串行和并行模式
- rabbitmq基础学习+springboot结合rabbitmq实现回调确认confirm
- RabbitMQ之消息确认机制(事务+Confirm)
- RabbitMQ的transaction、confirm、ack三个概念的解释
- RabbitMQ(三)消息确认机制(事务+Confirm)
- spring rabbitmq为listener配置并发消费者数量
- RabbitMQ系列(四)RabbitMQ事务和Confirm发送方消息确认——深入解读
- RabbitMQ---9、消息确认机制(事务+Confirm)