zoukankan      html  css  js  c++  java
  • 对RabbitMQ消息队列的理解

    一、RabbitMQ的消费模式有两种,一种是推,一种是拉

    推:RabbitMQ会将队列中的消息推给消费者。

    拉:消费者从队列中主动拉取消息,但是每次只能拉取一条。

    二:消息确认

    当消费者无论通过推模式还是拉模式消费消息后,都应该给RabbitMQ一个确认消息,告诉RabbitMQ自己已经消费了消息,让RabbitMQ从队列中将消息删除;当然了消费者也可以不给RabbitMQ回复确认消息,这样RabbitMQ的队列会一直持有消息。

    三:队列中会有两部分消息

    第1部分:还未发送给消费者的消息;可以供任意消费者来消费。

    第2部分:已经发送给消费者,但是还未收到消费者回复确认的消息;该部分消息不能再被其他消费者消费,只能等待它的消费者回应确认;或者消费者还没回应就断开了和队列的连接,则该部分消息会变成第1部分的消息。

    四:消息消费的过程

    1:假如初始状态下队列中有15个消息,这15个消息都属于第1部分,如下图:

    2:现在消费者A消费了两个消息:1号和2号;但是没有给队列回复确认消息,则1号和2号在队列中就属于第2部分,不能再被其他消费者消息,只能等待消费者A回应确认,如下图:

    3:假如又来了一个消费者B,需要消费两个消息,则消费者B只能从队列中消费3号和4号,在回复确认消息之后,3号和4号从队列中删除,如下图:

    4:如果消费者A一直没有给RabbitMQ回复确认消息,并断开了和RabbitMQ的连接,则1号和2号消息会从第2部分变成第1部分,即可以被其他消费者消费,如下图:

  • 相关阅读:
    Android开发如何定制framework层服务
    Intellij IDEA通过SVN导入基于Springboot的maven项目以及对已有项目做更新
    intelliJ IDEA 怎么添加本地的idea web项目
    Android热修复之AndFix使用教程
    iOS友盟分享的使用总结
    iOS 传感器集锦
    IOS CALayer的属性和使用
    Swift使用Alamofire实现网络请求
    Android踩坑随笔Fragment中onActivityResult方法不被调用
    上周热点回顾(4.30-5.6)团队
  • 原文地址:https://www.cnblogs.com/hzcya1995/p/13302428.html
Copyright © 2011-2022 走看看