springboot rabbitmq

作者: peipeicn | 来源:发表于2018-12-13 15:23 被阅读1次

    发送消息确认
    发送确认发生在生产者。保证消息成功发送到了queue。
    callback
    如果消息没有到exchange,则confirm回调,ack=false
    如果消息到达exchange,则confirm回调,ack=true
    exchange到queue成功,则不回调return
    exchange到queue失败,则回调return(需设置mandatory=true,否则不回回调,消息就丢了)

    ACK确认
    ACK确认发生在消费者。
    消费者在消费消息的时候,通过ack确认,保证消息在消费成功之后才会从queue中移除。

    开启ack

    spring.rabbitmq.listener.simple.acknowledge-mode=manual
    spring.rabbitmq.listener.direct.acknowledge-mode=manual

    相关文章

      网友评论

        本文标题:springboot rabbitmq

        本文链接:https://www.haomeiwen.com/subject/accbhqtx.html