5 天前 / binecy
前面文章已经分享了 Netty 如何引用 jemalloc 4 算法管理内存。 本文主要分享 Netty 4.1.52 之前版本中，如何使用 jemalloc 3 算法管理内存。 感兴趣的同学可以对比两种算法。 源码分析基于 Netty 4.1.29 首先说明 PoolChunk 内存组织方式。 PoolChunk 的内存大小默认是 16M，它将内存组织成为一颗完美二叉树。 二叉树的每一层每个节点所代表的内存大小都是均等的，并且每一层节点所代表的内存大小总和加起来都是 16M。 每一层节点可分配内存是父节点的 1/2。整颗二叉树的总层数为 12，层数从 0 开始。
18 天前 / 猿天地
在工作中，我相信很多人都有下面这样的感受： 这谁的代码呀，看不下去了这破代码，一行注释也没有这代码，还没我写的好这代码，有 bug 吧这代码，......是不是很真实，我们往往在看别人代码的时候就会有上面这些想法。我认为主要的原因还是大部分看的都是业务代码，而且很多是多年积累下来的，也没有重构，然后一年年的堆逻辑，最后就变成 shi 山了。 当然也有不少的人代码写的确实很好，简洁易懂，我们在看别人代码的时候要抱着学习的态度去看，同样的逻辑，看看别人是怎么写的，为什么这样写，如果是自己会怎么写，对比下，这样的话你就有收获了。
20 天前 / binecy
前面文章说了 PoolChunk 如何管理 Normal 内存块，本文分享 PoolSubpage 如何管理 Small 内存块。 源码分析基于 Netty 4.1.52 内存管理算法 PoolSubpage 负责管理 Small 内存块。一个 PoolSubpage 中的内存块 size 都相同，该 size 对应 SizeClasses#sizeClasses 表格的一个索引 index。 新创建的 PoolSubpage 都必须加入到 PoolArena#smallSubpagePools[index]的链表中。 PoolArena#smallSubpagePools 是一个 PoolSubpage 数组，数组中每个元素都是一个 PoolSubpage 链表，PoolSubpage 之间可以通过 next，prev 组成链表。
20 天前 / 蚂蚁集团移动开发平台mPaaS
前言 Apache RocketMQ 作为广为人知的开源消息中间件，诞生于阿里巴巴，于 2016 年捐赠给了 Apache。从 RocketMQ 4.0 到如今最新的 v4.7.1，不论是在阿里巴巴内部还是外部社区，都赢得了广泛的关注和好评。 本文将站在发送方视角，通过阅读 RocketMQ Producer 源码，来分析在事务消息发送中 RocketMQ 是如何工作的。 需要说明的是，本文所贴代码，均来自 4.7.1 版本的 RocketMQ 源码。本文中所讨论的发送，仅指从 Producer 发送到 Broker 的过程，并不包含 Broker 将消息投递到 Consumer 的过程。
26 天前 / 郭儿的跋涉
本文重点 前情提要之前文章中写到了 JDK 中 synchronized 关键字可以实现同步锁，并且详细分析了底层的实现原理。 Synchronized 原理及锁升级分析 虽然 synchronized 在性能上不再被人诟病，但是在实际使用中仍然缺乏一定的灵活性。 比如在一些场景中需要去尝试获取锁，如果失败则不再进行等待，又或者设置一定的等待时间，超时后就放弃等待。 正文开始，ReentrantLock 介绍 java.util.concurrent.locks 包提供了多种锁机制的实现，本文暂且以 ReentrantLock 为例，探究 Java 是如何实现同步锁的。
27 天前 / binecy
本文主要分享 Netty 中 PoolChunk 如何管理内存。 源码分析基于 Netty 4.1.52 内存管理算法首先说明 PoolChunk 内存组织方式。 PoolChunk 的内存大小默认是 16M，Netty 将它划分为 2048 个 page，每个 page 为 8K。 PoolChunk 上可以分配 Normal 内存块。 Normal 内存块大小必须是 page 的倍数。 PoolChunk 通过 runsAvail 字段管理内存块。 PoolChunk#runsAvail 是 PriorityQueue 数组，其中 PriorityQueue 存放的是 handle。
33 天前 / binecy
前面文章说了 PoolChunk 如何管理 Normal 内存块，本文分享 PoolSubpage 如何管理 Small 内存块。 源码分析基于 Netty 4.1.52 内存管理算法 PoolSubpage 负责管理 Small 内存块。一个 PoolSubpage 中的内存块 size 都相同，该 size 对应 SizeClasses#sizeClasses 表格的一个索引 index。 新创建的 PoolSubpage 都必须加入到 PoolArena#smallSubpagePools[index]的链表中。 PoolArena#smallSubpagePools 是一个 PoolSubpage 数组，数组中每个元素都是一个 PoolSubpage 链表，PoolSubpage 之间可以通过 next，prev 组成链表。
34 天前 / Leo叔叔
长安城里的一切都在无可避免的走向庸俗。 谈到编译器指示，我们在平时工作中几乎不会使用，除非你觉得你的代码瓶颈出现在编译期，不过了解掌握编译器指示对于我们阅读 golang 源码还是挺有帮助的。 什么是编译器指示？编译器接受注释形式的指示。比如我们常见的 //go:xxx 的形式出现在方法前面上方。为了将其与非指示注释区分开，编译器指示要求在注释开头和指示名称之间不需要空格。但是由于它们是注释，故而不了解指示约定或特定指示的工具可以像其他注释一样跳过指示。
34 天前 / Dr_Hydra
我们知道，在 java 中提供了两类锁的实现，一种是在 jvm 层级上实现的 synchrinized 隐式锁，另一类是 jdk 在代码层级实现的，juc 包下的 Lock 显示锁，而提到 Lock 就不得不提一下它的核心队列同步器（AQS）了，它的全称是 AbstractQueuedSynchronizer，是用来构建锁或者其他一些同步组件的基础，除了 ReentrantLock、ReentrantReadWriteLock 外，它还在 CountDownLatch、Semaphore 以及 ThreadPoolExecutor 中被使用，通过理解队列同步器的工作原理，对我们了解和使用这些工具类会有很大的帮助。
45 天前 / 郭儿的跋涉
Mybatis 源码分析 Mybatis，一款优秀 ORM 框架，它的核心是将 Java 对象和数据库表映射起来，方便对数据进行增删改查操作。阅读源码的重点关注以下几点。 1、如何找到要执行的 SQL2、如何执行 SQL，并返回对应的数据 3、查询缓存如何存取包的划分 MyBatis 的包划分很清晰，职责明确，如下图。 使用到的设计模式在 MyBatis 源码中使用到了多种设计模式，可以重点关注其使用方法。 Builder 模式工厂模式单例模式代理模式装饰器模式适配器模式 Demo 执行流程依照官网的文档，通过 不使用 XML 构建 SqlSessionFactory 的方式来运行一个简单的 Demo。
54 天前 / binecy
在学习 Netty 内存池之前，我们先了解一下 Netty 的内存对齐类 SizeClasses，它为 Netty 内存池中的内存块提供大小对齐，索引计算等服务方法。 源码分析基于 Netty 4.1.52 Netty 内存池中每个内存块 size 都符合如下计算公式 size = 1 chunkSize){ returnnSizes; } //#2 if(directMemoryCacheAlignment>0){ size=alignSize(size); } //#3 if(size>LOG2_QUANTUM]; } //#4 intx=log2((size>log2Delta& (1 idx 的对应关系。 从 sizeClasses 方法可以看到，sizeClasses 表格中每个 size 都是 (2^LOG2_QUANTUM) 的倍数。
61 天前 / binecy
我们知道，Netty 使用直接内存实现 Netty 零拷贝以提升性能， 但直接内存的创建和释放可能需要涉及系统调用，是比较昂贵的操作，如果每个请求都创建和释放一个直接内存，那性能肯定是不能满足要求的。 这时就需要使用内存池。 即从系统中申请一大块内存，再在上面分配每个请求所需的内存。 Netty 中的内存池主要涉及 PoolArena，PoolChunk 与 PoolSubpage。 本文主要分析 Netty 中内存池 PoolArena 的实现。 源码分析基于 Netty 4.1.52 接口关系 ByteBufAllocator，内存分配器，负责为 ByteBuf 分配内存， 线程安全。
62 天前 / MarvinZhang
前言The most incomprehensible thing about the world is that it is comprehensible. 世界上最不可理解的地方就是它竟然是可以理解的。-- 阿尔伯特·爱因斯坦 开源（Open-Source）造就了如今繁荣活跃的软件行业。开源让全世界的开发者都能够协力编写出优秀的工具类项目，也就是所谓的 "轮子"，在造福大大小小的公司个人的同时，也可以展现创作者或贡献者的技术实力。如今很多开发者都在大量使用开源项目作为自己项目的第三方库或依赖，更快更高效的完成开发任务。 open-source 笔者也不例外。
66 天前 / 影浅
errgroup 前言来看下 errgroup 的实现 如何使用 func main() {var eg errgroup.Groupeg.Go(func() error {return errors.New("test1")})eg.Go(func() error {return errors.New("test2")})if err := eg.Wait(); err != nil {fmt.Println(err)}}类比于 waitgroup,errgroup 增加了一个对 goroutine 错误收集的作用。 不过需要注意的是： errgroup 返回的第一个出错的 goroutine 抛出的 err。 errgroup 中还可以加入 context func main() {eg, ctx := errgroup.WithContext(context.Background())eg.Go(func() error {// test1 函数还可以在启动很多 goroutin...