-
Kafka重复消费场景及解决方案
Kafka消费者以消费者组(Consumer Group)的形式消费一个topic，发布到topic中的每个记录将传递到每个订阅消费者者组中的一个消费者实例。Consumer Group 之间彼此独立，互不影响，它们能够订阅相同的一组主题而互不干...- 1年前
-
CyclicBarrier源码分析
类的结构并没有显式继承哪个父类或者实现哪个接口,所有的AQS和重入锁都是同事组合实现的. CyclicBarrier类存在一个内部类Generation,每一次使用CyclicBarrier都可以当成Generation的实例 pr...- 1年前
-
CopyOnWriteArrayList详解
CopyOnWriteArrayList实现了List接口，List接口定义了对列表的基本操作；同时实现了RandomAccess接口，表示可以随机访问(数组具有随机访问的特性；同时实现了Cloneable接口，表示可克隆；同时也实现了Seria...- 1年前
-
ConcurrentLinkedQueue详解
ConcurrentLinkedQueue是一个线程安全的队列，它采用的是 CAS 算法来进行实现，也就是说它是非阻塞的；队列中的元素按照 FIFO(先进先出)的原则对元素进行排列，此外，它是一个无界队列；添加元素的时候，在链表的尾部进行添加，获...- 1年前
-
ConcurrentHashMap源码分析整理
java7的ConcurrentHashMap结构图: 底层使用了数组+链表的方法整个结构是一个segment数组，segment数组的大小决定了ConcurrentHashMap的并发度，默认是16，为什么这么说呢？是因为在java7的Con...- 1年前
-
Mysql精进之路-为什么表数据删掉一半，表文件大小不变？
这里针对MySQL中应用最广泛的InnoDB引擎展开讨论,一个 InnoDB 表包含两部分，即：表结构定义和数据。在 MySQL 8.0 版本以前，表结构是存在以.frm 为后缀的文件里。而 MySQL 8.0 版本，则已经允许把表结构定义放在系...- 1年前
-
排查思路 第一反应是接口是不是返回的数据量太大，导致读超时，排查发现数据量很小，却SocketTimeoutException，首先就排除了业务接口返回数据量过大的原因。 那会不会是哪个链路拖慢了整个请求呢？ 接着发现日志中有好多关于该接口的慢s...
- 1年前
-
Mysql精进之路-持久化binlog与redo log写入机制
binlog的写入机制事务执行过程中,先把日志写到binlog cache,事务提交的时候,再把binlog cache写到binlog文件中.一个事务的binlog是不能被拆开的,因此不论这个事务多大,也要确保一次性写入.这就涉及到了binlo...- 1年前
-
Mysql精进之路-"order by"工作原理
demo: CREATE TABLE `t` ( `id` int(11) NOT NULL, `city` varchar(16) NOT NULL, `name` varchar(16) NOT NULL, `age` int(11) NOT...- 1年前
-
synchronized同步原理总结
为什么说synchronized是Java语言中的重量级操作: Synchronized的重量级锁是通过对象内部的一个叫做监视器锁（monitor）来实现的，监视器锁本质又是依赖于底层的操作系统的Mutex Lock（互斥锁）来实现的。而操作系统...- 1年前
