发表于 |
Cassandra源码阅读(3)-Memtable Flush本文介绍Cassandra的memtable flush到sstable的过程,重点关注下面两个问题 什么时候memtable会被flush到sstable 如果刷到sstable 何时触发 在Memtable初始化的时候，里面有一个 ...
阅读全文 »

发表于 | 更新于 |
Cassandra源码阅读(2):写流程解析本文以简单的写操作为例来分析，这里介绍的不包括CQL解析，Trigger，counter，view的更新，对于tokenRing的具体选择方法这里也暂时不涉及，只涉及最基础的写流程。上面说到的这些后续会有分析文章。 文章更新日志： 2019-03-03 介 ...
阅读全文 »

发表于 |
Cassandra源码阅读(1)：启动流程本文简述cassandra的启动流程，目的主要是形成一个整体的大概印象。后面的文章会详细分析Cassandra的读写流程，同步流程，失败处理，集群通信等等相关信息。 Cassandra的主入口是CassandraDaemon这个类，通过activate启动， ...
阅读全文 »

发表于 |
事务消息组件的套路本文介绍一些互联网产品的服务端关于处理事务消息的套路 套路1：最终一致性消息模型该方案关键是要有个消息表。另外，一般会有个队列，而且我们一般都会假设这个MQ不丢消息。 基本思路如下 消息生产方 需要额外建一个消息表，并记录消息发送状态。消息表和业务数据要在一个事务里提交（有时实 ...
阅读全文 »

发表于 |
论文笔记：Scaling Memcache at Facebook论文介绍了Facebook如何使用memcache，以及相关魔改和维护memcache集群。 背景facebook使用一致性哈希来构建memcahce集群。 We provision hundreds of memcached ser ...
阅读全文 »

发表于 | 更新于 |
基数估计算法简介注：本文是之前工作时在团队内分享的一个PPT的文字版本. 下文中的sqrt表示开根号(sqrt(4)=2)，m^n表示m的n次方 什么是基数（Cardinality）基数指的是一个可重复集合中不重复元素的个数。 什么是基数计算给定一个含有重复元素的有限集合，计算其不重复元素的个数。 ...
阅读全文 »

发表于 |
JDK 11 ZGC简介注：本文翻译自这篇文章 前言ZGC是最近由Oracle为OpenJDK开源的新垃圾收集器。它主要由Per Liden编写。ZGC类似于Shenandoah或Azul的C4，专注于减少暂停时间的同时仍然压缩堆 。 虽然我不会在这里给出完整的介绍，但“压缩堆”只是意味着将仍然存活 ...
阅读全文 »

发表于 | 更新于 |
Kafka源码学习:网络通信层(2)上一篇里面讲了Kafka的服务端是如何收发请求的，这一篇主要学习一下网络层收到的数据是如何跟业务逻辑层打交道的 上篇文章讲到了processCompletedReceives方法里面把completedReceives队列里面的NetworkReceive拿出来组 ...
阅读全文 »

发表于 | 更新于 |
Kafka源码学习:网络通信层(1)因为工作过程中基本没有涉及到直接使用网络API编程的，所以借这次学习Kafka源码的机会，一起把Java NIO Api以及网络的编程模型套路一起学习一下。 本文主要目的是学习Kafka如何使用NIO与客户端通信的:包括连接的建立，数据的读取，给客户端的应答。 本 ...
阅读全文 »