Consumer源代码分析 消费流程 DefaultMQPushConsumer DefaultMQPushConsumer是默认进行消费的工具类，类图如下： public DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook, AllocateMessageQ...

NameServer源代码分析 周末继续阅读RocketMq的学习,在上周已经简单的把RocketMq的安装和使用学习了一下。本周主要来看一下NameServer的源代码和设计 NameServer启动 NamesrvController启动 public static NamesrvController main0(String[] args) { try {...

RocketMQ组件 RocketMQ简单的看是由四个组件构成的，分别是NameServe、Broker、Producer、consumer这四个组件构成的; 一个简单的执行过程是: consumer通过向NameServer询问具体的Topic所在的Broker地址 consumer通过向Broker保持长连接的形式，获取到信息 同一组下的consumer会向broker中的不同Message...

RocketMQ中的通信模式 在RocketMQ中为producer提供了三种通讯模式分别是同步、异步、单向; 同时对于消息类型也提供了多种选择:广播消息、延迟消息、 顺序消息、事务消息等选择; 下文就主要介绍一些概念性的东西和最佳实践 producer 同步模式 public static void main(String[] args) throws MQClientException &#...

RocketMQ入门 在工作中只是简单的使用了一下kafka进行系统间的交互，并未系统化的学习过消息队列这个中间件。基于开源MQ项目的一个活跃度,选择阿里开源出来的RocketMQ来进行学习，再来就是RocketMQ本身也是用java语言进行开发的一个项目。 安装 安装前提 需要拥有以下软件： 操作系统(推荐使用64位) jdk1.8 (推荐使用64位的) Maven 3.2x Git 4G以上...

读书列表 正在读 名称 状态 《现代操作系统-原理与实现》 ing 读过 名称 状态 《重构–改善既有代码的设计》 end 《大话设计模式》 end 《RocketMQ实战与原理解析》 end 《Spring Cloud与Docker微服务架构实战》 end 《MySQL技术内幕.InnoDB存储引擎》 end 《Effective Java中...