Notes

前言 在阅读完和 AQS 相关的锁以及同步辅助器之后，来一起阅读 JUC 下的和队列相关的源码。先从第一个开始：ArrayBlockingQueue。 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 介绍由数组支持的有界BlockingQueue阻塞队列。 这个队列的命令元素FIFO（先入先出）。 队列的头是元素一直在队列中时间最长。 队列的尾部是该元素已经在队列中的时间最短。 新元素插入到队列的尾部，并且队列检索操作获取在队列的头部元素。 这是一个典型的“有界缓冲区”，在其中一个固定大小的数组保持由生产者插入并受到消费者的提取的元素。 一旦创建，容量不能改变。 试图put 一个元素到一个满的队列将导致操作阻塞; 试图 take 从空队列一个元素将类似地阻塞。 此类支持订购等待生产者和消费者线程可选的公平政策。 默认情况下，这个顺序不能保证。 然而，队列公平设置为构建 true 保证线程以FIFO的顺序进行访问。 公平性通常会降低吞吐量，但减少了可变性和避免饥饿。 基本使用 public class A ...

前言 在 JUC 中线程同步器除了 CountDownLatch 和 CycleBarrier ，还有一个叫做 Semaphore （信号量），同样是基于 AQS 实现的。下面来看看信号量的内部原理。 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 介绍一个计数信号量。 从概念上讲，信号量维护了一组许可。 如果有必要，在许可可用之前调用 acquire 方法会被阻塞，直到许可证可用。 调用 release 方法会增加了一个许可证，从而释放被阻塞的线程。 声明时指定初始许可数量。 调用 acquire(int permits) 方法，指定目标许可数量。 调用 release(int permits) 方法，发布指定的许可数量。 在许可数量没有到达指定目标数量时，调用 acquire 方法的线程会被阻塞。 基本使用public class SemaphoreTest1 { private static final Semaphore SEMAPHORE = new Semaphore(0); ...

前言 近期做新项目，在设计表结构的时候，突然想起来之前面试的时候遇到的一个问题，那时候也是初出茅庐，对很多东西一知半解（当然现在也是），当时那个小哥哥问我为什么交易和退款要拆成两个表？是基于什么考虑？有什么好处和优点么？ 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 背景那是一个风和日丽的下午，当然，风和日丽的下午应该配点其他的形容词，实在是我才疏学浅，只能用这个词充当了下开头…… （此处省略小五千字） 赶紧进入正文！ 因为之前一直做聚合支付，而在使用过程中，也是支付和退款表拆开的，一直这么用，并没有觉得不妥。 比如一个交易表基本就是这样的： 字段 类型 含义 id bigint 主键 id trans_id varchar 交易订单号 trans_amount bigint 订单金额 trans_status tinyint 交易状态 …… …… …… create_time datetime 创建时间 update_time datetime 更新时间 退款 ...

前言 看完 CountDownLatch 正准备表示一番，突然看到了一个 CyclicBarrier —— 回环屏障。沃特？回环还屏障？说比 CountDownLatch 要多一个回环，那咱可得瞧一瞧，看一看了！ 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 介绍一个同步辅助，它允许一组线程的所有等待彼此达成共同屏障点。 CyclicBarrier 在涉及固定线程数且必须等待彼此的程序非常有用。 该屏障被称为回环屏障 ，因为它在等待的线程被释放后可以被重新利用。 CyclicBarrier 支持一个可选的 Runnable 命令，该命令在障碍中的最后一个线程到达之后，但在释放任何线程之前，每个屏障点运行一次。 此屏障操作对于在任何一方继续之前更新共享状态很有用。 通过上面的源码注释基本可以得出以下结论： CyclicBarrier 和 CountDownLatch 类似，但它是一组线程等待，直到在其他线程中执行的一组操作完成为止。 CountDownLatch 是计数递减，结束后再调用 awai ...

前言 之前推了一篇文章《十张图带大家看懂 ES 原理 ！明白为什么说：ES 是准实时的！》，很多小伙伴都比较好奇在文章中的图是用的什么画图软件？看那么明显的手绘风格，当然是手画的啦！（开玩笑），其实我用的是 draw.io ，下面分享我的画图软件 —— draw.io 。 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 为什么需要画图？俗话说：“一图顶百字！”，好吧！这是我现想的俗话。 在新项目开发，技术分享，阅读代码笔记，或者面试的时候，画个流程图，架构图等等，比较直观，便于理解等。优点啥的就不多介绍了，这里主要介绍我的画图软件。 基本要求 免费 使用方便 支持离线使用 用过的其他软件 Visio：使用方便，在最开始的时候就是使用 Visio，不过只能在 Win 系统上使用。 ProcessOn：在线版，使用方便，很简洁。个人免费，不过限制文件数量。 OmniGraffle：Mac 客户端，收费，有很多功能，不过对我来说有点玩不熟练。 语雀：语雀也支持画简单的流程图。 其他一些，暂时没想起来的。 ...

前言 CountDownLatch 一个同步辅助工具，同样是基于 AQS 实现，本篇文件主要是介绍 CountDownLatch 的使用，以及源码。 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 介绍一个同步辅助工具，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成为止 一个 CountDownLatch 初始化为给定计数。 在 await 方法阻塞，调用 countDown 方法会减少计数直到达到零，此后所有等待的线程被释放，任何后续调用 await 都会立即返回。 这是一次性的现象 - 计数不能复位。 如果你需要一个版本重置计数，请考虑使用CyclicBarrier 。 CountDownLatch 是一种通用的同步工具，可用于多种用途。 用作一个简单的开/关锁存器，或者门：所有线程调用await在门口等待，直到被调用 countDown 的线程打开。 初始化计数为 N ，用一个线程等待，直到 N 个线程完成某项操作，或某些动作已经完成 N 次。 CountDownLatch 一 ...

前言 说到 Elasticsearch ，其中最明显的一个特点就是 near real-time 准实时 —— 当文档存储在Elasticsearch中时，将在1秒内以几乎实时的方式对其进行索引和完全搜索。那为什么说 ES 是准实时的呢？ 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ Lucene 和 ESLuceneLucene 是 Elasticsearch所基于的 Java 库，它引入了按段搜索的概念。 Segment： 也叫段，类似于倒排索引，相当于一个数据集。 Commit point：提交点，记录着所有已知的段。 Lucene index： “a collection of segments plus a commit point”。由一堆 Segment 的集合加上一个提交点组成。 对于一个 Lucene index 的组成，如下图所示。 Elasticsearch一个 Elasticsearch Index 由一个或者多个 shard （分片） 组成。 而 Lucene 中的 Lu ...

前言 ES 使用过程中常用的就是查询以及检索，那查询和检索的过程，什么样的呢？ 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ 查询流程GET my-index/_doc/0 Client 将请求发送到任意节点 node，此时 node 节点就是协调节点（coordinating node）。 协调节点对 id 进行路由，从而判断该数据在哪个shard。 在 primary shard 和 replica shard 之间 随机选择一个，请求获取 doc。 接收请求的节点会将数据返回给协调节点，协调节点会将数据返回给Client。 可以通过 preference 参数指定执行操作的节点或分片。默认为随机。 检索流程GET /my-index/_search Client 将请求发送到任意节点 node，此时 node 节点就是协调节点（coordinating node） 协调节点进行分词等操作后，去查询所有的 shard （primary shard 和 replica shard 选择一 ...

前言 在前面已经介绍了 ES 中常用的一些名词，知道了数据是存储在 shard 中的，而 index 会映射一个或者多个 shard 。那这时候我要存储一条数据到某个索引下，这条数据是在哪个 index 下的呢？ 公众号：liuzhihangs，记录工作学习中的技术、开发及源码笔记；时不时分享一些生活中的见闻感悟。欢迎大佬来指导！ ES 演示一切按照官方教程使用 三条命令，在本机启动三个节点组装成伪集群。 ~ % > ./elasticsearch ~ % > ./elasticsearch -Epath.data=data2 -Epath.logs=log2 ~ % > ./elasticsearch -Epath.data=data3 -Epath.logs=log3 创建索引curl -X PUT "localhost:9200/my-index-000001?pretty" -H 'Content-Type: application/json' -d' { "settings": { "index": { "number_of_sh ...