Gakkiyomi的博客 👋🏼

一位 new Date()大法好的老顽固的真香之旅。 new Date()大法和new SimpleDateFormat()等API是从我2018年学习Java开始就一直在使用的处理日期和格式化日期的神器，直到几个月前我还是喜欢用他们，但是突然遇到一个比较复杂并且涉及用户分布在全球的报表需求时，我开始退坑了。。。 我开始使用java.time包下的API，真香～～～ 在 Java 8 之前，java.util.Date 和 java.util.Calendar是用于表示日期和时间的类。但是这两个工具类 存在很多问题，例如： Date 和Calender是可变的，这意味着它不是线程安全的。 java.util.Date 的时间表示只能精确到毫秒，不能精确到更小的时间单位。 API 设计相对复杂且容易出错。 Calender使用了许多常量和魔法值，不够直观。例如，月份从 0 开始计数，这与我们通常的习惯不同，容易导致错误。 Date 存储的时间是从 1970-01-01T00:00:00Z（即格林威治时间）开始经过的时间，但是它的 API 设计存在很多问题，例如 getYear()....

在学习蚂蚁金服实现的Raft算法实现sofa-jraft项目中第一次接触到这个锁。jraft使用StampedLock来实现对于raft group 的路由信息的线程安全。 StampedLock是Java 8中引入的新的锁机制，它支持三种模式的访问控制，分别是读模式、写模式和乐观读模式，它可以在高并发的情况下提供更好的性能和吞吐量。 在StampedLock中，每个线程都需要获取一个戳（stamp）来进行读或写操作，这个戳是一个64位的数字，其中高16位代表一个版本号，低48位代表一个序号。线程可以使用tryOptimisticRead()方法来获取一个乐观读锁，这种方式不会阻塞线程，只是获取一个戳，如果获取到的戳发生了变化，就意味着有其他线程已经修改了共享资源，这时候需要重新获取锁。 StampedLock还支持读锁和写锁。读锁是共享锁，多个线程可以同时持有读锁，并发地读取共享资源，而写锁是独占锁，只有一个线程可以持有写锁，其他线程需要等待写锁释放才能继续执行。 StampedLock的优势在于，对于读多写少的场景，使用乐观读锁可以避免大量线程阻塞，提高系统的吞吐量；对于写操作比....

Semaphore是一种经典的同步工具，用于控制并发线程数，它可以保证在同一时间内只有一定数量的线程能够访问某个资源，从而避免线程间的竞争和冲突。 Semaphore有两个核心概念： 许可证（Permit）：表示可用的访问权限数量，Semaphore内部维护了一个许可证池，初始时可以设置许可证的数量。 信号量（Semaphore）：表示一个计数器，当线程想要访问某个资源时，必须先从Semaphore中获取一个许可证，然后才能访问资源；当线程使用完资源后，必须释放许可证，以便其他线程可以访问资源。 Semaphore的使用方式如下： 创建Semaphore对象，指定许可证数量。 在需要访问共享资源的线程中，调用acquire()方法获取许可证。 线程使用共享资源。 在共享资源使用完毕后，调用release()方法释放许可证。 听起来有点像操作系统里面信号量的概念，其实本质是一样的，不过操作系统层面的信号量是作用于进程与进程之间的同步，java里面的信号量是线程与线程之间的同步。 下面是一个简单的示例代码，使用Semaphore控制了同时执行的线程数目： import java.....

CyclicBarrier也是Java中的一个同步工具类，它允许一组线程等待彼此达到一个共同的屏障点，直到所有线程都到达屏障点后才能继续执行。CyclicBarrier可以被认为是一个可重用的计数器，每当一个线程到达屏障点时，计数器减1，当计数器减为0时，表示所有线程都已到达屏障点，等待的线程可以继续执行。 API CyclicBarrier的常用方法有两个： int await()：表示一个线程已经到达屏障点，等待其他线程，如果所有线程都到达屏障点，则计数器重置，并且所有线程都继续执行； int await(long timeout, TimeUnit unit)：表示一个线程已经到达屏障点，等待其他线程，如果所有线程都到达屏障点，则计数器重置，并且所有线程都继续执行；如果超时则抛出TimeoutException异常。 以下是一个使用CyclicBarrier进行线程同步的示例代码： import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; p....

