原文:RocketMQ原理及源码解析

RocketMQ原理深入: 一 定义: RocketMQ是一款分布式 队列模型的消息中间件,有以下部分组成: NameServer: 一个几乎无状态的节点,可集群部署,节点之间无任何信息同步 Broker:是RocketMQ的核心组成部分,通过轻量级的Topic和队列机制来维护消息存储,Broker支持消息Push和Pull模式。支持千亿级别的消息堆积能力 Producer:消息生产者,和Nam ...

2019-06-09 16:57 0 2554 推荐指数:

查看详情

RocketMQ源码解析-消息消费

RocketMQ源码解析-消息消费 1.消费者相关类 2.消费者的启动 3.消息的拉取 4.消息的消费 5.消费队列的负载 6.消费进度管理 看了很多遍的代码,还是决定动手把记录下来,梳理一下整体结构和实现细节 RocketMQ中消息的消费分为2种方式,一种是pull模式,一种 ...

Sat May 04 16:49:00 CST 2019 0 684
RocketMQ原理解析-NameServer

Namesrv名称服务,是没有状态可集群横向扩展。 一:Namesrv功能: 二:Namesrv启动流程: 三: RouteInfoM ...

Sat Nov 12 01:42:00 CST 2016 0 2908
RocketMQ原理解析-Consumer

consumer 1.启动 有别于其他消息中间件由broker做负载均衡并主动向consumer投递消息,RocketMq是基于拉模式拉取消息,consumer做负载均衡并通过长轮询向broker拉消息。 Consumer消费拉取的消息的方式有两种 下面介绍默认 ...

Sat Nov 12 00:43:00 CST 2016 2 8769
RocketMQ原理解析-Broker

broker 1. broker的启动 brker的启动 Broker向namesrv注册 Topic在broker文件上的存储json格式 Nam ...

Sat Nov 12 01:21:00 CST 2016 0 16324
RocketMQ原理解析-Producer

producer producer 1.启动流程 Producer如何感知要发送消息的broker即brokerAddrTable中的值是怎么获得的, ...

Tue Nov 08 18:19:00 CST 2016 1 9167
RocketMQ源码解析之Windows环境部署

下载rocketmq,选择binary 解压后,配置环境变量ROCKETMQ_HOME,变量值是MQ解压路径\MQ文件夹名 cmd命令跳转至MQ解压路径\MQ文件夹名\bin 路径下,执行start mqnamesrv.cmd 新弹出的窗口显示错误: 找不到或无法加载主类 ...

Sat Sep 11 17:16:00 CST 2021 0 110
RocketMQ架构原理解析(一):整体架构

RocketMQ架构原理解析(一):整体架构 RocketMQ架构原理解析(二):消息存储(CommitLog) RocketMQ架构原理解析(三):消息索引(ConsumeQueue & IndexFile) RocketMQ架构原理解析(四):消息生产端(Producer) 一、概述 ...

Wed Nov 17 17:27:00 CST 2021 0 1327
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM