鲤鱼小刺猬

文章
6
资源
0
加入时间
3年0月9天

RabbitMq之发布确认

与单个等待确认消息相比,先发布一批消息然后一起确认可以极大地提高吞吐量,当然这种方式的缺点就是:当发生故障导致发布出现问题时,不知道是哪个消息出现问题了,我们必须将整个批处理保存在内存中,以记录重要的信息而后重新发布消息。当然这种方案仍然是同步的,也一样阻塞消息的发布。一种同步确认发布的方式,也就是发一个消息以后只有他被确认发布,后续的才能继续发布。保证消息不丢失,除了队列开启持久化,消息开启持久化之后,还要发布确认才能完全保证消息不丢失。要如何处理未发布确认的消息,简单记录代码如下。