children = client.getChildren().forPath("/zkid");
+ if (CollectionUtil.isNotEmpty(children)) {
+ for (String child : children) {
+ client.delete().forPath("/zkid/" + child);
+ }
+ }
+ client.delete().forPath("/zkid");
+
+ // 关闭客户端
+ client.close();
+ }
+
+}
diff --git a/codes/java-distributed/java-distributed-id/src/main/java/io/github/dunwu/distributed/id/ZookeeperDistributedId2.java b/codes/java-distributed/java-distributed-id/src/main/java/io/github/dunwu/distributed/id/ZookeeperDistributedId2.java
new file mode 100644
index 00000000..69d5d543
--- /dev/null
+++ b/codes/java-distributed/java-distributed-id/src/main/java/io/github/dunwu/distributed/id/ZookeeperDistributedId2.java
@@ -0,0 +1,46 @@
+package io.github.dunwu.distributed.id;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.curator.RetryPolicy;
+import org.apache.curator.framework.CuratorFramework;
+import org.apache.curator.framework.CuratorFrameworkFactory;
+import org.apache.curator.framework.recipes.atomic.AtomicValue;
+import org.apache.curator.framework.recipes.atomic.DistributedAtomicLong;
+import org.apache.curator.retry.ExponentialBackoffRetry;
+
+/**
+ * ZK 分布式 ID
+ *
+ * 基于原子计数器生成 ID
+ *
+ * @author Zhang Peng
+ * @date 2024-12-20
+ */
+@Slf4j
+public class ZookeeperDistributedId2 {
+
+ public static void main(String[] args) throws Exception {
+
+ // 获取客户端
+ RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
+ CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retryPolicy);
+ DistributedAtomicLong atomicLong = new DistributedAtomicLong(client, "/zkid", retryPolicy);
+
+ // 开启会话
+ client.start();
+
+ // 基于原子计数器生成 ID
+ AtomicValue id1 = atomicLong.increment();
+ log.info("id: {}", id1.postValue());
+
+ AtomicValue id2 = atomicLong.increment();
+ log.info("id: {}", id2.postValue());
+
+ // 清理节点
+ client.delete().forPath("/zkid");
+
+ // 关闭客户端
+ client.close();
+ }
+
+}
diff --git a/codes/java-distributed/java-distributed-id/src/main/resources/scripts/fixed_window_rate_limit.lua b/codes/java-distributed/java-distributed-id/src/main/resources/scripts/fixed_window_rate_limit.lua
new file mode 100644
index 00000000..e0c9ad00
--- /dev/null
+++ b/codes/java-distributed/java-distributed-id/src/main/resources/scripts/fixed_window_rate_limit.lua
@@ -0,0 +1,21 @@
+-- 缓存 Key
+local key = KEYS[1]
+-- 访问请求数
+local permits = tonumber(ARGV[1])
+-- 过期时间
+local seconds = tonumber(ARGV[2])
+-- 限流阈值
+local limit = tonumber(ARGV[3])
+
+-- 获取统计值
+local count = tonumber(redis.call('GET', key) or "0")
+
+if count + permits > limit then
+ -- 请求拒绝
+ return -1
+else
+ -- 请求通过
+ redis.call('INCRBY', key, permits)
+ redis.call('EXPIRE', key, seconds)
+ return count + permits
+end
\ No newline at end of file
diff --git a/codes/java-distributed/java-distributed-id/src/main/resources/scripts/token_bucket_rate_limit.lua b/codes/java-distributed/java-distributed-id/src/main/resources/scripts/token_bucket_rate_limit.lua
new file mode 100644
index 00000000..541d70c9
--- /dev/null
+++ b/codes/java-distributed/java-distributed-id/src/main/resources/scripts/token_bucket_rate_limit.lua
@@ -0,0 +1,39 @@
+local tokenKey = KEYS[1]
+local timeKey = KEYS[2]
+
+-- 申请令牌数
+local permits = tonumber(ARGV[1])
+-- QPS
+local qps = tonumber(ARGV[2])
+-- 桶的容量
+local capacity = tonumber(ARGV[3])
+-- 当前时间（单位：毫秒）
+local nowMillis = tonumber(ARGV[4])
+-- 填满令牌桶所需要的时间
+local fillTime = capacity / qps
+local ttl = math.min(capacity, math.floor(fillTime * 2))
+
+local currentTokenNum = tonumber(redis.call("GET", tokenKey))
+if currentTokenNum == nil then
+ currentTokenNum = capacity
+end
+
+local endTimeMillis = tonumber(redis.call("GET", timeKey))
+if endTimeMillis == nil then
+ endTimeMillis = 0
+end
+
+local gap = nowMillis - endTimeMillis
+local newTokenNum = math.max(0, gap * qps / 1000)
+local currentTokenNum = math.min(capacity, currentTokenNum + newTokenNum)
+
+if currentTokenNum < permits then
+ -- 请求拒绝
+ return -1
+else
+ -- 请求通过
+ local finalTokenNum = currentTokenNum - permits
+ redis.call("SETEX", tokenKey, ttl, finalTokenNum)
+ redis.call("SETEX", timeKey, ttl, nowMillis)
+ return finalTokenNum
+end
diff --git a/codes/java-distributed/java-load-balance/pom.xml b/codes/java-distributed/java-load-balance/pom.xml
index 5f14ae1a..b4e73f0f 100644
--- a/codes/java-distributed/java-load-balance/pom.xml
+++ b/codes/java-distributed/java-load-balance/pom.xml
@@ -3,11 +3,10 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- io.github.dunwu.javatech
+ io.github.dunwu.distributed
java-load-balance
1.0.0
jar
- ${project.artifactId}
UTF-8
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/BaseLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/BaseLoadBalance.java
similarity index 96%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/BaseLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/BaseLoadBalance.java
index e4f03ab2..ebb317a8 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/BaseLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/BaseLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import cn.hutool.core.collection.CollectionUtil;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/ConsistentHashLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/ConsistentHashLoadBalance.java
similarity index 99%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/ConsistentHashLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/ConsistentHashLoadBalance.java
index 42394a12..c67558a2 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/ConsistentHashLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/ConsistentHashLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/IpHashLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/IpHashLoadBalance.java
similarity index 94%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/IpHashLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/IpHashLoadBalance.java
index 00be0c93..3d71cbb7 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/IpHashLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/IpHashLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import cn.hutool.core.util.HashUtil;
import cn.hutool.core.util.StrUtil;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LeastActiveLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LeastActiveLoadBalance.java
similarity index 98%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LeastActiveLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LeastActiveLoadBalance.java
index 25dc6f13..23a7f03c 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LeastActiveLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LeastActiveLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
import java.util.Random;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalance.java
similarity index 86%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalance.java
index 046734af..f2d0c561 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalanceDemo.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalanceDemo.java
similarity index 97%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalanceDemo.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalanceDemo.java
index 1077f48e..57dc61f1 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/LoadBalanceDemo.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/LoadBalanceDemo.java
@@ -1,6 +1,10 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Random;
+import java.util.TreeMap;
/**
* 负载均衡算法测试例
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/Node.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/Node.java
similarity index 97%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/Node.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/Node.java
index ad0c8ed4..2fc9c712 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/Node.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/Node.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.Objects;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RandomLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RandomLoadBalance.java
similarity index 94%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RandomLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RandomLoadBalance.java
index 8f4b7d8d..5b775dd2 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RandomLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RandomLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
import java.util.Random;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RoundRobinLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RoundRobinLoadBalance.java
similarity index 94%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RoundRobinLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RoundRobinLoadBalance.java
index d14b251d..c0858152 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/RoundRobinLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/RoundRobinLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/StatisticsUtil.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/StatisticsUtil.java
similarity index 95%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/StatisticsUtil.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/StatisticsUtil.java
index 50eaa59a..cbb66d13 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/StatisticsUtil.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/StatisticsUtil.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
public class StatisticsUtil {
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRandomLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRandomLoadBalance.java
similarity index 96%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRandomLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRandomLoadBalance.java
index a3f1c853..c7135667 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRandomLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRandomLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
import java.util.Random;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRoundRobinLoadBalance.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRoundRobinLoadBalance.java
similarity index 99%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRoundRobinLoadBalance.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRoundRobinLoadBalance.java
index 3180958d..3f71a573 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/WeightRoundRobinLoadBalance.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/WeightRoundRobinLoadBalance.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/package-info.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/package-info.java
similarity index 76%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/package-info.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/package-info.java
index 8633bb5a..4d8b7a26 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/package-info.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/package-info.java
@@ -4,4 +4,4 @@
* @author Zhang Peng
* @since 2020-01-22
*/
-package io.github.dunwu.javatech;
+package io.github.dunwu.distributed;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/CRCHashStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/CRCHashStrategy.java
similarity index 98%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/CRCHashStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/CRCHashStrategy.java
index 8622bb51..5c732a5b 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/CRCHashStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/CRCHashStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
import java.nio.charset.StandardCharsets;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/FnvHashStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/FnvHashStrategy.java
similarity index 92%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/FnvHashStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/FnvHashStrategy.java
index 807f3c33..fc7cea13 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/FnvHashStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/FnvHashStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
public class FnvHashStrategy implements HashStrategy {
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/HashStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/HashStrategy.java
similarity index 59%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/HashStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/HashStrategy.java
index 2ad6deef..f574c86e 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/HashStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/HashStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
public interface HashStrategy {
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/JdkHashCodeStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/JdkHashCodeStrategy.java
similarity index 77%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/JdkHashCodeStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/JdkHashCodeStrategy.java
index f4a8389c..6541e2a4 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/JdkHashCodeStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/JdkHashCodeStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
public class JdkHashCodeStrategy implements HashStrategy {
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/KetamaHashStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/KetamaHashStrategy.java
similarity index 96%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/KetamaHashStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/KetamaHashStrategy.java
index 8e98ef1f..ef479aaf 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/KetamaHashStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/KetamaHashStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
diff --git a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/MurmurHashStrategy.java b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/MurmurHashStrategy.java
similarity index 96%
rename from codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/MurmurHashStrategy.java
rename to codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/MurmurHashStrategy.java
index a100f3d3..82ee1620 100644
--- a/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/javatech/support/MurmurHashStrategy.java
+++ b/codes/java-distributed/java-load-balance/src/main/java/io/github/dunwu/distributed/support/MurmurHashStrategy.java
@@ -1,4 +1,4 @@
-package io.github.dunwu.javatech.support;
+package io.github.dunwu.distributed.support;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
diff --git a/codes/java-distributed/java-rate-limit/pom.xml b/codes/java-distributed/java-rate-limit/pom.xml
new file mode 100644
index 00000000..312d7f21
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/pom.xml
@@ -0,0 +1,41 @@
+
+
+ 4.0.0
+
+ io.github.dunwu.distributed
+ java-rate-limit
+ 1.0.0
+ jar
+
+
+ UTF-8
+ 1.8
+ ${java.version}
+ ${java.version}
+
+
+
+
+ redis.clients
+ jedis
+ 5.1.0
+
+
+ cn.hutool
+ hutool-all
+ 5.8.25
+
+
+ org.projectlombok
+ lombok
+ 1.18.30
+
+
+ ch.qos.logback
+ logback-classic
+ 1.2.3
+ true
+
+
+
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/FixedWindowRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/FixedWindowRateLimiter.java
new file mode 100644
index 00000000..0af8d142
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/FixedWindowRateLimiter.java
@@ -0,0 +1,59 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * 固定时间窗口限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+public class FixedWindowRateLimiter implements RateLimiter {
+
+ /**
+ * 允许的最大请求数
+ */
+ private final long maxPermits;
+
+ /**
+ * 窗口期时长
+ */
+ private final long periodMillis;
+
+ /**
+ * 窗口期截止时间
+ */
+ private long lastPeriodMillis;
+
+ /**
+ * 请求计数
+ */
+ private AtomicLong count = new AtomicLong(0);
+
+ public FixedWindowRateLimiter(long qps) {
+ this(qps, 1000, TimeUnit.MILLISECONDS);
+ }
+
+ public FixedWindowRateLimiter(long maxPermits, long period, TimeUnit timeUnit) {
+ this.maxPermits = maxPermits;
+ this.periodMillis = timeUnit.toMillis(period);
+ this.lastPeriodMillis = System.currentTimeMillis() + this.periodMillis;
+ }
+
+ @Override
+ public synchronized boolean tryAcquire(int permits) {
+ long now = System.currentTimeMillis();
+ if (lastPeriodMillis <= now) {
+ this.lastPeriodMillis = now + this.periodMillis;
+ count = new AtomicLong(0);
+ }
+ if (count.get() + permits <= maxPermits) {
+ count.addAndGet(permits);
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/LeakyBucketRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/LeakyBucketRateLimiter.java
new file mode 100644
index 00000000..0d99a227
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/LeakyBucketRateLimiter.java
@@ -0,0 +1,64 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * 漏桶限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+public class LeakyBucketRateLimiter implements RateLimiter {
+
+ /**
+ * QPS
+ */
+ private final int qps;
+
+ /**
+ * 桶的容量
+ */
+ private final long capacity;
+
+ /**
+ * 计算的起始时间
+ */
+ private long beginTimeMillis;
+
+ /**
+ * 桶中当前的水量
+ */
+ private final AtomicLong waterNum = new AtomicLong(0);
+
+ public LeakyBucketRateLimiter(int qps, int capacity) {
+ this.qps = qps;
+ this.capacity = capacity;
+ }
+
+ @Override
+ public synchronized boolean tryAcquire(int permits) {
+
+ // 如果桶中没有水，直接放行
+ if (waterNum.get() == 0) {
+ beginTimeMillis = System.currentTimeMillis();
+ waterNum.addAndGet(permits);
+ return true;
+ }
+
+ // 计算水量
+ long leakedWaterNum = ((System.currentTimeMillis() - beginTimeMillis) / 1000) * qps;
+ long currentWaterNum = waterNum.get() - leakedWaterNum;
+ waterNum.set(Math.max(0, currentWaterNum));
+
+ // 重置时间
+ beginTimeMillis = System.currentTimeMillis();
+
+ if (waterNum.get() + permits < capacity) {
+ waterNum.addAndGet(permits);
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiter.java
new file mode 100644
index 00000000..4fbc9646
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiter.java
@@ -0,0 +1,13 @@
+package io.github.dunwu.distributed.ratelimit;
+
+/**
+ * 限流器
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+public interface RateLimiter {
+
+ boolean tryAcquire(int permits);
+
+}
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiterDemo.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiterDemo.java
new file mode 100644
index 00000000..e4a50641
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RateLimiterDemo.java
@@ -0,0 +1,95 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import cn.hutool.core.thread.ThreadUtil;
+import cn.hutool.core.util.RandomUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * 限流器示例
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+@Slf4j
+public class RateLimiterDemo {
+
+ public static void main(String[] args) {
+
+ // ============================================================================
+
+ int qps = 20;
+
+ System.out.println("======================= 固定时间窗口限流算法 =======================");
+ FixedWindowRateLimiter fixedWindowRateLimiter = new FixedWindowRateLimiter(qps);
+ testRateLimit(fixedWindowRateLimiter, qps);
+
+ System.out.println("======================= 滑动时间窗口限流算法 =======================");
+ SlidingWindowRateLimiter slidingWindowRateLimiter = new SlidingWindowRateLimiter(qps, 10);
+ testRateLimit(slidingWindowRateLimiter, qps);
+
+ System.out.println("======================= 漏桶限流算法 =======================");
+ LeakyBucketRateLimiter leakyBucketRateLimiter = new LeakyBucketRateLimiter(qps, 100);
+ testRateLimit(leakyBucketRateLimiter, qps);
+
+ System.out.println("======================= 令牌桶限流算法 =======================");
+ TokenBucketRateLimiter tokenBucketRateLimiter = new TokenBucketRateLimiter(qps, 100);
+ testRateLimit(tokenBucketRateLimiter, qps);
+ }
+
+ private static void testRateLimit(RateLimiter rateLimiter, int qps) {
+
+ AtomicInteger okNum = new AtomicInteger(0);
+ AtomicInteger limitNum = new AtomicInteger(0);
+ ExecutorService executorService = ThreadUtil.newFixedExecutor(10, "限流测试", true);
+ long beginTime = System.currentTimeMillis();
+
+ int threadNum = 4;
+ final CountDownLatch latch = new CountDownLatch(threadNum);
+ for (int i = 0; i < threadNum; i++) {
+ executorService.submit(() -> {
+ try {
+ batchRequest(rateLimiter, okNum, limitNum, 1000);
+ } catch (Exception e) {
+ log.error("发生异常!", e);
+ } finally {
+ latch.countDown();
+ }
+ });
+ }
+
+ try {
+ latch.await(10, TimeUnit.SECONDS);
+ long endTime = System.currentTimeMillis();
+ long gap = endTime - beginTime;
+ log.info("限流 QPS: {} -> 实际结果：耗时 {} ms，{} 次请求成功，{} 次请求被限流，实际 QPS: {}",
+ qps, gap, okNum.get(), limitNum.get(), okNum.get() * 1000 / gap);
+ if (okNum.get() == qps) {
+ log.info("限流符合预期");
+ }
+ } catch (Exception e) {
+ log.error("发生异常!", e);
+ } finally {
+ executorService.shutdown();
+ }
+ }
+
+ private static void batchRequest(RateLimiter rateLimiter, AtomicInteger okNum, AtomicInteger limitNum, int num)
+ throws InterruptedException {
+ for (int j = 0; j < num; j++) {
+ if (rateLimiter.tryAcquire(1)) {
+ log.info("请求成功");
+ okNum.getAndIncrement();
+ } else {
+ log.info("请求限流");
+ limitNum.getAndIncrement();
+ }
+ TimeUnit.MILLISECONDS.sleep(RandomUtil.randomInt(0, 10));
+ }
+ }
+
+}
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisFixedWindowRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisFixedWindowRateLimiter.java
new file mode 100644
index 00000000..ec5d77d9
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisFixedWindowRateLimiter.java
@@ -0,0 +1,100 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.io.resource.ResourceUtil;
+import cn.hutool.core.util.RandomUtil;
+import cn.hutool.core.util.StrUtil;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.exceptions.JedisConnectionException;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 基于 Redis + Lua 实现的固定时间窗口限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-23
+ */
+public class RedisFixedWindowRateLimiter implements RateLimiter {
+
+ private static final String REDIS_HOST = "localhost";
+
+ private static final int REDIS_PORT = 6379;
+
+ private static final Jedis JEDIS;
+
+ public static final String SCRIPT;
+
+ static {
+ // Jedis 有多种构造方法，这里选用最简单的一种情况
+ JEDIS = new Jedis(REDIS_HOST, REDIS_PORT);
+
+ // 触发 ping 命令
+ try {
+ JEDIS.ping();
+ System.out.println("jedis 连接成功");
+ } catch (JedisConnectionException e) {
+ e.printStackTrace();
+ }
+
+ SCRIPT = FileUtil.readString(ResourceUtil.getResource("scripts/fixed_window_rate_limit.lua"),
+ StandardCharsets.UTF_8);
+ }
+
+ private final long maxPermits;
+ private final long periodSeconds;
+ private final String key;
+
+ public RedisFixedWindowRateLimiter(long qps, String key) {
+ this(qps * 60, 60, TimeUnit.SECONDS, key);
+ }
+
+ public RedisFixedWindowRateLimiter(long maxPermits, long period, TimeUnit timeUnit, String key) {
+ this.maxPermits = maxPermits;
+ this.periodSeconds = timeUnit.toSeconds(period);
+ this.key = key;
+ }
+
+ @Override
+ public boolean tryAcquire(int permits) {
+ List keys = Collections.singletonList(key);
+ List args = CollectionUtil.newLinkedList(String.valueOf(permits), String.valueOf(periodSeconds),
+ String.valueOf(maxPermits));
+ Object eval = JEDIS.eval(SCRIPT, keys, args);
+ long value = (long) eval;
+ return value != -1;
+ }
+
+ public static void main(String[] args) throws InterruptedException {
+
+ int qps = 20;
+ RateLimiter jedisFixedWindowRateLimiter = new RedisFixedWindowRateLimiter(qps, "rate:limit:20240122210000");
+
+ // 模拟在一分钟内，不断收到请求，限流是否有效
+ int seconds = 60;
+ long okNum = 0L;
+ long total = 0L;
+ long beginTime = System.currentTimeMillis();
+ int num = RandomUtil.randomInt(qps, 100);
+ for (int second = 0; second < seconds; second++) {
+ for (int i = 0; i < num; i++) {
+ total++;
+ if (jedisFixedWindowRateLimiter.tryAcquire(1)) {
+ okNum++;
+ System.out.println("请求成功");
+ } else {
+ System.out.println("请求限流");
+ }
+ }
+ TimeUnit.SECONDS.sleep(1);
+ }
+ long endTime = System.currentTimeMillis();
+ long time = (endTime - beginTime) / 1000;
+ System.out.println(StrUtil.format("请求通过数：{}，总请求数：{}，实际 QPS：{}", okNum, total, okNum / time));
+ }
+
+}
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisTokenBucketRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisTokenBucketRateLimiter.java
new file mode 100644
index 00000000..9dd219df
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/RedisTokenBucketRateLimiter.java
@@ -0,0 +1,104 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.io.resource.ResourceUtil;
+import cn.hutool.core.util.RandomUtil;
+import cn.hutool.core.util.StrUtil;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.exceptions.JedisConnectionException;
+
+import java.nio.charset.StandardCharsets;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 基于 Redis + Lua 实现的令牌桶限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-23
+ */
+public class RedisTokenBucketRateLimiter implements RateLimiter {
+
+ private static final String REDIS_HOST = "localhost";
+
+ private static final int REDIS_PORT = 6379;
+
+ private static final Jedis JEDIS;
+
+ public static final String SCRIPT;
+
+ static {
+ // Jedis 有多种构造方法，这里选用最简单的一种情况
+ JEDIS = new Jedis(REDIS_HOST, REDIS_PORT);
+
+ // 触发 ping 命令
+ try {
+ JEDIS.ping();
+ System.out.println("jedis 连接成功");
+ } catch (JedisConnectionException e) {
+ e.printStackTrace();
+ }
+
+ SCRIPT = FileUtil.readString(ResourceUtil.getResource("scripts/token_bucket_rate_limit.lua"),
+ StandardCharsets.UTF_8);
+ }
+
+ private final long qps;
+ private final long capacity;
+ private final String tokenKey;
+ private final String timeKey;
+
+ public RedisTokenBucketRateLimiter(long qps, long capacity, String tokenKey, String timeKey) {
+ this.qps = qps;
+ this.capacity = capacity;
+ this.tokenKey = tokenKey;
+ this.timeKey = timeKey;
+ }
+
+ @Override
+ public boolean tryAcquire(int permits) {
+ long now = System.currentTimeMillis();
+ List keys = CollectionUtil.newLinkedList(tokenKey, timeKey);
+ List args = CollectionUtil.newLinkedList(String.valueOf(permits), String.valueOf(qps),
+ String.valueOf(capacity), String.valueOf(now));
+ Object eval = JEDIS.eval(SCRIPT, keys, args);
+ long value = (long) eval;
+ return value != -1;
+ }
+
+ public static void main(String[] args) throws InterruptedException {
+
+ int qps = 20;
+ int bucket = 100;
+ RedisTokenBucketRateLimiter redisTokenBucketRateLimiter =
+ new RedisTokenBucketRateLimiter(qps, bucket, "token:rate:limit", "token:rate:limit:time");
+
+ // 先将令牌桶预热令牌申请完，后续才能真实反映限流 QPS
+ redisTokenBucketRateLimiter.tryAcquire(bucket);
+ TimeUnit.SECONDS.sleep(1);
+
+ // 模拟在一分钟内，不断收到请求，限流是否有效
+ int seconds = 60;
+ long okNum = 0L;
+ long total = 0L;
+ long beginTime = System.currentTimeMillis();
+ for (int second = 0; second < seconds; second++) {
+ int num = RandomUtil.randomInt(qps, 100);
+ for (int i = 0; i < num; i++) {
+ total++;
+ if (redisTokenBucketRateLimiter.tryAcquire(1)) {
+ okNum++;
+ System.out.println("请求成功");
+ } else {
+ System.out.println("请求限流");
+ }
+ }
+ TimeUnit.SECONDS.sleep(1);
+ }
+ long endTime = System.currentTimeMillis();
+ long time = (endTime - beginTime) / 1000;
+ System.out.println(StrUtil.format("请求通过数：{}，总请求数：{}，实际 QPS：{}", okNum, total, okNum / time));
+ }
+
+}
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/SlidingWindowRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/SlidingWindowRateLimiter.java
new file mode 100644
index 00000000..a93613a2
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/SlidingWindowRateLimiter.java
@@ -0,0 +1,87 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * 滑动时间窗口限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+public class SlidingWindowRateLimiter implements RateLimiter {
+
+ /**
+ * 允许的最大请求数
+ */
+ private final long maxPermits;
+
+ /**
+ * 窗口期时长
+ */
+ private final long periodMillis;
+
+ /**
+ * 分片窗口期时长
+ */
+ private final long shardPeriodMillis;
+
+ /**
+ * 窗口期截止时间
+ */
+ private long lastPeriodMillis;
+
+ /**
+ * 分片窗口数
+ */
+ private final int shardNum;
+
+ /**
+ * 请求总计数
+ */
+ private final AtomicLong totalCount = new AtomicLong(0);
+
+ /**
+ * 分片窗口计数列表
+ */
+ private final List countList = new LinkedList<>();
+
+ public SlidingWindowRateLimiter(long qps, int shardNum) {
+ this(qps, 1000, TimeUnit.MILLISECONDS, shardNum);
+ }
+
+ public SlidingWindowRateLimiter(long maxPermits, long period, TimeUnit timeUnit, int shardNum) {
+ this.maxPermits = maxPermits;
+ this.periodMillis = timeUnit.toMillis(period);
+ this.lastPeriodMillis = System.currentTimeMillis();
+ this.shardPeriodMillis = timeUnit.toMillis(period) / shardNum;
+ this.shardNum = shardNum;
+ for (int i = 0; i < shardNum; i++) {
+ countList.add(new AtomicLong(0));
+ }
+ }
+
+ @Override
+ public synchronized boolean tryAcquire(int permits) {
+ long now = System.currentTimeMillis();
+ if (now > lastPeriodMillis) {
+ for (int shardId = 0; shardId < shardNum; shardId++) {
+ long shardCount = countList.get(shardId).get();
+ totalCount.addAndGet(-shardCount);
+ countList.set(shardId, new AtomicLong(0));
+ lastPeriodMillis += shardPeriodMillis;
+ }
+ }
+ int shardId = (int) (now % periodMillis / shardPeriodMillis);
+ if (totalCount.get() + permits <= maxPermits) {
+ countList.get(shardId).addAndGet(permits);
+ totalCount.addAndGet(permits);
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/TokenBucketRateLimiter.java b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/TokenBucketRateLimiter.java
new file mode 100644
index 00000000..e03e4c7d
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/java/io/github/dunwu/distributed/ratelimit/TokenBucketRateLimiter.java
@@ -0,0 +1,59 @@
+package io.github.dunwu.distributed.ratelimit;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * 令牌桶限流算法
+ *
+ * @author Zhang Peng
+ * @date 2024-01-18
+ */
+public class TokenBucketRateLimiter implements RateLimiter {
+
+ /**
+ * QPS
+ */
+ private final long qps;
+
+ /**
+ * 桶的容量
+ */
+ private final long capacity;
+
+ /**
+ * 上一次令牌发放时间
+ */
+ private long endTimeMillis;
+
+ /**
+ * 桶中当前的令牌数量
+ */
+ private final AtomicLong tokenNum = new AtomicLong(0);
+
+ public TokenBucketRateLimiter(long qps, long capacity) {
+ this.qps = qps;
+ this.capacity = capacity;
+ this.endTimeMillis = System.currentTimeMillis();
+ }
+
+ @Override
+ public synchronized boolean tryAcquire(int permits) {
+
+ long now = System.currentTimeMillis();
+ long gap = now - endTimeMillis;
+
+ // 计算令牌数
+ long newTokenNum = (gap * qps / 1000);
+ long currentTokenNum = tokenNum.get() + newTokenNum;
+ tokenNum.set(Math.min(capacity, currentTokenNum));
+
+ if (tokenNum.get() < permits) {
+ return false;
+ } else {
+ tokenNum.addAndGet(-permits);
+ endTimeMillis = now;
+ return true;
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/codes/java-distributed/java-rate-limit/src/main/resources/scripts/fixed_window_rate_limit.lua b/codes/java-distributed/java-rate-limit/src/main/resources/scripts/fixed_window_rate_limit.lua
new file mode 100644
index 00000000..e0c9ad00
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/resources/scripts/fixed_window_rate_limit.lua
@@ -0,0 +1,21 @@
+-- 缓存 Key
+local key = KEYS[1]
+-- 访问请求数
+local permits = tonumber(ARGV[1])
+-- 过期时间
+local seconds = tonumber(ARGV[2])
+-- 限流阈值
+local limit = tonumber(ARGV[3])
+
+-- 获取统计值
+local count = tonumber(redis.call('GET', key) or "0")
+
+if count + permits > limit then
+ -- 请求拒绝
+ return -1
+else
+ -- 请求通过
+ redis.call('INCRBY', key, permits)
+ redis.call('EXPIRE', key, seconds)
+ return count + permits
+end
\ No newline at end of file
diff --git a/codes/java-distributed/java-rate-limit/src/main/resources/scripts/token_bucket_rate_limit.lua b/codes/java-distributed/java-rate-limit/src/main/resources/scripts/token_bucket_rate_limit.lua
new file mode 100644
index 00000000..541d70c9
--- /dev/null
+++ b/codes/java-distributed/java-rate-limit/src/main/resources/scripts/token_bucket_rate_limit.lua
@@ -0,0 +1,39 @@
+local tokenKey = KEYS[1]
+local timeKey = KEYS[2]
+
+-- 申请令牌数
+local permits = tonumber(ARGV[1])
+-- QPS
+local qps = tonumber(ARGV[2])
+-- 桶的容量
+local capacity = tonumber(ARGV[3])
+-- 当前时间（单位：毫秒）
+local nowMillis = tonumber(ARGV[4])
+-- 填满令牌桶所需要的时间
+local fillTime = capacity / qps
+local ttl = math.min(capacity, math.floor(fillTime * 2))
+
+local currentTokenNum = tonumber(redis.call("GET", tokenKey))
+if currentTokenNum == nil then
+ currentTokenNum = capacity
+end
+
+local endTimeMillis = tonumber(redis.call("GET", timeKey))
+if endTimeMillis == nil then
+ endTimeMillis = 0
+end
+
+local gap = nowMillis - endTimeMillis
+local newTokenNum = math.max(0, gap * qps / 1000)
+local currentTokenNum = math.min(capacity, currentTokenNum + newTokenNum)
+
+if currentTokenNum < permits then
+ -- 请求拒绝
+ return -1
+else
+ -- 请求通过
+ local finalTokenNum = currentTokenNum - permits
+ redis.call("SETEX", tokenKey, ttl, finalTokenNum)
+ redis.call("SETEX", timeKey, ttl, nowMillis)
+ return finalTokenNum
+end
diff --git a/codes/java-distributed/java-task/pom.xml b/codes/java-distributed/java-task/pom.xml
new file mode 100644
index 00000000..8d7cc462
--- /dev/null
+++ b/codes/java-distributed/java-task/pom.xml
@@ -0,0 +1,40 @@
+
+
+ 4.0.0
+
+
+ io.github.dunwu.distributed
+ java-distributed
+ 1.0.0
+
+
+ io.github.dunwu.distributed
+ java-task
+ 1.0.0
+ jar
+
+
+ UTF-8
+ 1.8
+ ${java.version}
+ ${java.version}
+
+
+
+
+ cn.hutool
+ hutool-all
+
+
+ org.projectlombok
+ lombok
+
+
+ ch.qos.logback
+ logback-classic
+ 1.2.3
+ true
+
+
+
diff --git a/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/DelayQueueExample.java b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/DelayQueueExample.java
new file mode 100644
index 00000000..d510eed1
--- /dev/null
+++ b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/DelayQueueExample.java
@@ -0,0 +1,52 @@
+package io.github.dunwu.local.task;
+
+import cn.hutool.core.date.DateUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Date;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.DelayQueue;
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+public class DelayQueueExample {
+
+ public static void main(String[] args) throws InterruptedException {
+ BlockingQueue delayQueue = new DelayQueue<>();
+ long now = System.currentTimeMillis();
+ delayQueue.put(new SampleTask(now + 1000));
+ delayQueue.put(new SampleTask(now + 2000));
+ delayQueue.put(new SampleTask(now + 3000));
+ for (int i = 0; i < 3; i++) {
+ log.info("task 执行时间：{}", DateUtil.format(new Date(delayQueue.take().getTime()), "yyyy-MM-dd HH:mm:ss"));
+ }
+ }
+
+ static class SampleTask implements Delayed {
+
+ long time;
+
+ public SampleTask(long time) {
+ this.time = time;
+ }
+
+ public long getTime() {
+ return time;
+ }
+
+ @Override
+ public int compareTo(Delayed o) {
+ return Long.compare(this.getDelay(TimeUnit.MILLISECONDS), o.getDelay(TimeUnit.MILLISECONDS));
+ }
+
+ @Override
+ public long getDelay(TimeUnit unit) {
+ return unit.convert(time - System.currentTimeMillis(), TimeUnit.MILLISECONDS);
+ }
+
+ }
+
+}
+
+
diff --git a/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/ScheduledExecutorServiceExample.java b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/ScheduledExecutorServiceExample.java
new file mode 100644
index 00000000..78e8f5bd
--- /dev/null
+++ b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/ScheduledExecutorServiceExample.java
@@ -0,0 +1,37 @@
+package io.github.dunwu.local.task;
+
+import cn.hutool.core.date.DateUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Date;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+@Slf4j
+public class ScheduledExecutorServiceExample {
+
+ public static void main(String[] args) {
+ // 创建一个 ScheduledExecutorService 对象，它将使用一个线程池来执行任务
+ ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
+
+ // 创建一个 Runnable 对象，这个任务将在 2 秒后执行，并且每 1 秒重复执行一次
+ Runnable task = () -> {
+ log.info("task 执行时间：{}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
+ };
+
+ // 安排任务在 2 秒后执行，并且每 1 秒重复执行一次
+ executor.scheduleAtFixedRate(task, 2, 1, TimeUnit.SECONDS);
+
+ // 主线程等待 10 秒后结束
+ try {
+ Thread.sleep(10000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ // 关闭 executor，这将停止所有正在执行的任务，并拒绝新任务的提交
+ executor.shutdown();
+ }
+
+}
diff --git a/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/TimerExample.java b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/TimerExample.java
new file mode 100644
index 00000000..ce1d7756
--- /dev/null
+++ b/codes/java-distributed/java-task/src/main/java/io/github/dunwu/local/task/TimerExample.java
@@ -0,0 +1,39 @@
+package io.github.dunwu.local.task;
+
+import cn.hutool.core.date.DateUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Date;
+import java.util.Timer;
+import java.util.TimerTask;
+
+@Slf4j
+public class TimerExample {
+
+ public static void main(String[] args) {
+ // 创建一个 Timer 对象
+ Timer timer = new Timer();
+
+ // 创建一个 TimerTask 对象，这个任务将在 2 秒后执行，并且每 1 秒重复执行一次
+ TimerTask task = new TimerTask() {
+ @Override
+ public void run() {
+ log.info("task 执行时间：{}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
+ }
+ };
+
+ // 安排任务在 2 秒后执行，并且每 1 秒重复执行一次
+ timer.schedule(task, 2000, 1000);
+
+ // 主线程等待 10 秒后结束
+ try {
+ Thread.sleep(10000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ // 取消定时器和所有已安排的任务
+ timer.cancel();
+ }
+
+}
diff --git a/codes/java-distributed/pom.xml b/codes/java-distributed/pom.xml
index 35fd5860..aa88d15d 100644
--- a/codes/java-distributed/pom.xml
+++ b/codes/java-distributed/pom.xml
@@ -3,15 +3,52 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
- io.github.dunwu.javatech
+ io.github.dunwu.distributed
java-distributed
1.0.0
pom
- JAVA-DISTRIBUTED
- JAVA-DISTRIBUTED 示例源码
java-load-balance
+ java-rate-limit
+ java-distributed-id
+ java-task
+
+
+
+ org.apache.zookeeper
+ zookeeper
+ 3.9.2
+
+
+ org.apache.curator
+ curator-recipes
+ 4.3.0
+
+
+ redis.clients
+ jedis
+ 5.1.0
+
+
+ cn.hutool
+ hutool-all
+ 5.8.34
+
+
+ org.projectlombok
+ lombok
+ 1.18.30
+
+
+ ch.qos.logback
+ logback-classic
+ 1.4.12
+ true
+
+
+
+
diff --git a/codes/javatech/javatech-cache/pom.xml b/codes/javatech/javatech-cache/pom.xml
new file mode 100644
index 00000000..4503c60c
--- /dev/null
+++ b/codes/javatech/javatech-cache/pom.xml
@@ -0,0 +1,76 @@
+
+
+ 4.0.0
+
+
+ org.springframework.boot
+ spring-boot-starter-parent
+ 2.2.1.RELEASE
+
+
+ io.github.dunwu.javatech
+ javatech-cache
+ 1.0.0
+ jar
+ JAVATECH-缓存示例
+
+
+
+ org.springframework.boot
+ spring-boot-starter-data-jpa
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
+
+ org.springframework.boot
+ spring-boot-starter-cache
+
+
+ net.sf.ehcache
+ ehcache
+
+
+ com.github.ben-manes.caffeine
+ caffeine
+
+
+ net.spy
+ spymemcached
+ 2.12.2
+
+
+ com.google.guava
+ guava
+ 29.0-jre
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+
+
+ org.projectlombok
+ lombok
+
+
+ mysql
+ mysql-connector-java
+
+
+ com.h2database
+ h2
+ test
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/SpringBootDataCacheApplication.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/SpringBootDataCacheApplication.java
new file mode 100644
index 00000000..4a5220d3
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/SpringBootDataCacheApplication.java
@@ -0,0 +1,87 @@
+package io.github.dunwu.javatech;
+
+import io.github.dunwu.javatech.data.User;
+import io.github.dunwu.javatech.data.UserDao;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import javax.sql.DataSource;
+
+/**
+ * @author Zhang Peng
+ * @since 2019-10-14
+ */
+@EnableCaching
+@SpringBootApplication
+public class SpringBootDataCacheApplication implements CommandLineRunner {
+
+ private final Logger log = LoggerFactory.getLogger(this.getClass());
+
+ private final UserDao userDao;
+
+ public SpringBootDataCacheApplication(UserDao userDao) {
+ this.userDao = userDao;
+ }
+
+ public static void main(String[] args) {
+ SpringApplication.run(SpringBootDataCacheApplication.class, args);
+ }
+
+ @Override
+ public void run(String... args) throws Exception {
+
+ if (userDao != null) {
+ printDataSourceInfo(userDao.getJdbcTemplate());
+ log.info("连接数据源成功！");
+ } else {
+ log.error("连接数据源失败！");
+ return;
+ }
+
+ for (int i = 1; i <= 3; i++) {
+ User user = userDao.queryByName("张三");
+ log.info("第 {} 次查询 name = {}", i, user.toString());
+ }
+
+ for (int i = 1; i <= 3; i++) {
+ User user = userDao.queryByName("李四");
+ log.info("第 {} 次查询 name = {}", i, user.toString());
+ }
+
+ User result = userDao.queryByName("张三");
+ result.setAddress("深圳");
+ userDao.update(result);
+
+ for (int i = 1; i <= 3; i++) {
+ User user = userDao.queryByName("张三");
+ log.info("第 {} 次查询 name = {}", i, user.toString());
+ }
+ }
+
+ public void printDataSourceInfo(JdbcTemplate jdbcTemplate) throws SQLException {
+
+ DataSource dataSource = jdbcTemplate.getDataSource();
+
+ Connection connection;
+ if (dataSource != null) {
+ connection = dataSource.getConnection();
+ } else {
+ log.error("获取 DataSource 失败");
+ return;
+ }
+
+ if (connection != null) {
+ log.info("DB URL: {}", connection.getMetaData().getURL());
+ } else {
+ log.error("获取 Connection 失败");
+ }
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/CaffeineDemo.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/CaffeineDemo.java
new file mode 100644
index 00000000..484259a6
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/CaffeineDemo.java
@@ -0,0 +1,23 @@
+package io.github.dunwu.javatech.cache;
+
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author Zhang Peng
+ * @since 2020-07-09
+ */
+public class CaffeineDemo {
+
+ public static void main(String[] args) {
+ Cache cache = Caffeine.newBuilder()
+ .expireAfterWrite(1, TimeUnit.SECONDS)
+ .expireAfterAccess(1, TimeUnit.SECONDS)
+ .maximumSize(10)
+ .build();
+ cache.put("hello", "hello");
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/GuavaCacheDemo.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/GuavaCacheDemo.java
new file mode 100644
index 00000000..1cdb585e
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/GuavaCacheDemo.java
@@ -0,0 +1,55 @@
+package io.github.dunwu.javatech.cache;
+
+import com.google.common.cache.*;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author Zhang Peng
+ * @since 2020-07-09
+ */
+public class GuavaCacheDemo {
+
+ public static void main(String[] args) {
+ CacheLoader loader = new CacheLoader() {
+ @Override
+ public String load(String key) throws Exception {
+ Thread.sleep(1000);
+ if ("key".equals(key)) {
+ return null;
+ }
+ System.out.println(key + " is loaded from a cacheLoader!");
+ return key + "'s value";
+ }
+ };
+
+ RemovalListener removalListener = new RemovalListener() {
+ @Override
+ public void onRemoval(RemovalNotification removal) {
+ System.out.println("[" + removal.getKey() + ":" + removal.getValue() + "] is evicted!");
+ }
+ };
+
+ LoadingCache testCache = CacheBuilder.newBuilder()
+ .maximumSize(7)
+ .expireAfterWrite(10, TimeUnit.MINUTES)
+ .removalListener(removalListener)
+ .build(loader);
+
+ for (int i = 0; i < 10; i++) {
+ String key = "key" + i;
+ String value = "value" + i;
+ testCache.put(key, value);
+ System.out.println("[" + key + ":" + value + "] is put into cache!");
+ }
+
+ System.out.println(testCache.getIfPresent("key6"));
+
+ try {
+ System.out.println(testCache.get("key"));
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/LRUCache.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/LRUCache.java
new file mode 100644
index 00000000..3d38eae3
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/LRUCache.java
@@ -0,0 +1,60 @@
+package io.github.dunwu.javatech.cache;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 通过继承 LinkedHashMap 来实现一个简单的 LRUHashMap
+ *
+ * 核心思想就是：LRU （最近最少使用）算法
+ *
+ * @author Zhang Peng
+ * @since 2020-01-18
+ */
+class LRUCache extends LinkedHashMap {
+
+ private final int max;
+ private Object lock;
+
+ public LRUCache(int max) {
+ //无需扩容
+ super((int) (max * 1.4f), 0.75f, true);
+ this.max = max;
+ this.lock = new Object();
+ }
+
+ /**
+ * 重写LinkedHashMap的removeEldestEntry方法即可 在Put的时候判断，如果为true，就会删除最老的
+ *
+ * @param eldest
+ * @return
+ */
+ @Override
+ protected boolean removeEldestEntry(Map.Entry eldest) {
+ return size() > max;
+ }
+
+ public Object getValue(Object key) {
+ synchronized (lock) {
+ return get(key);
+ }
+ }
+
+ public void putValue(Object key, Object value) {
+ synchronized (lock) {
+ put(key, value);
+ }
+ }
+
+ public boolean removeValue(Object key) {
+ synchronized (lock) {
+ return remove(key) != null;
+ }
+ }
+
+ public boolean removeAll() {
+ clear();
+ return true;
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/MemcachedDemo.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/MemcachedDemo.java
new file mode 100644
index 00000000..9399b12d
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/cache/MemcachedDemo.java
@@ -0,0 +1,294 @@
+package io.github.dunwu.javatech.cache;
+
+import net.spy.memcached.CASResponse;
+import net.spy.memcached.CASValue;
+import net.spy.memcached.MemcachedClient;
+
+import java.net.InetSocketAddress;
+import java.util.concurrent.Future;
+
+/**
+ * Memcached 客户端连接示例
+ *
+ * @author Zhang Peng
+ * @since 2020-07-10
+ */
+public class MemcachedDemo {
+
+ public static final String URL = "127.0.0.1";
+ public static final int PORT = 11211;
+
+ public static void main(String[] args) {
+ add();
+ remove();
+ append();
+ prepend();
+ cas();
+ get();
+ delete();
+ incrAndDecr();
+ }
+
+ public static void add() {
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "Free Education");
+
+ // 打印状态
+ System.out.println("set status:" + fo.get());
+
+ // 输出
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 添加
+ fo = mcc.add("MyKey", 900, "memcached");
+
+ // 打印状态
+ System.out.println("add status:" + fo.get());
+
+ // 添加新key
+ fo = mcc.add("codingground", 900, "All Free Compilers");
+
+ // 打印状态
+ System.out.println("add status:" + fo.get());
+
+ // 输出
+ System.out.println("codingground value in cache - " + mcc.get("codingground"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void remove() {
+
+ try {
+ //连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加第一个 key=》value 对
+ Future fo = mcc.set("MyKey", 900, "Free Education");
+
+ // 输出执行 add 方法后的状态
+ System.out.println("add status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 添加新的 key
+ fo = mcc.replace("MyKey", 900, "Largest Tutorials' Library");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("replace status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void append() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "Free Education");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 对存在的key进行数据添加操作
+ fo = mcc.append(900, "MyKey", " for All");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("append status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("codingground"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void prepend() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "Education for All");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 对存在的key进行数据添加操作
+ fo = mcc.prepend(900, "MyKey", "Free ");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("prepend status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("codingground"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void cas() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "Free Education");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 使用 get 方法获取数据
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 通过 gets 方法获取 CAS token（令牌）
+ CASValue casValue = mcc.gets("MyKey");
+
+ // 输出 CAS token（令牌） 值
+ System.out.println("CAS token - " + casValue);
+
+ // 尝试使用cas方法来更新数据
+ CASResponse casresp = mcc.cas("MyKey", casValue.getCas(), 900, "Largest Tutorials-Library");
+
+ // 输出 CAS 响应信息
+ System.out.println("CAS Response - " + casresp);
+
+ // 输出值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void get() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "Free Education");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 使用 get 方法获取数据
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void delete() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数据
+ Future fo = mcc.set("MyKey", 900, "World's largest online tutorials library");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("MyKey"));
+
+ // 对存在的key进行数据添加操作
+ fo = mcc.delete("MyKey");
+
+ // 输出执行 delete 方法后的状态
+ System.out.println("delete status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("MyKey value in cache - " + mcc.get("codingground"));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+ public static void incrAndDecr() {
+
+ try {
+
+ // 连接本地的 Memcached 服务
+ MemcachedClient mcc = new MemcachedClient(new InetSocketAddress(URL, PORT));
+ System.out.println("Connection to server sucessful.");
+
+ // 添加数字值
+ Future fo = mcc.set("number", 900, "1000");
+
+ // 输出执行 set 方法后的状态
+ System.out.println("set status:" + fo.get());
+
+ // 获取键对应的值
+ System.out.println("value in cache - " + mcc.get("number"));
+
+ // 自增并输出
+ System.out.println("value in cache after increment - " + mcc.incr("number", 111));
+
+ // 自减并输出
+ System.out.println("value in cache after decrement - " + mcc.decr("number", 112));
+
+ // 关闭连接
+ mcc.shutdown();
+ } catch (Exception ex) {
+ System.out.println(ex.getMessage());
+ }
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/User.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/User.java
new file mode 100644
index 00000000..758e3c9a
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/User.java
@@ -0,0 +1,38 @@
+package io.github.dunwu.javatech.data;
+
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+
+@Data
+@ToString
+public class User implements Serializable {
+
+ private static final long serialVersionUID = 4142994984277644695L;
+
+ private Long id;
+
+ private String name;
+
+ private Integer age;
+
+ private String address;
+
+ private String email;
+
+ public User() {}
+
+ public User(Long id, String name) {
+ this.id = id;
+ this.name = name;
+ }
+
+ public User(String name, Integer age, String address, String email) {
+ this.name = name;
+ this.age = age;
+ this.address = address;
+ this.email = email;
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDao.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDao.java
new file mode 100644
index 00000000..370147cd
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDao.java
@@ -0,0 +1,33 @@
+package io.github.dunwu.javatech.data;
+
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import java.util.List;
+
+public interface UserDao {
+
+ void batchInsert(List users);
+
+ Integer count();
+
+ @CacheEvict(value = "dunwu:users", key = "#name")
+ int deleteByName(String name);
+
+ void insert(User user);
+
+ List list();
+
+ @Cacheable(value = "dunwu:users", key = "#name")
+ User queryByName(String name);
+
+ void recreateTable();
+
+ @CachePut(value = "dunwu:users", key = "#user.name")
+ User update(User user);
+
+ JdbcTemplate getJdbcTemplate();
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDaoImpl.java b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDaoImpl.java
new file mode 100644
index 00000000..a69ec012
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/java/io/github/dunwu/javatech/data/UserDaoImpl.java
@@ -0,0 +1,105 @@
+package io.github.dunwu.javatech.data;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.dao.EmptyResultDataAccessException;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class UserDaoImpl implements UserDao {
+
+ private final Logger log = LoggerFactory.getLogger(this.getClass());
+
+ private final JdbcTemplate jdbcTemplate;
+
+ public UserDaoImpl(JdbcTemplate jdbcTemplate) {
+ this.jdbcTemplate = jdbcTemplate;
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void batchInsert(List users) {
+ String sql = "INSERT INTO user(name, age, address, email) VALUES(?, ?, ?, ?)";
+
+ List params = new ArrayList<>();
+
+ users.forEach(item -> {
+ params.add(new Object[] { item.getName(), item.getAge(), item.getAddress(), item.getEmail() });
+ });
+ jdbcTemplate.batchUpdate(sql, params);
+ }
+
+ @Override
+ public Integer count() {
+ try {
+ return jdbcTemplate.queryForObject("SELECT COUNT(*) FROM user", Integer.class);
+ } catch (EmptyResultDataAccessException e) {
+ return null;
+ }
+ }
+
+ @Override
+ public int deleteByName(String name) {
+ int result = jdbcTemplate.update("DELETE FROM user WHERE name = ?", name);
+ log.info("[Delete] name = {}", name);
+ return result;
+ }
+
+ @Override
+ public void insert(User user) {
+ jdbcTemplate.update("INSERT INTO user(name, age, address, email) VALUES(?, ?, ?, ?)", user.getName(),
+ user.getAge(), user.getAddress(), user.getEmail());
+ }
+
+ @Override
+ public List list() {
+ return jdbcTemplate.query("select * from USER", new BeanPropertyRowMapper(User.class));
+ }
+
+ @Override
+ public User queryByName(String name) {
+
+ try {
+ User user = jdbcTemplate.queryForObject("SELECT * FROM user WHERE name = ?",
+ new BeanPropertyRowMapper<>(User.class), name);
+ log.info("[Query] name = {}, result = {}", name, user);
+ return user;
+ } catch (EmptyResultDataAccessException e) {
+ return null;
+ }
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void recreateTable() {
+ jdbcTemplate.execute("DROP TABLE IF EXISTS user");
+
+ String sqlStatement =
+ "CREATE TABLE user (\n" + " id BIGINT(10) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'Id',\n"
+ + " name VARCHAR(10) NOT NULL DEFAULT '' COMMENT '用户名',\n"
+ + " age TINYINT(3) NOT NULL DEFAULT 0 COMMENT '年龄',\n"
+ + " address VARCHAR(32) NOT NULL DEFAULT '' COMMENT '地址',\n"
+ + " email VARCHAR(32) NOT NULL DEFAULT '' COMMENT '邮件',\n" + " PRIMARY KEY (id)\n"
+ + ") COMMENT = '用户表';";
+ jdbcTemplate.execute(sqlStatement);
+ }
+
+ @Override
+ public User update(User user) {
+ jdbcTemplate.update("UPDATE USER SET name=?, age=?, address=?, email=? WHERE id=?", user.getName(),
+ user.getAge(), user.getAddress(), user.getEmail(), user.getId());
+ return user;
+ }
+
+ @Override
+ public JdbcTemplate getJdbcTemplate() {
+ return jdbcTemplate;
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/main/resources/application.properties b/codes/javatech/javatech-cache/src/main/resources/application.properties
new file mode 100644
index 00000000..63306cc8
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/resources/application.properties
@@ -0,0 +1,15 @@
+spring.datasource.url = jdbc:mysql://localhost:3306/spring_boot_tutorial?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false
+spring.datasource.driver-class-name = com.mysql.cj.jdbc.Driver
+spring.datasource.username = root
+spring.datasource.password = root
+# 强制每次启动使用 sql 初始化数据，本项目仅为了演示方便，真实环境应避免这种模式
+spring.datasource.initialization-mode = ALWAYS
+spring.datasource.schema = classpath:sql/schema.sql
+spring.datasource.data = classpath:sql/data.sql
+#spring.redis.database = 0
+#spring.redis.host = localhost
+#spring.redis.port = 6379
+#spring.redis.password =
+spring.cache.type = simple
+spring.cache.cache-names = dunwu
+spring.cache.redis.time-to-live = 60s
diff --git a/codes/javatech/javatech-cache/src/main/resources/banner.txt b/codes/javatech/javatech-cache/src/main/resources/banner.txt
new file mode 100644
index 00000000..449413d5
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/resources/banner.txt
@@ -0,0 +1,12 @@
+${AnsiColor.BRIGHT_YELLOW}${AnsiStyle.BOLD}
+ ________ ___ ___ ________ ___ __ ___ ___
+|\ ___ \|\ \|\ \|\ ___ \|\ \ |\ \|\ \|\ \
+\ \ \_|\ \ \ \\\ \ \ \\ \ \ \ \ \ \ \ \ \\\ \
+ \ \ \ \\ \ \ \\\ \ \ \\ \ \ \ \ __\ \ \ \ \\\ \
+ \ \ \_\\ \ \ \\\ \ \ \\ \ \ \ \|\__\_\ \ \ \\\ \
+ \ \_______\ \_______\ \__\\ \__\ \____________\ \_______\
+ \|_______|\|_______|\|__| \|__|\|____________|\|_______|
+${AnsiColor.CYAN}${AnsiStyle.BOLD}
+:: Java :: (v${java.version})
+:: Spring Boot :: (v${spring-boot.version})
+${AnsiStyle.NORMAL}
diff --git a/codes/javatech/javatech-cache/src/main/resources/logback.xml b/codes/javatech/javatech-cache/src/main/resources/logback.xml
new file mode 100644
index 00000000..240ee4c6
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/resources/logback.xml
@@ -0,0 +1,15 @@
+
+
+
+
+ %d{HH:mm:ss.SSS} [%boldYellow(%thread)] [%highlight(%-5level)] %boldGreen(%c{36}.%M) - %boldBlue(%m%n)
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/main/resources/sql/data.sql b/codes/javatech/javatech-cache/src/main/resources/sql/data.sql
new file mode 100644
index 00000000..694c3472
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/resources/sql/data.sql
@@ -0,0 +1,8 @@
+-- -------------------------------------------
+-- 运行本项目的 DML 脚本
+-- -------------------------------------------
+
+INSERT INTO user (name, age, address, email)
+VALUES ('张三', 18, '北京', 'xxx@163.com');
+INSERT INTO user (name, age, address, email)
+VALUES ('李四', 19, '上海', 'xxx@163.com');
diff --git a/codes/javatech/javatech-cache/src/main/resources/sql/schema.sql b/codes/javatech/javatech-cache/src/main/resources/sql/schema.sql
new file mode 100644
index 00000000..247bdc1e
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/main/resources/sql/schema.sql
@@ -0,0 +1,13 @@
+-- -------------------------------------------
+-- 运行本项目的 DDL 脚本
+-- -------------------------------------------
+
+-- 创建数据表 user
+CREATE TABLE IF NOT EXISTS user (
+ id BIGINT(10) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'Id',
+ name VARCHAR(10) NOT NULL DEFAULT '' COMMENT '用户名',
+ age TINYINT(3) NOT NULL DEFAULT 0 COMMENT '年龄',
+ address VARCHAR(32) NOT NULL DEFAULT '' COMMENT '地址',
+ email VARCHAR(32) NOT NULL DEFAULT '' COMMENT '邮件',
+ PRIMARY KEY (id)
+) COMMENT = '用户表';
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/EhcacheApiTest.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/EhcacheApiTest.java
new file mode 100644
index 00000000..d8d2a356
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/EhcacheApiTest.java
@@ -0,0 +1,235 @@
+package io.github.dunwu.javatech.cache;
+
+import net.sf.ehcache.Cache;
+import net.sf.ehcache.CacheManager;
+import net.sf.ehcache.Element;
+import net.sf.ehcache.config.CacheConfiguration;
+import net.sf.ehcache.config.PersistenceConfiguration;
+import net.sf.ehcache.store.MemoryStoreEvictionPolicy;
+import org.junit.jupiter.api.Test;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.net.URL;
+
+/**
+ * Ehcache API 测试（没有和任何框架集成的情况）
+ *
+ * @author Zhang Peng
+ * @since 2019-09-04
+ */
+public class EhcacheApiTest {
+
+ /**
+ * 使用Ehcache默认配置(classpath下的ehcache.xml)获取单例的CacheManager实例
+ */
+ @Test
+ public void operation() {
+ CacheManager manager = CacheManager.newInstance("src/test/resources/ehcache/ehcache.xml");
+
+ // 获得Cache的引用
+ Cache cache = manager.getCache("users");
+
+ // 将一个Element添加到Cache
+ cache.put(new Element("key1", "value1"));
+
+ // 获取Element，Element类支持序列化，所以下面两种方法都可以用
+ Element element1 = cache.get("key1");
+ // 获取非序列化的值
+ System.out.println("key=" + element1.getObjectKey() + ", value=" + element1.getObjectValue());
+ // 获取序列化的值
+ System.out.println("key=" + element1.getKey() + ", value=" + element1.getValue());
+
+ // 更新Cache中的Element
+ cache.put(new Element("key1", "value2"));
+ Element element2 = cache.get("key1");
+ System.out.println("key=" + element2.getObjectKey() + ", value=" + element2.getObjectValue());
+
+ // 获取Cache的元素数
+ System.out.println("cache size:" + cache.getSize());
+
+ // 获取MemoryStore的元素数
+ System.out.println("MemoryStoreSize:" + cache.getMemoryStoreSize());
+
+ // 获取DiskStore的元素数
+ System.out.println("DiskStoreSize:" + cache.getDiskStoreSize());
+
+ // 移除Element
+ cache.remove("key1");
+ System.out.println("cache size:" + cache.getSize());
+
+ // 关闭当前CacheManager对象
+ manager.shutdown();
+
+ // 关闭CacheManager单例实例
+ CacheManager.getInstance().shutdown();
+ }
+
+ /**
+ * 使用Ehcache默认配置(classpath下的ehcache.xml)获取单例的CacheManager实例
+ */
+ @Test
+ public void create01() {
+ CacheManager cacheManager = CacheManager.create();
+
+ String[] cacheNames = cacheManager.getCacheNames();
+ for (String name : cacheNames) {
+ System.out.println("name:" + name);
+ }
+
+ cacheManager.shutdown();
+ }
+
+ /**
+ * 使用Ehcache默认配置(classpath下的ehcache.xml)新建一个单例的CacheManager实例
+ */
+ @Test
+ public void create02() {
+ CacheManager.newInstance();
+
+ String[] cacheNames = CacheManager.getInstance().getCacheNames();
+ for (String name : cacheNames) {
+ System.out.println("name:" + name);
+ }
+
+ // 关闭CacheManager单例实例
+ CacheManager.getInstance().shutdown();
+ }
+
+ /**
+ * 使用不同的配置文件分别创建一个CacheManager实例
+ */
+ @Test
+ public void create03() {
+ CacheManager manager1 = CacheManager.newInstance("src/test/resources/ehcache/ehcache1.xml");
+ CacheManager manager2 = CacheManager.newInstance("src/test/resources/ehcache/ehcache1.xml");
+ String[] cacheNamesForManager1 = manager1.getCacheNames();
+ String[] cacheNamesForManager2 = manager2.getCacheNames();
+
+ for (String name : cacheNamesForManager1) {
+ System.out.println("[ehcache1.xml]name:" + name);
+ }
+
+ for (String name : cacheNamesForManager2) {
+ System.out.println("[ehcache2.xml]name:" + name);
+ }
+
+ manager1.shutdown();
+ manager2.shutdown();
+ }
+
+ /**
+ * 基于classpath下的配置文件创建CacheManager实例
+ */
+ @Test
+ public void create04() {
+ URL url = getClass().getResource("/ehcache/ehcache.xml");
+ CacheManager manager = CacheManager.newInstance(url);
+ String[] cacheNames = manager.getCacheNames();
+
+ for (String name : cacheNames) {
+ System.out.println("[ehcache.xml]name:" + name);
+ }
+
+ manager.shutdown();
+ }
+
+ /**
+ * 基于IO流得到配置文件，并创建CacheManager实例
+ */
+ @Test
+ public void create05() throws Exception {
+ InputStream fis = new FileInputStream(new File("src/test/resources/ehcache/ehcache.xml").getAbsolutePath());
+ CacheManager manager = CacheManager.newInstance(fis);
+ fis.close();
+ String[] cacheNames = manager.getCacheNames();
+
+ for (String name : cacheNames) {
+ System.out.println("[ehcache.xml]name:" + name);
+ }
+
+ manager.shutdown();
+ }
+
+ /**
+ * 使用默认配置(classpath下的ehcache.xml)添加缓存
+ */
+ @Test
+ public void addAndRemove01() {
+ CacheManager singletonManager = CacheManager.create();
+
+ // 添加缓存
+ singletonManager.addCache("testCache");
+
+ // 打印配置信息和状态
+ Cache test = singletonManager.getCache("testCache");
+ System.out.println("cache name:" + test.getCacheConfiguration().getName());
+ System.out.println("cache status:" + test.getStatus().toString());
+ System.out.println("maxElementsInMemory:" + test.getCacheConfiguration().getMaxElementsInMemory());
+ System.out.println("timeToIdleSeconds:" + test.getCacheConfiguration().getTimeToIdleSeconds());
+ System.out.println("timeToLiveSeconds:" + test.getCacheConfiguration().getTimeToLiveSeconds());
+
+ // 删除缓存
+ singletonManager.removeCache("testCache");
+ System.out.println("cache status:" + test.getStatus().toString());
+
+ singletonManager.shutdown();
+ }
+
+ /**
+ * 使用自定义配置添加缓存，注意缓存未添加进CacheManager之前并不可用
+ */
+ @Test
+ public void addAndRemove02() {
+ CacheManager singletonManager = CacheManager.create();
+
+ // 添加缓存
+ Cache memoryOnlyCache = new Cache("testCache2", 5000, false, false, 5, 2);
+ singletonManager.addCache(memoryOnlyCache);
+
+ // 打印配置信息和状态
+ Cache test = singletonManager.getCache("testCache2");
+ System.out.println("cache name:" + test.getCacheConfiguration().getName());
+ System.out.println("cache status:" + test.getStatus().toString());
+ System.out.println("maxElementsInMemory:" + test.getCacheConfiguration().getMaxElementsInMemory());
+ System.out.println("timeToIdleSeconds:" + test.getCacheConfiguration().getTimeToIdleSeconds());
+ System.out.println("timeToLiveSeconds:" + test.getCacheConfiguration().getTimeToLiveSeconds());
+
+ // 删除缓存
+ singletonManager.removeCache("testCache2");
+ System.out.println("cache status:" + test.getStatus().toString());
+
+ singletonManager.shutdown();
+ }
+
+ /**
+ * 使用特定的配置添加缓存
+ */
+ @Test
+ public void addAndRemove03() {
+ CacheManager manager = CacheManager.create();
+
+ // 添加缓存
+ Cache testCache = new Cache(new CacheConfiguration("testCache3", 5000)
+ .memoryStoreEvictionPolicy(MemoryStoreEvictionPolicy.LFU).eternal(false).timeToLiveSeconds(60)
+ .timeToIdleSeconds(30).diskExpiryThreadIntervalSeconds(0)
+ .persistence(new PersistenceConfiguration().strategy(PersistenceConfiguration.Strategy.LOCALTEMPSWAP)));
+ manager.addCache(testCache);
+
+ // 打印配置信息和状态
+ Cache test = manager.getCache("testCache3");
+ System.out.println("cache name:" + test.getCacheConfiguration().getName());
+ System.out.println("cache status:" + test.getStatus().toString());
+ System.out.println("maxElementsInMemory:" + test.getCacheConfiguration().getMaxElementsInMemory());
+ System.out.println("timeToIdleSeconds:" + test.getCacheConfiguration().getTimeToIdleSeconds());
+ System.out.println("timeToLiveSeconds:" + test.getCacheConfiguration().getTimeToLiveSeconds());
+
+ // 删除缓存
+ manager.removeCache("testCache3");
+ System.out.println("cache status:" + test.getStatus().toString());
+
+ manager.shutdown();
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/LRUCacheTest.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/LRUCacheTest.java
new file mode 100644
index 00000000..21bfbc81
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/LRUCacheTest.java
@@ -0,0 +1,25 @@
+package io.github.dunwu.javatech.cache;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+/**
+ * @author Zhang Peng
+ * @since 2020-01-18
+ */
+public class LRUCacheTest {
+
+ @Test
+ public void test() {
+ LRUCache cache = new LRUCache(2);
+ Assertions.assertNull(cache.get(2));
+ cache.put(2, "B");
+ Assertions.assertNull(cache.get(1));
+ cache.put(1, "A");
+ cache.put(3, "C");
+ Assertions.assertEquals("A", cache.get(1));
+ Assertions.assertEquals(null, cache.get(2));
+ Assertions.assertEquals("C", cache.get(3));
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCacheDemo.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCacheDemo.java
new file mode 100644
index 00000000..837744ab
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCacheDemo.java
@@ -0,0 +1,142 @@
+package io.github.dunwu.javatech.cache.spring;
+
+import io.github.dunwu.javatech.data.User;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.CacheManager;
+import org.springframework.stereotype.Component;
+
+/**
+ * Spring 缓存接口测试类
+ *
+ * @author Zhang Peng
+ * @since 2019-09-04
+ */
+@Component
+public class SpringCacheDemo {
+
+ @Autowired
+ private UserService userService;
+
+ @Autowired
+ private CacheManager cacheManager;
+
+ /**
+ * 测试当前真实工作的 CacheManager 是什么
+ */
+ public void getCacheManager() {
+ System.out.println("当前 CacheManager 类：" + cacheManager.getClass());
+ System.out.println(cacheManager.getCacheNames());
+ }
+
+ /**
+ * 测试@Cacheable
+ */
+ public void testFindUser() throws InterruptedException {
+ // 设置查询条件
+ User user1 = new User(1L, null);
+ User user2 = new User(2L, null);
+ User user3 = new User(3L, null);
+ User user4 = new User(3L, null);
+
+ System.out.println("第一次查询");
+ System.out.println(userService.findUser(user1));
+ System.out.println(userService.findUser(user2));
+ System.out.println(userService.findUser(user3));
+ System.out.println(userService.findUser(user4));
+
+ // 如果缓存有效，应该不会打印 查找数据库 id = %d 成功 这样的信息
+ System.out.println("\n第二次查询");
+ System.out.println(userService.findUser(user1));
+ System.out.println(userService.findUser(user2));
+ System.out.println(userService.findUser(user3));
+ System.out.println(userService.findUser(user4));
+
+ // 在classpath:ehcache/ehcache.xml中，设置了userCache的缓存时间为3000 ms, 这里设置等待
+ Thread.sleep(3000);
+
+ System.out.println("\n缓存过期，再次查询");
+ System.out.println(userService.findUser(user1));
+ System.out.println(userService.findUser(user2));
+ System.out.println(userService.findUser(user3));
+ }
+
+ /**
+ * 测试@Cacheable设置Spring SpEL条件限制
+ */
+ public void testFindUserInLimit() throws InterruptedException {
+ // 设置查询条件
+ User user1 = new User(1L, null);
+ User user2 = new User(2L, null);
+ User user3 = new User(3L, null);
+
+ System.out.println("第一次查询user info");
+ System.out.println(userService.findUserInLimit(user1));
+ System.out.println(userService.findUserInLimit(user2));
+ System.out.println(userService.findUserInLimit(user3));
+
+ System.out.println("\n第二次查询user info");
+ System.out.println(userService.findUserInLimit(user1));
+ System.out.println(userService.findUserInLimit(user2));
+ System.out.println(userService.findUserInLimit(user3)); // 超过限制条件，不会从缓存中读数据
+
+ // 在classpath:ehcache/ehcache.xml中，设置了userCache的缓存时间为3000 ms, 这里设置等待
+ Thread.sleep(3000);
+
+ System.out.println("\n缓存过期，再次查询");
+ System.out.println(userService.findUserInLimit(user1));
+ System.out.println(userService.findUserInLimit(user2));
+ System.out.println(userService.findUserInLimit(user3));
+ }
+
+ /**
+ * 测试@CachePut
+ */
+ public void testUpdateUser() {
+ // 设置查询条件
+ User user1 = new User(2L, null);
+ User user2 = new User(2L, null);
+
+ System.out.println(userService.findUser(user1));
+ System.out.println(userService.findUser(user2));
+ userService.updateUser(new User(2L, "尼古拉斯.赵四"));
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ System.out.println(userService.findUser(user1));
+ System.out.println(userService.findUser(user2));
+ }
+
+ /**
+ * 测试@CacheEvict删除指定缓存
+ */
+ public void testRemoveUser() {
+ // 设置查询条件
+ User user1 = new User(1L, null);
+
+ System.out.println("数据删除前：");
+ System.out.println(userService.findUser(user1));
+
+ userService.removeUser(user1);
+ System.out.println("数据删除后：");
+ System.out.println(userService.findUser(user1));
+ }
+
+ /**
+ * 测试@CacheEvict删除所有缓存
+ */
+ public void testClear() {
+ System.out.println("数据清空前：");
+ System.out.println(userService.findUser(new User(1L, null)));
+ System.out.println(userService.findUser(new User(2L, null)));
+ System.out.println(userService.findUser(new User(3L, null)));
+
+ userService.clear();
+ System.out.println("\n数据清空后：");
+ System.out.println(userService.findUser(new User(1L, null)));
+ System.out.println(userService.findUser(new User(2L, null)));
+ System.out.println(userService.findUser(new User(3L, null)));
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCaffeineCacheTest.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCaffeineCacheTest.java
new file mode 100644
index 00000000..ba1445ee
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringCaffeineCacheTest.java
@@ -0,0 +1,72 @@
+package io.github.dunwu.javatech.cache.spring;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * 使用 Caffeine 作为 Spring 缓存测试
+ *
+ * 配置内容见：spring/spring-caffeine.xml
+ *
+ * @author Zhang Peng
+ * @since 2019-09-04
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = { "classpath:spring/spring-caffeine.xml" })
+public class SpringCaffeineCacheTest {
+
+ @Autowired
+ private SpringCacheDemo springCacheDemo;
+
+ /**
+ * 测试当前真实工作的 CacheManager 是什么
+ */
+ @Test
+ public void getCacheManager() {
+ springCacheDemo.getCacheManager();
+ }
+
+ /**
+ * 测试@Cacheable
+ */
+ @Test
+ public void testFindUser() throws InterruptedException {
+ springCacheDemo.testFindUser();
+ }
+
+ /**
+ * 测试@Cacheable设置Spring SpEL条件限制
+ */
+ @Test
+ public void testFindUserInLimit() throws InterruptedException {
+ springCacheDemo.testFindUserInLimit();
+ }
+
+ /**
+ * 测试@CachePut
+ */
+ @Test
+ public void testUpdateUser() {
+ springCacheDemo.testUpdateUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除指定缓存
+ */
+ @Test
+ public void testRemoveUser() {
+ springCacheDemo.testRemoveUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除所有缓存
+ */
+ @Test
+ public void testClear() {
+ springCacheDemo.testClear();
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringConcurrentHashMapCacheTest.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringConcurrentHashMapCacheTest.java
new file mode 100644
index 00000000..d63d03d1
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringConcurrentHashMapCacheTest.java
@@ -0,0 +1,72 @@
+package io.github.dunwu.javatech.cache.spring;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * 使用 ConcurrentHashMap 作为 Spring 缓存测试
+ *
+ * 配置内容见：spring/spring-hashmap.xml
+ *
+ * @author Zhang Peng
+ * @since 2019-09-04
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = { "classpath:spring/spring-hashmap.xml" })
+public class SpringConcurrentHashMapCacheTest {
+
+ @Autowired
+ private SpringCacheDemo springCacheDemo;
+
+ /**
+ * 测试当前真实工作的 CacheManager 是什么
+ */
+ @Test
+ public void getCacheManager() {
+ springCacheDemo.getCacheManager();
+ }
+
+ /**
+ * 测试@Cacheable
+ */
+ @Test
+ public void testFindUser() throws InterruptedException {
+ springCacheDemo.testFindUser();
+ }
+
+ /**
+ * 测试@Cacheable设置Spring SpEL条件限制
+ */
+ @Test
+ public void testFindUserInLimit() throws InterruptedException {
+ springCacheDemo.testFindUserInLimit();
+ }
+
+ /**
+ * 测试@CachePut
+ */
+ @Test
+ public void testUpdateUser() {
+ springCacheDemo.testUpdateUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除指定缓存
+ */
+ @Test
+ public void testRemoveUser() {
+ springCacheDemo.testRemoveUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除所有缓存
+ */
+ @Test
+ public void testClear() {
+ springCacheDemo.testClear();
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringEhcacheCacheTest.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringEhcacheCacheTest.java
new file mode 100644
index 00000000..d39e9d86
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/SpringEhcacheCacheTest.java
@@ -0,0 +1,72 @@
+package io.github.dunwu.javatech.cache.spring;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * 使用 Ehcache 作为 Spring 缓存测试
+ *
+ * 配置内容见：spring/spring-ehcache.xml
+ *
+ * @author Zhang Peng
+ * @since 2019-09-04
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = { "classpath:spring/spring-ehcache.xml" })
+public class SpringEhcacheCacheTest {
+
+ @Autowired
+ private SpringCacheDemo springCacheDemo;
+
+ /**
+ * 测试当前真实工作的 CacheManager 是什么
+ */
+ @Test
+ public void getCacheManager() {
+ springCacheDemo.getCacheManager();
+ }
+
+ /**
+ * 测试@Cacheable
+ */
+ @Test
+ public void testFindUser() throws InterruptedException {
+ springCacheDemo.testFindUser();
+ }
+
+ /**
+ * 测试@Cacheable设置Spring SpEL条件限制
+ */
+ @Test
+ public void testFindUserInLimit() throws InterruptedException {
+ springCacheDemo.testFindUserInLimit();
+ }
+
+ /**
+ * 测试@CachePut
+ */
+ @Test
+ public void testUpdateUser() {
+ springCacheDemo.testUpdateUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除指定缓存
+ */
+ @Test
+ public void testRemoveUser() {
+ springCacheDemo.testRemoveUser();
+ }
+
+ /**
+ * 测试@CacheEvict删除所有缓存
+ */
+ @Test
+ public void testClear() {
+ springCacheDemo.testClear();
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/UserService.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/UserService.java
new file mode 100644
index 00000000..588b6d27
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/UserService.java
@@ -0,0 +1,87 @@
+package io.github.dunwu.javatech.cache.spring;
+
+import io.github.dunwu.javatech.data.User;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+@Service
+public class UserService {
+
+ private ConcurrentHashMap map;
+
+ public UserService() {
+ // 模拟应用启动时加载缓存
+ map = new ConcurrentHashMap<>();
+ User user1 = new User(1L, "张三");
+ User user2 = new User(2L, "赵四");
+ User user3 = new User(3L, "王五");
+ map.put(user1.getId(), user1);
+ map.put(user2.getId(), user2);
+ map.put(user3.getId(), user3);
+ }
+
+ @Cacheable(value = "users", key = "#user.id")
+ public User findUser(User user) {
+ return findUserInDb(user.getId());
+ }
+
+ /**
+ * 模拟数据库查询操作
+ */
+ private User findUserInDb(Long id) {
+ User user = map.get(id);
+ if (user != null) {
+ System.out.println("查找数据库 id = " + id + " 成功");
+ return user;
+ }
+ return null;
+ }
+
+ @Cacheable(value = "users", condition = "#user.getId() <= 2")
+ public User findUserInLimit(User user) {
+ return findUserInDb(user.getId());
+ }
+
+ @CachePut(value = "users", key = "#user.getId()")
+ public void updateUser(User user) {
+ updateUserInDb(user);
+ }
+
+ /**
+ * 模拟数据库更新操作
+ */
+ private void updateUserInDb(User user) {
+ User old = map.get(user.getId());
+ if (old != null) {
+ System.out.println("更新数据库" + old + " -> " + user);
+ old.setName(user.getName());
+ }
+ }
+
+ @CacheEvict(value = "users", key = "#user.getId()")
+ public void removeUser(User user) {
+ removeUserInDb(user.getId());
+ }
+
+ /**
+ * 模拟数据库删除操作
+ */
+ private void removeUserInDb(Long id) {
+ map.remove(id);
+ System.out.println("从数据库移除 id = " + id + " 的数据");
+ }
+
+ @CacheEvict(value = "users", allEntries = true)
+ public void clear() {
+ removeAllInDb();
+ }
+
+ private void removeAllInDb() {
+ map.clear();
+ }
+
+}
diff --git a/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/package-info.java b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/package-info.java
new file mode 100644
index 00000000..21c5686c
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/java/io/github/dunwu/javatech/cache/spring/package-info.java
@@ -0,0 +1,7 @@
+/**
+ * Spring 集成各类缓存库测试
+ *
+ * @author Zhang Peng
+ * @since 2020-07-10
+ */
+package io.github.dunwu.javatech.cache.spring;
diff --git a/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache.xml b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache.xml
new file mode 100644
index 00000000..9bf4c661
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache.xml
@@ -0,0 +1,42 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache1.xml b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache1.xml
new file mode 100644
index 00000000..690eebbd
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache1.xml
@@ -0,0 +1,26 @@
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache2.xml b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache2.xml
new file mode 100644
index 00000000..bb41206a
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/ehcache/ehcache2.xml
@@ -0,0 +1,26 @@
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/test/resources/spring/spring-caffeine.xml b/codes/javatech/javatech-cache/src/test/resources/spring/spring-caffeine.xml
new file mode 100644
index 00000000..1570bba2
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/spring/spring-caffeine.xml
@@ -0,0 +1,19 @@
+
+
+
+ 使用 Caffeine 作为 Spring 缓存
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/test/resources/spring/spring-ehcache.xml b/codes/javatech/javatech-cache/src/test/resources/spring/spring-ehcache.xml
new file mode 100644
index 00000000..81af38dd
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/spring/spring-ehcache.xml
@@ -0,0 +1,25 @@
+
+
+
+ 使用 EhCache 作为 Spring 缓存
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-cache/src/test/resources/spring/spring-hashmap.xml b/codes/javatech/javatech-cache/src/test/resources/spring/spring-hashmap.xml
new file mode 100644
index 00000000..1620e0fe
--- /dev/null
+++ b/codes/javatech/javatech-cache/src/test/resources/spring/spring-hashmap.xml
@@ -0,0 +1,26 @@
+
+
+
+ 使用 ConcurrentHashMap 作为 Spring 缓存
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/codes/javatech/javatech-lib/pom.xml b/codes/javatech/javatech-lib/pom.xml
new file mode 100644
index 00000000..7c6da10b
--- /dev/null
+++ b/codes/javatech/javatech-lib/pom.xml
@@ -0,0 +1,173 @@
+
+
+ 4.0.0
+
+
+ io.github.dunwu
+ dunwu-parent
+ 1.0.8
+
+
+ io.github.dunwu.javatech
+ javatech-lib
+ 1.0.0
+ JAVATECH-工具包示例
+
+
+ 5.2.2
+ 1.22
+
+
+
+
+ cn.hutool
+ hutool-all
+
+
+ org.projectlombok
+ lombok
+
+
+
+
+ com.alibaba
+ fastjson
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+
+
+ com.google.code.gson
+ gson
+
+
+
+
+ de.ruedigermoeller
+ fst
+ 2.56
+
+
+ com.esotericsoftware
+ kryo
+ 5.3.0
+
+
+
+
+ ch.qos.logback
+ logback-classic
+
+
+
+
+ org.reflections
+ reflections
+ 0.10.2
+
+
+
+
+ com.squareup.okhttp3
+ okhttp
+ 4.10.0
+
+
+
+
+ org.apache.poi
+ poi
+ ${poi.version}
+
+
+ org.apache.poi
+ poi-ooxml
+ ${poi.version}
+
+
+ org.apache.poi
+ poi-scratchpad
+ ${poi.version}
+
+
+
+
+ com.alibaba
+ easyexcel
+ 3.1.1
+
+
+
+
+ org.dom4j
+ dom4j
+ 2.1.3
+
+
+
+
+ com.github.javaparser
+ javaparser-symbol-solver-core
+ 3.24.2
+
+
+
+
+ com.github.promeg
+ tinypinyin
+ 2.0.3
+
+
+ com.github.promeg
+ tinypinyin-lexicons-java-cncity
+ 2.0.3
+
+
+
+
+ org.openjdk.jmh
+ jmh-core
+ ${jmh.version}
+
+
+ org.openjdk.jmh
+ jmh-generator-annprocess
+ ${jmh.version}
+
+
+
+
+
+
+ junit
+ junit
+ test
+
+
+
+ org.junit.jupiter
+ junit-jupiter
+ test
+
+
+ org.assertj
+ assertj-core
+ test
+
+
+ org.mockito
+ mockito-core
+ test
+
+
+ org.hamcrest
+ hamcrest
+ 2.2
+ test
+
+
+
+
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo01.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo01.java
new file mode 100644
index 00000000..9e4104fe
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo01.java
@@ -0,0 +1,28 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * 使用 @Builder 不当导致 json 反序列化失败
+ *
+ * @author Zhang Peng
+ * @date 2020/12/3
+ */
+@Data
+@Builder
+public class BuilderDemo01 {
+
+ private String name;
+
+ public static void main(String[] args) throws JsonProcessingException {
+ BuilderDemo01 demo01 = BuilderDemo01.builder().name("demo01").build();
+ ObjectMapper mapper = new ObjectMapper();
+ String json = mapper.writeValueAsString(demo01);
+ BuilderDemo01 expectDemo01 = mapper.readValue(json, BuilderDemo01.class);
+ System.out.println(expectDemo01.toString());
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo02.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo02.java
new file mode 100644
index 00000000..0820b063
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/BuilderDemo02.java
@@ -0,0 +1,33 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 修正 {@link BuilderDemo01} 使用不当的问题
+ *
+ * @author Zhang Peng
+ * @date 2020/12/3
+ * @see BuilderDemo01
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class BuilderDemo02 {
+
+ private String name;
+
+ public static void main(String[] args) throws JsonProcessingException {
+ BuilderDemo02 demo02 = BuilderDemo02.builder().name("demo01").build();
+ ObjectMapper mapper = new ObjectMapper();
+ String json = mapper.writeValueAsString(demo02);
+ BuilderDemo02 expectDemo02 = mapper.readValue(json, BuilderDemo02.class);
+ System.out.println(expectDemo02.toString());
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/DataDemo.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/DataDemo.java
new file mode 100644
index 00000000..a35811c0
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/DataDemo.java
@@ -0,0 +1,25 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.Data;
+import lombok.ToString;
+
+import java.util.List;
+
+/**
+ * @Data 示例
+ *
+ * @author Zhang Peng
+ * @see @Data
+ * @since 2019-11-22
+ */
+@Data(staticConstructor = "of")
+@ToString
+public class DataDemo {
+
+ private final Person founder;
+
+ protected List employees;
+
+ private String name;
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/EqualsAndHashCodeDemo.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/EqualsAndHashCodeDemo.java
new file mode 100644
index 00000000..c342ab4d
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/EqualsAndHashCodeDemo.java
@@ -0,0 +1,55 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NonNull;
+
+/**
+ * @EqualsAndHashCode 示例
+ *
+ * @author Zhang Peng
+ * @see @EqualsAndHashCode
+ * @since 2019-11-22
+ */
+@Data
+@EqualsAndHashCode(callSuper = true, exclude = { "address", "city", "state", "zip" })
+public class EqualsAndHashCodeDemo extends Person {
+
+ @NonNull
+ private String name;
+
+ @NonNull
+ private Gender gender;
+
+ private String ssn;
+
+ private String address;
+
+ private String city;
+
+ private String state;
+
+ private String zip;
+
+ public EqualsAndHashCodeDemo(@NonNull String name, @NonNull Gender gender) {
+ this.name = name;
+ this.gender = gender;
+ }
+
+ public EqualsAndHashCodeDemo(@NonNull String name, @NonNull Gender gender,
+ String ssn, String address, String city, String state, String zip) {
+ this.name = name;
+ this.gender = gender;
+ this.ssn = ssn;
+ this.address = address;
+ this.city = city;
+ this.state = state;
+ this.zip = zip;
+ }
+
+ public enum Gender {
+ Male,
+ Female
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/GetterAndSetterDemo.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/GetterAndSetterDemo.java
new file mode 100644
index 00000000..e4365b6e
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/GetterAndSetterDemo.java
@@ -0,0 +1,23 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @Getter 和 @Setter 示例
+ *
+ * @author Zhang Peng
+ * @see @Getter and @Setter
+ * @since 2019-11-22
+ */
+public class GetterAndSetterDemo {
+
+ @Getter
+ @Setter
+ private boolean employed = true;
+
+ @Setter(AccessLevel.PROTECTED)
+ private String name;
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/NonNullDemo.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/NonNullDemo.java
new file mode 100644
index 00000000..266e3ad8
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/NonNullDemo.java
@@ -0,0 +1,23 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.Getter;
+import lombok.NonNull;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @NonNull 示例
+ *
+ * @author Zhang Peng
+ * @see @NonNull
+ * @since 2019-11-22
+ */
+public class NonNullDemo {
+
+ @Getter
+ @Setter
+ @NonNull
+ private List members;
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/Person.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/Person.java
new file mode 100644
index 00000000..30f1519c
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/Person.java
@@ -0,0 +1,26 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+/**
+ * @Data 、@ToString、@EqualsAndHashCode 示例
+ *
+ * @author Zhang Peng
+ * @see @Data
+ * 、@ToString、@EqualsAndHashCode
+ * @since 2019-11-22
+ */
+@Data
+@ToString(exclude = "age")
+@EqualsAndHashCode(exclude = { "age", "sex" })
+public class Person {
+
+ protected String name;
+
+ protected Integer age;
+
+ protected String sex;
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/ToStringDemo.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/ToStringDemo.java
new file mode 100644
index 00000000..bd083e91
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/ToStringDemo.java
@@ -0,0 +1,24 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.ToString;
+
+/**
+ * @author Zhang Peng
+ * @since 2019-11-22
+ */
+@ToString(callSuper = true, exclude = "someExcludedField")
+public class ToStringDemo {
+
+ private boolean someBoolean = true;
+
+ private String someStringField;
+
+ private float someExcludedField;
+
+ public ToStringDemo(boolean someBoolean, String someStringField, float someExcludedField) {
+ this.someBoolean = someBoolean;
+ this.someStringField = someStringField;
+ this.someExcludedField = someExcludedField;
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/User.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/User.java
new file mode 100644
index 00000000..093b010a
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/User.java
@@ -0,0 +1,24 @@
+package io.github.dunwu.javatech.bean.lombok;
+
+import lombok.Data;
+import lombok.ToString;
+
+/**
+ * @Data 、@ToString、@EqualsAndHashCode 示例
+ *
+ * @author Zhang Peng
+ * @see @Data
+ * 、@ToString、@EqualsAndHashCode
+ * @since 2019-11-22
+ */
+@Data
+@ToString
+public class User {
+
+ private String name;
+
+ private Integer age;
+
+ private String sex;
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/package-info.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/package-info.java
new file mode 100644
index 00000000..c0f2a966
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/lombok/package-info.java
@@ -0,0 +1,8 @@
+/**
+ * 本 package 下所有代码均为 Lombok 示例
+ *
+ * @author Zhang Peng
+ * @see Reducing Boilerplate Code with Project Lombok
+ * @since 2019-11-22
+ */
+package io.github.dunwu.javatech.bean.lombok;
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Group.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Group.java
new file mode 100644
index 00000000..f07b3e08
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Group.java
@@ -0,0 +1,42 @@
+package io.github.dunwu.javatech.bean.sample;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class Group {
+
+ private Long id;
+
+ private String name;
+
+ private List users = new ArrayList<>();
+
+ public Long getId() {
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public List getUsers() {
+ return users;
+ }
+
+ public void setUsers(List users) {
+ this.users = users;
+ }
+
+ public void addUser(User user) {
+ this.users.add(user);
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Person.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Person.java
new file mode 100644
index 00000000..8d87dddd
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/Person.java
@@ -0,0 +1,42 @@
+package io.github.dunwu.javatech.bean.sample;
+
+import java.io.Serializable;
+
+public class Person implements Serializable {
+
+ private static final long serialVersionUID = -210388541252854256L;
+
+ private String name;
+
+ private int age;
+
+ public Person() {
+ }
+
+ public Person(String name, int age) {
+ this.name = name;
+ this.age = age;
+ }
+
+ @Override
+ public String toString() {
+ return "Person{" + "name='" + name + '\'' + ", age=" + age + '}';
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public int getAge() {
+ return age;
+ }
+
+ public void setAge(int age) {
+ this.age = age;
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean.java
new file mode 100644
index 00000000..b53be676
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean.java
@@ -0,0 +1,59 @@
+package io.github.dunwu.javatech.bean.sample;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定义一个满足大多数情况的 Bean 结构（含 JDK8 数据类型），使得各种 Json 库测试性能时能相对公平
+ *
+ * @author Zhang Peng
+ * @since 2019-11-22
+ */
+@Data
+@ToString
+@Accessors(chain = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class TestBean implements Serializable {
+
+ private static final long serialVersionUID = -6473181683996762084L;
+
+ private int i1;
+
+ private Integer i2;
+
+ private float f1;
+
+ private Double d1;
+
+ private Date date1;
+
+ private LocalDateTime date2;
+
+ private LocalDate date3;
+
+ private Color color;
+
+ private String[] strArray;
+
+ private List intList;
+
+ private Map map;
+
+ public static enum Color {
+ RED,
+ YELLOW,
+ BLUE
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean2.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean2.java
new file mode 100644
index 00000000..ac3a80e7
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/TestBean2.java
@@ -0,0 +1,50 @@
+package io.github.dunwu.javatech.bean.sample;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 定义一个满足大多数情况的 Bean 结构（不含 JDK8 数据类型），使得各种 Json 库测试性能时能相对公平
+ *
+ * @author Zhang Peng
+ * @since 2019-11-22
+ */
+@Data
+@ToString
+@Accessors(chain = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class TestBean2 {
+
+ private int i1;
+
+ private Integer i2;
+
+ private float f1;
+
+ private Double d1;
+
+ private Date date1;
+
+ private Color color;
+
+ private String[] strArray;
+
+ private List intList;
+
+ private Map map;
+
+ public static enum Color {
+ RED,
+ YELLOW,
+ BLUE
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/User.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/User.java
new file mode 100644
index 00000000..b2418eb9
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/bean/sample/User.java
@@ -0,0 +1,35 @@
+package io.github.dunwu.javatech.bean.sample;
+
+public class User {
+
+ private Long id;
+
+ private String name;
+
+ public User() {
+ }
+
+ public User(Long id, String name) {
+ this.id = id;
+ this.name = name;
+ }
+
+ public Long getId() {
+ return id;
+ }
+
+ public User setId(Long id) {
+ this.id = id;
+ return this;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public User setName(String name) {
+ this.name = name;
+ return this;
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JMHSample_34_SafeLooping.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JMHSample_34_SafeLooping.java
new file mode 100644
index 00000000..ce44dbb9
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JMHSample_34_SafeLooping.java
@@ -0,0 +1,159 @@
+package io.github.dunwu.javatech.jmh;
+
+import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.infra.Blackhole;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.RunnerException;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+import java.util.concurrent.TimeUnit;
+
+@State(Scope.Thread)
+@Warmup(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
+@Measurement(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
+@Fork(3)
+@BenchmarkMode(Mode.AverageTime)
+@OutputTimeUnit(TimeUnit.NANOSECONDS)
+public class JMHSample_34_SafeLooping {
+
+ /*
+ * JMHSample_11_Loops warns about the dangers of using loops in @Benchmark methods.
+ * Sometimes, however, one needs to traverse through several elements in a dataset.
+ * This is hard to do without loops, and therefore we need to devise a scheme for
+ * safe looping.
+ */
+
+ /*
+ * Suppose we want to measure how much it takes to execute work() with different
+ * arguments. This mimics a frequent use case when multiple instances with the same
+ * implementation, but different data, is measured.
+ */
+
+ static final int BASE = 42;
+
+ static int work(int x) {
+ return BASE + x;
+ }
+
+ /*
+ * Every benchmark requires control. We do a trivial control for our benchmarks
+ * by checking the benchmark costs are growing linearly with increased task size.
+ * If it doesn't, then something wrong is happening.
+ */
+
+ @Param({ "1", "10", "100", "1000" })
+ int size;
+
+ int[] xs;
+
+ @Setup
+ public void setup() {
+ xs = new int[size];
+ for (int c = 0; c < size; c++) {
+ xs[c] = c;
+ }
+ }
+
+ /*
+ * First, the obviously wrong way: "saving" the result into a local variable would not
+ * work. A sufficiently smart compiler will inline work(), and figure out only the last
+ * work() call needs to be evaluated. Indeed, if you run it with varying $size, the score
+ * will stay the same!
+ */
+
+ @Benchmark
+ public int measureWrong_1() {
+ int acc = 0;
+ for (int x : xs) {
+ acc = work(x);
+ }
+ return acc;
+ }
+
+ /*
+ * Second, another wrong way: "accumulating" the result into a local variable. While
+ * it would force the computation of each work() method, there are software pipelining
+ * effects in action, that can merge the operations between two otherwise distinct work()
+ * bodies. This will obliterate the benchmark setup.
+ *
+ * In this example, HotSpot does the unrolled loop, merges the $BASE operands into a single
+ * addition to $acc, and then does a bunch of very tight stores of $x-s. The final performance
+ * depends on how much of the loop unrolling happened *and* how much data is available to make
+ * the large strides.
+ */
+
+ @Benchmark
+ public int measureWrong_2() {
+ int acc = 0;
+ for (int x : xs) {
+ acc += work(x);
+ }
+ return acc;
+ }
+
+ /*
+ * Now, let's see how to measure these things properly. A very straight-forward way to
+ * break the merging is to sink each result to Blackhole. This will force runtime to compute
+ * every work() call in full. (We would normally like to care about several concurrent work()
+ * computations at once, but the memory effects from Blackhole.consume() prevent those optimization
+ * on most runtimes).
+ */
+
+ @Benchmark
+ public void measureRight_1(Blackhole bh) {
+ for (int x : xs) {
+ bh.consume(work(x));
+ }
+ }
+
+ /*
+ * DANGEROUS AREA, PLEASE READ THE DESCRIPTION BELOW.
+ *
+ * Sometimes, the cost of sinking the value into a Blackhole is dominating the nano-benchmark score.
+ * In these cases, one may try to do a make-shift "sinker" with non-inlineable method. This trick is
+ * *very* VM-specific, and can only be used if you are verifying the generated code (that's a good
+ * strategy when dealing with nano-benchmarks anyway).
+ *
+ * You SHOULD NOT use this trick in most cases. Apply only where needed.
+ */
+
+ @Benchmark
+ public void measureRight_2() {
+ for (int x : xs) {
+ sink(work(x));
+ }
+ }
+
+ @CompilerControl(CompilerControl.Mode.DONT_INLINE)
+ public static void sink(int v) {
+ // IT IS VERY IMPORTANT TO MATCH THE SIGNATURE TO AVOID AUTOBOXING.
+ // The method intentionally does nothing.
+ }
+
+
+ /*
+ * ============================== HOW TO RUN THIS TEST: ====================================
+ *
+ * You might notice measureWrong_1 does not depend on $size, measureWrong_2 has troubles with
+ * linearity, and otherwise much faster than both measureRight_*. You can also see measureRight_2
+ * is marginally faster than measureRight_1.
+ *
+ * You can run this test:
+ *
+ * a) Via the command line:
+ * $ mvn clean install
+ * $ java -jar target/benchmarks.jar JMHSample_34
+ *
+ * b) Via the Java API:
+ * (see the JMH homepage for possible caveats when running from IDE:
+ * http://openjdk.java.net/projects/code-tools/jmh/)
+ */
+
+ public static void main(String[] args) throws RunnerException {
+ Options opt = new OptionsBuilder().include(JMHSample_34_SafeLooping.class.getSimpleName()).forks(3).build();
+
+ new Runner(opt).run();
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JmhQuickStart.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JmhQuickStart.java
new file mode 100644
index 00000000..7b16bcc1
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/JmhQuickStart.java
@@ -0,0 +1,40 @@
+package io.github.dunwu.javatech.jmh;
+
+import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.RunnerException;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+import java.util.concurrent.TimeUnit;
+
+@BenchmarkMode(Mode.Throughput)
+@Warmup(iterations = 3)
+@Measurement(iterations = 10, time = 5, timeUnit = TimeUnit.SECONDS)
+@OutputTimeUnit(TimeUnit.MILLISECONDS)
+public class JmhQuickStart {
+
+ public static void main(String[] args) throws RunnerException {
+ Options opt = new OptionsBuilder().include(JmhQuickStart.class.getSimpleName()).forks(1).build();
+ new Runner(opt).run();
+ }
+
+ @Benchmark
+ public String testStringAdd() {
+ String a = "";
+ for (int i = 0; i < 10; i++) {
+ a += i;
+ }
+ return a;
+ }
+
+ @Benchmark
+ public String testStringBuilderAdd() {
+ StringBuilder sb = new StringBuilder();
+ for (int i = 0; i < 10; i++) {
+ sb.append(i);
+ }
+ return sb.toString();
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/StringBuilderBenchmark.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/StringBuilderBenchmark.java
new file mode 100644
index 00000000..00ee2ea4
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/jmh/StringBuilderBenchmark.java
@@ -0,0 +1,44 @@
+package io.github.dunwu.javatech.jmh;
+
+import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.RunnerException;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+import java.util.concurrent.TimeUnit;
+
+@BenchmarkMode(Mode.Throughput)
+@Warmup(iterations = 3)
+@Measurement(iterations = 10, time = 5, timeUnit = TimeUnit.SECONDS)
+@Threads(8)
+@Fork(2)
+@OutputTimeUnit(TimeUnit.MILLISECONDS)
+public class StringBuilderBenchmark {
+
+ public static void main(String[] args) throws RunnerException {
+ Options options = new OptionsBuilder().include(StringBuilderBenchmark.class.getSimpleName())
+ .output("d:/Benchmark.log")
+ .build();
+ new Runner(options).run();
+ }
+
+ @Benchmark
+ public void testStringAdd() {
+ String str = "";
+ for (int i = 0; i < 10; i++) {
+ str += i;
+ }
+ System.out.println(str);
+ }
+
+ @Benchmark
+ public void testStringBuilderAdd() {
+ StringBuilder sb = new StringBuilder();
+ for (int i = 0; i < 10; i++) {
+ sb.append(i);
+ }
+ System.out.println(sb.toString());
+ }
+
+}
diff --git a/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/poi/excel/ExcelUtil.java b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/poi/excel/ExcelUtil.java
new file mode 100644
index 00000000..e75cd267
--- /dev/null
+++ b/codes/javatech/javatech-lib/src/main/java/io/github/dunwu/javatech/poi/excel/ExcelUtil.java
@@ -0,0 +1,100 @@
+package io.github.dunwu.javatech.poi.excel;
+
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.context.AnalysisContext;
+import com.alibaba.excel.event.AnalysisEventListener;
+import com.alibaba.excel.event.SyncReadListener;
+import com.alibaba.excel.read.listener.ReadListener;
+import com.alibaba.fastjson.JSON;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * @author Zhang Peng
+ * @since 2020-07-01
+ */
+public class ExcelUtil {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(ExcelUtil.class);
+
+ public static List> readAsync(InputStream inputStream) {
+ List> list = new ArrayList<>();
+ EasyExcel.read(inputStream, new NoModelDataListener(list)).sheet().doRead();
+ return list;
+ }
+
+ /**
+ * 异步方式，根据 InputStream 读取 Excel 内容。
+ *
+ * 返回结果为指定的 Class 类型列表
+ *
+ * 需要指定读取结束后，负责处理数据的监听器
+ *
+ * 注意：Class 类型中不能使用枚举类型
+ */
+ public static void readAsync(InputStream inputStream, Class clazz, ReadListener listener) {
+ EasyExcel.read(inputStream, clazz, listener).sheet().doRead();
+ }
+
+ /**
+ * 同步方式，根据 InputStream 读取 Excel 内容。
+ *
+ * 返回结果为指定的 Class 类型列表
+ *
+ * 注意：Class 类型中不能使用枚举类型
+ */
+ public static List readSync(InputStream inputStream, Class clazz) {
+ SyncReadListener listener = new SyncReadListener();
+ EasyExcel.read(inputStream, clazz, listener).sheet().doRead();
+ List
+ 
