路行的亚洲

LV0
发表了文章

kafka学习二 -发送消息

从源码中我们发现在Sender的run方法中,并没有涉及到append追加操作。因此可以看到源码中,如果消息收集器中的消息收集结果为空或者新的消息批次已经创建好...

路行的亚洲
发表了文章

Scala学习一

当记录方法返回值的变量被声明为lazy时,方法的执行将被推迟,直到我们首次使用该值时,方法才会执行。类似java中的延迟加载。同时lazy不能修饰var类型的变...

路行的亚洲
发表了文章

RocketMQ学习六-消息存储

消息存储主要做的事情:首先将消息放入,然后进行消息追加,进行统计,然后进行刷盘操作,最后进行HA主从同步。此时的消息放入是在CommitLog中会进行转发到Co...

路行的亚洲
发表了文章

RocketMQ学习Broker流程、生产者和存储流程联系

Broker作为代理,路由注册是通过Broker与nameServer的心跳功能实现的。除此之外,还联系了生产者和消费者、存储。因此可以知道Broker是非常重...

路行的亚洲
发表了文章

RocketMQ的NameServer执行流程学习梳理

首先NamesrvStartUp启动,首先经过main()方法,也是我们常见的main方法进入到main0()执行创建controller操作与启动contro...

路行的亚洲
发表了文章

RocketMQ学习5

进行消息发送的过程首先会准备好路由信息,最终是由netty完成的,也即使用nettyRemotingClient来实现的。

路行的亚洲
发表了文章

RocketMQ学习四-生产者producer

前面我们已经知道RocketMQ的生产者和消费者依赖NameServer和broker,因此需要先启动nameServer和broker。同时nameServe...

路行的亚洲
发表了文章

rocketmq学习2

从启动类中,我们看到:首先创建NamesrvConfig、nettyServerConfig,设置监听端口,将8888改成9876。填充NamesrvConfi...

路行的亚洲
发表了文章

ThreadPoolExecutor源码学习

但点进去看newSingleThreadExecutor可以看到其会调用ThreadPoolExecutor里面的线程。因此有必要研究ThreadPoolExe...

路行的亚洲
发表了文章

LinkedBlockingQueue源码学习

采用线程池和阻塞队列实现生产/消费者模型。其中LinkedBlockingQueue是阻塞队列,同时线程安全,其特点:

路行的亚洲
发表了文章

JVM学习一

jvm的内存结构:可以看到我们的java文件会首先编译成class文件,经过类加载器进行加载,然后经过jvm的相关区域:f方法区、堆、虚拟机栈、程序计数器、本地...

路行的亚洲
发表了文章

JVM学习二

jps、jstat、jinfo、jhat、jstack、jconsole、jmap、MAT、Btrace、psi_probe监控tomcat,通过gceasy查...

路行的亚洲
发表了文章

ArrayList源码学习

ArrayList是一种以数组实现的列表,而数组的优势在于有角标,因此查询的速度较快,是一种可以动态扩容的数组。我们着重了解添加、获取、替换、删除操作。

路行的亚洲
发表了文章

HashMap源码学习

首先实现map的子类:HashMap、HashTable、TreeMap、LinkedHashMap。

路行的亚洲
发表了文章

ConcurrentHashMap源码学习

既然有了HashMap为什么还会出现ConcurrentHashMap?同时ConcurrentHashMap具有什么优势?ConcurrentHashMap与...

路行的亚洲
关注了用户

芋道源码

835 文章0 回答108 关注者
关注了用户

一个会写诗的程序员

902 文章0 回答46 关注者
关注了用户

机器之心

专业的人工智能媒体和产业服务平台

4.3K 文章0 回答162 关注者
关注了用户

美团技术团队

做一个勤勉的技术干货“搬运工”,欢迎关注我们的公众号:美团技术团队(meituantech)

363 文章0 回答138 关注者
订阅了专栏

中间件兴趣圈

《RocketMQ技术内幕》作者维护,关注Netty、Mycat、Dubbo、es-job、Rocketmq、es、mybatis等。

129 文章60 关注者

个人简介

个人成就

扫码关注云+社区

领取腾讯云代金券