RMQ消息队列的结构是什么?

已解决

RMQ消息队列的结构是什么?

展开
收起
游客lmkkns5ck6auu 2022-10-11 17:19:13 387 分享 版权
1 条回答
写回答
取消 提交回答
  • 推荐回答

    RMQ消息队列由三部分组成,分别为ZooKeeper、RMQ二方库、Redis。 •ZooKeeper负责维护集群worker的信息,将topic的所有slot分配给全局的woker;

    •Redis负责存储消息,采用Sorted Set结构存储,Store Queue是消息存放的队列,Prepare Queue是采用二阶段消费方式正在消费的消息存放队列,Dead Queue是死信队列;

    •RMQ二方库由RmqClient、Consumer、Producer三部分组成: RmqClient负责RMQ的启动工作,包括上报TopicDef、Worker给ZooKeeper,分配Slot给Worker,扫描业务定义的MessageListener Bean;

    Producer负责根据不用消息类型将消息按照指定的方式存储到Redis; Consumer负责根据不用消息类型按照指定方式从Redis弹出消息并调用业务的MessageListener。

    以上内容摘自《阿里开发者手册-Redis专题》电子书,点击https://developer.aliyun.com/ebook/download/7770 可下载完整版

    2022-10-12 23:22:44
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

收录在圈子:
阿里云开发者社区官方技术圈,用户产品功能发布、用户反馈收集等。
还有其他疑问?
咨询AI助理