RocketMq comsumer源码

消费者启动

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

消息拉取

集群模式:各个消费者通过负载均衡的方式消费消息
广播模式:每一个消费者消费所有消息

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

消息队列负载与重新分布机制

在这里插入图片描述
在这里插入图片描述

消息消费过程

PullMessageService负责对消息队列进行消息拉取,从远端服务器拉取消息后将消息存储ProcessQueue消息队列处理队列中,然后调用ConsumeMessageService#submitConsumeRequest方法进行消息消费,使用线程池来消费消息,确保了消息拉取与消息消费的解耦。
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

相关推荐

  1. 安装git

    2024-06-06 05:34:02       38 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-06-06 05:34:02       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-06-06 05:34:02       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-06-06 05:34:02       18 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-06-06 05:34:02       20 阅读

热门阅读

  1. 深入探索 MongoDB:高级索引解析与优化策略

    2024-06-06 05:34:02       8 阅读
  2. 甜蜜约会网页制作html

    2024-06-06 05:34:02       8 阅读
  3. AWK使用总结

    2024-06-06 05:34:02       7 阅读
  4. 鲁教版八年级数学上册-笔记

    2024-06-06 05:34:02       8 阅读
  5. 有多少苹果用来分赃

    2024-06-06 05:34:02       9 阅读
  6. 枚举类型知识点

    2024-06-06 05:34:02       9 阅读
  7. Linux中挂载Windows Samba共享的指南

    2024-06-06 05:34:02       9 阅读
  8. python基于百度,哈工大等停用表进行的中文分词

    2024-06-06 05:34:02       8 阅读
  9. 个人关于ChatGPT的用法及建议

    2024-06-06 05:34:02       8 阅读