《 大义觉迷录 》是清朝雍正帝亲自颁行的一部在全国发行的官方宣传资料，收录了曾静一案的上谕、曾静口供及其《归仁录》，描述了曾静从反对雍正到拥护雍正这一“大义觉迷”的过程。利用第三人称的角色为切入题材，是研究满清的重要史料。乾隆帝即位后，认为该书主要起到弄假成真的效果，在颁行之后呈现适得其反的情形，原因是书中钜细靡遗的记载反而引起人们过度的讨论，因此迅速禁绝该书。 相关人物 爱新觉罗·胤禛 也就是雍正皇帝，他执政13年期间推行了许多项的改革。但在此期间也有许多流言蜚语，说他弑父，逼母，杀弟，是史上最凶残的暴君和最大的昏君。 曾静 号 蒲潭，清代湖南省郴州永兴县人，为一秀才。雍正年间，曾与其门徒劝川陕总督岳锺琪造反而被捕，引发吕留良案。雍正帝没有处死曾静，除了把曾静的口供收录进《大义觉迷录》，还要曾静在全国各地巡讲《大义觉迷录》。乾隆帝即位后，认为曾静的罪与吕留良相当，所以不顾父训也要把曾静凌迟处死。 对线 正常的皇帝碰到这种事情，大概就是用权力蔽之或者杀之。但雍正这个铁憨憨却竟然将曾静押回京来，进行中路对线。然后以理 [难说是不是物理 ] 服人，然后让曾静带着雍正皇帝亲自对线的结果全国....

继续 Java标准库API系列文章，今天要讲的是一个同步利器。CountDownLatch是Java中的一个同步工具类，它允许一个或多个线程等待一组事件的发生，直到所有事件都发生后才能继续执行。CountDownLatch通过一个计数器来实现，初始化一个正整数，每当一个事件发生时，计数器减1，当计数器为0时，表示所有事件都已发生，等待的线程可以继续执行。 在没有CountDownLatch之前，我们想让线程等待其他线程执行完之前等待话，需要使用到Thread类的join方法 就像之前 Java 标准库API系列之Exchanger的例子里的一样。 有了CountDownLatch之后等待其他多个线程执行完成的需求就可以使用更佳方便的API了。 CountDownLatch的常用方法有两个： void countDown()：表示一个事件已经发生，将计数器减1； void await()：等待所有事件发生，如果计数器不为0，则一直等待。 以下是一个使用CountDownLatch进行线程同步的示例代码： import java.util.concurrent.CountDownLa....

作为一名java程序员，熟练掌握java提供的标准库是非常必要的，所以有了Java 标准库API系列文章来介绍java标准库里的一些常用的工具类，了解这些标准库可以从中学习到大神贡献给java的优良的代码和理解一些操作系统的原理，例如并发等等。。。 本文会介绍juc包下的Exchanger类。 java.util.concurrent 包是 Java 5.0 提供的并发工具包(简称 JUC)包, 主要有原子操作 CAS，锁机制 AQS（可重入锁，闭锁，屏障锁等）， 并发集合（Map，Queue 等），线程池（线程池执行器，调度线程池执行器和执行器），Exchanger是Java中的一个同步工具类，它提供了一个同步点，允许两个线程在这个同步点交换数据。Exchanger实现了一种简单的交换数据模型，可以用于解决线程间通信和同步的问题。 Exchanger的常用方法有两个： exchange(V x)：交换数据，当前线程将数据x交换给另一个线程，同时等待另一个线程返回的数据； exchange(V x, long timeout, TimeUnit unit)：在指定时间内交换数据....

关于java字节码的处理，有很多工具，如bcel，asm。不过这些都需要直接跟虚拟机指令打交道。如果你不想了解虚拟机指令，可以采用javassist。javassist是jboss的一个子项目，其主要的优点，在于简单，而且快速。直接使用java编码的形式，而不需要了解虚拟机指令，就能动态改变类的结构，或者动态生成类。 ‍ 生成类 ClassPool pool = ClassPool.getDefault(); CtClass fangcongC = pool.makeClass("fangcong"); fangcongC.addField(CtField.make("public String name;",fangcongC)); fangcongC.addMethod(CtMethod.make("public String getName(){return this.name;}", fangcongC)); fangcongC.addMethod(CtMethod.make("public void setName(String name){this.name = ....

自己多次搭建nginx做站点反向代理，这里将命令组合成脚本，方便日后使用。 #!/bin/sh mkdir /srv/nginx/config echo -e "user nginx;\nworker_processes auto;\n\nerror_log /var/log/nginx/error.log notice;\npid /var/run/nginx.pid;\n\n\nevents {\n worker_connections 1024;\n}\n\n\nhttp {\n include /etc/nginx/mime.types;\n default_type application/octet-stream;\n\n log_format main '\$remote_addr - \$remote_user [\$time_local] \"\$request\" '\n '\$status \$body_bytes_sent \"\$http_referer\" '\n '\"\$http_user_agent\" \"\$http_x_forwarded_f....

查看程序内存占用 kubectl top pod -nsky ‍ 进入目标容器 kubectl exec -it -nsky <pod名称> bash 获取 java 程序进程号 jps ‍ 保存堆栈信息 jmap -dump:live,format=b,file=<文件保存位置> <java进程号> ‍ 通过 MAT 分析内存 pipeline 分析案例 1、通过 MAT 打开堆栈信息 2、打开自动生成的内存溢出分析 ‍ 发现 ConcurrentSkipListMap 占用了大量内存 点开 detail 单击大对象 选择 List objects->with incoming references 查看持有该对象引用的对象 ‍ 发现有很多的 grpc channel 对象 查看代码发现重复创建 channel ‍ bug fixed

为了解决AOF文件体积膨胀的问题，Redis提供了AOF文件重写功能，新生成一个AOF文件来替代现有的AOF文件，新旧两个文件所保存的数据库状态相同，但新文件不会包含任何冗余命令,所以新AOF文件的体积会比旧的文件小。 redis的重写aof算法非常的聪明。 直接读取key的值，获取最新的key当前的值,然后用一条命令就可以做为这个key的当前状态。 def aof_rewrite(new_aof_file_name): # 创建新的AOF文件 f = create_file(new_aof_file_name) # 遍历数据库 for db in redisServer.db: # 忽略空数据库 if db.is_empty(): continue # 显示指定数据库 f.write_command("SELECT "+ db.id) for key in db: # 忽略已过期的key if key.is_expired(): continue # 根据key的类型对key进行重新 switch(key.type): case String: r....

查看数据量大的表 SELECT table_schema || '.' || table_name AS table_full_name, pg_size_pretty(pg_total_relation_size('"' || table_schema || '"."' || table_name || '"')) AS size FROM information_schema.tables ORDER BY pg_total_relation_size('"' || table_schema || '"."' || table_name || '"') DESC limit 100 查看数据量大的字段 select sum(pg_column_size(path_analyze_result)) as path, sum(pg_column_size(object_analyze_result)) as object, sum(pg_column_size(correlation_analyze_result)) as correlation from nap_pol....

容器的本质是一个特殊的进程，特殊在为期创建了 Namespace 隔离运行环境，并用 CGroup 为其控制资源开销。借助这两个技术我们可以成功实现应用容器化，但如何让多个容器在网络环境相互通信，以及访问外部网络，或者让外部网络访问特定容器等问题，则还需要利用一些Linux网络虚拟化技术。 在Linux提供的众多Namespace中，我们可以其中Network Namespace 来给容器配置独立的网络视图。 现在让我们从linux提供的一些网络虚拟化技术来实现一个简易版的"docker"。 网络命名空间隔离 通过一个小实验demo来体验网络命名空间 通过使用命令 readlink proc/$$/ns/net来查看宿主机的网络空间 我们也可以创建Network Namespace，通过ip netns 工具来创建 在这两个网络命名空间上创建两个bash容器 进行观察, 发现 网络空间的值改变了 查看接口 查看路由表 发现这个网络命名空间里的网络都被重置了，同样的fangcong2这个空间应该也如此。 不同的容器（ fangcong1 和 fangcong2 ）拥有自己独立....

Github Stats 所有开源项目 仓库 项目简介 Stars fork 编程语言 galang Some utils for the Go: network,network address,string,algorithms/structure,array/silce,一款包含了网络地址相关，字符串相关，算法和数据结构的 Go 语言常用工具库。 9 2 Go gakkiyomi my page 5 1 snmp-go-example golang snmp网段扫描接口列表 支持单个ip或者ip范围或者一个网段，目前只支持/24网段 5 0 Go keycloak-k8s-deploy-template keycloak-k8s部署脚本 4 0 Shell pwl-chat-python 摸鱼派聊天室python客户端 4 0 Python learn-daily 学习整理的文章 3 0 netty-demo useage netty framwork build a client and server demo 2 0 Java j....

如果人会在一瞬间成长或者成熟，那一定是遇到了一些痛苦的事，我以为痛苦只是一瞬间，但没想到整个2021都会如此。 工作 我是一个重感情的人。 初入社会最后一名称得上朋友的同事离职之后，孤身一人在深圳的我再也没有了工作的热情，再也没有了友情。在离别聚餐时候说以后可能大家都不会再见面了。说的很残酷也很真实 ....

作为一名现代青年出入夜店也不是什么稀奇事，去夜店了当然得来杯鸡尾酒咯。当时就是觉得那些装酒的瓶子好看，而且一杯鸡尾酒卖的巨贵，那还不如我自己调呢，于是买了鸡尾酒的常见基酒。自己调酒便宜还有情调。正值中秋假期的第二天，自己闲着无事突发奇想，不调酒，直接纯饮。当然，未成年人不得饮酒！ 今天要体验纯饮的就 ....

Fastjson 重复引用对象的问题 出现相同的对象时，fastjson默认开启引用检测将相同的对象写成引用的形式 引用是通过"$ref"来表示的 引用 描述 "$ref":".." 上一级 "$ref":"@" 当前对象，也就是自引用 "ref":"" 根对象 "ref":".children.0" 基于路径的引用，相当于 root.getChildren().get(0) 复现 public static void main(String[] args) { final JSONObject src = new JSONObject(); src.put("a", "b"); src.put("c", "d"); src.put("e", "f"); final JSONObject object = new JSONObject(); object.put("src", src); object.put("target", src); System.out.println(object.toJSONString()); } ....

使用@RestControllerAdvice,@Pattern,@Valid实现统一表单参数校验返回 表单校验有很多种方法，最直接明了的就是直接在代码里面明编码。 这样子写既不美观也不专业，所以直入正题。 使用@RestControllerAdvice,@ExceptionHandler,@Pattern,@Valid实现统一表单参数校验返回 @RestControllerAdvice和@ExceptionHandler一起使用可以捕获controller层抛出的异常,然后我们就可以对期异常返回进行改造。 @Pattern 带有此注解的属性必须与起指定的正则表达式所匹配。 @Valid 带有此注解的对象会对自己的属性检查，如果带有了@Pattern,就进行校验。 结合这四个注解，我们就可以进行表单参数的校验返回了。 @RestControllerAdvice public class CmdbExceptionHandler{ public CmdbExceptionHandler() { } @ExceptionHandler({MethodArgumentNotVal....

最近开工了，回到了深圳和朋友们聊天时谈到了我们自身的发展前景。大家都各有看法，但最终呈现出的答案无非两种，一种是自信派，自信人生二百年，会当击水三千里。一种是安稳派，认为应该在外打工太难，应该激流勇退，早日回老家工作生活。 在家里过年时,天天在客厅陪亲戚看电视《雍正王朝》，在剧中老康熙带着不想还债的群臣到了畅春园里坐下后，说出了这句“朕一生自信，自信人生一百年 会当纵横九万里。”这句话是编剧刘和平老师化用的毛主席的《七古·残局》，然后例举了自己一生赫赫功勋。可是有多少人一出生就是九五至尊呢？我当时这般想。后来发现这是毛主席的诗后，又有了新的感悟，也正是有毛主席在青年时代的这般自信，才有了中年时代屡遭冷落和排挤时的百折不挠，才有了如钢铁般意志的新中国成立。 所以自信是好的，自信能带给你肾上腺素的上升，让你坚持自己。现在网络太发达，任何时间地点发生的任何事都能从网络中获取，导致有些许人对同样出身的自己产生了怀疑和不自信，他如此，我当如此吗？当年毛主席在北京求学时泡在图书馆，其获取知识的难度相对于现在更是无比巨大，现在的信息时代任何东西都能在网上找到。获取知识的途径越来越多，现在的年轻人却退....

Redis 学习记录 记录一下 Redis 的学习，仅供参考。 SDS 简单动态字符串 Redis 没有直接使用 C 语言的传统字符串表示，而是自己构建了(simple dynamic string)的抽象类型，并且广泛运用在 Redis 的代码当中。 传统的 c 字符串只会在 Redis 的代码中充当字符串字面量使用，也就是类似于打印日志时 log("xxxxx")这样使用。 sds.h/sdshdr 定义了 sds 的结构 struct sdshdr { //记录buf数组中所使用的字节数量 //等于sds所保存的字符串的长度 int len; //记录buf数组中为使用的字节数量 int free; //字节数组 用于保存字符串 char buf[]; } 并且还沿用了 c 字符串的以空字符串'\0'结尾，这样可以重用一部分 c 字符串函数库里面的函数。 C 字符串 SDS 获取字符串长度的复杂度为 O(n) 获取字符串长度的复杂度为 O(1) API 是不安全的，可能造成缓冲区溢出 API 是安全的，不会造成缓冲区溢出 修改字符串长度 N 次必然要执行....