
Nacos是阿里巴巴开源的,用于服务发现和配置管理的中间件。配置中心已经使用Apollo,所以我们只需要使用服务发现能力即可。 问题 学习研究N...
RocketMQ的定时消息有2种实现方式,第一种实现机制在[ RocketMQ源码阅读 8 ] 延迟消息实现机制-非TimeWheel实现[ht...
Broker的功能点很多,安装程序启动的顺序去看源码,发现代码量比之前的组件要大很多。阅读过程中发现Broker会去持久化一些配置,并且会将消息...
RocketMQ采用了后台定时任务,定时轮询延迟消息队列来实现。 先介绍一下延迟队列用到的数据结构,所有的消息都存储在名为SCHEDULE_TO...
之前我们进行RocketMQ的搭建,其中有一个参数是用来配置刷盘方式的。存在“同步”和“异步”两种方式。 和刷新磁盘逻辑相关的代码可以从这里开始...
RocketMQ官方文档介绍了多种部署方式。我们抛开Local和Cluster集群的差异(Broker和Proxy是否部署在同一个进程),再去分...
该组件的核心就是一个Raft协议的实现。这个Raft协议的实现用的也不是淘宝系的JRaft,而是第三方的产品DLedger。对于生产要求比较严格...
启动过程 NameServer模块下的代码结构,项目启动类为NamesrvStartup。启动过程主要做了如下几件事情。 读取配置文件和命令行参...
我选择的源码版本是5.1.4(源码地址[https://github.com/apache/rocketmq/tree/release-5.1....