From 7f206d3969246336f4ffcc65765337f387ef749c Mon Sep 17 00:00:00 2001 From: Lu-aiLiang <13208981+Lu-aiLiang@user.noreply.gitee.com> Date: Sun, 29 Oct 2023 19:43:37 +0800 Subject: [PATCH] csh --- .gitignore | 29 ++ .idea/$PROJECT_FILE$ | 11 + .idea/.gitignore | 8 + .idea/compiler.xml | 13 + .idea/encodings.xml | 7 + .idea/jarRepositories.xml | 20 + .idea/misc.xml | 26 + .idea/qaplug_profiles.xml | 465 ++++++++++++++++++ .idea/vcs.xml | 6 + pom.xml | 57 +++ redisPool.iml | 8 + src/main/java/com/lhj/ai/IRedisPool.java | 23 + src/main/java/com/lhj/ai/PoolApplication.java | 17 + src/main/java/com/lhj/ai/myRedisPool.java | 81 +++ src/test/java/IRedisPoolTest.java | 58 +++ target/classes/classpath.index | Bin 0 -> 132 bytes target/classes/com/lhj/ai/IRedisPool.class | Bin 0 -> 288 bytes .../classes/com/lhj/ai/PoolApplication.class | Bin 0 -> 716 bytes target/classes/com/lhj/ai/myRedisPool.class | Bin 0 -> 2393 bytes target/test-classes/IRedisPoolTest$1.class | Bin 0 -> 1498 bytes target/test-classes/IRedisPoolTest.class | Bin 0 -> 1489 bytes target/test-classes/classpath.index | Bin 0 -> 98 bytes 22 files changed, 829 insertions(+) create mode 100644 .gitignore create mode 100644 .idea/$PROJECT_FILE$ create mode 100644 .idea/.gitignore create mode 100644 .idea/compiler.xml create mode 100644 .idea/encodings.xml create mode 100644 .idea/jarRepositories.xml create mode 100644 .idea/misc.xml create mode 100644 .idea/qaplug_profiles.xml create mode 100644 .idea/vcs.xml create mode 100644 pom.xml create mode 100644 redisPool.iml create mode 100644 src/main/java/com/lhj/ai/IRedisPool.java create mode 100644 src/main/java/com/lhj/ai/PoolApplication.java create mode 100644 src/main/java/com/lhj/ai/myRedisPool.java create mode 100644 src/test/java/IRedisPoolTest.java create mode 100644 target/classes/classpath.index create mode 100644 target/classes/com/lhj/ai/IRedisPool.class create mode 100644 target/classes/com/lhj/ai/PoolApplication.class create mode 100644 target/classes/com/lhj/ai/myRedisPool.class create mode 100644 target/test-classes/IRedisPoolTest$1.class create mode 100644 target/test-classes/IRedisPoolTest.class create mode 100644 target/test-classes/classpath.index diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..f68d109 --- /dev/null +++ b/.gitignore @@ -0,0 +1,29 @@ +### IntelliJ IDEA ### +out/ +!**/src/main/**/out/ +!**/src/test/**/out/ + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache +bin/ +!**/src/main/**/bin/ +!**/src/test/**/bin/ + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/.idea/$PROJECT_FILE$ b/.idea/$PROJECT_FILE$ new file mode 100644 index 0000000..58b7e3e --- /dev/null +++ b/.idea/$PROJECT_FILE$ @@ -0,0 +1,11 @@ + + + + + + + \ No newline at end of file diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..35410ca --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# 默认忽略的文件 +/shelf/ +/workspace.xml +# 基于编辑器的 HTTP 客户端请求 +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/compiler.xml b/.idea/compiler.xml new file mode 100644 index 0000000..ecf5e69 --- /dev/null +++ b/.idea/compiler.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..aa00ffa --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml new file mode 100644 index 0000000..5a2f139 --- /dev/null +++ b/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..5825257 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,26 @@ + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/qaplug_profiles.xml b/.idea/qaplug_profiles.xml new file mode 100644 index 0000000..3dfd21f --- /dev/null +++ b/.idea/qaplug_profiles.xml @@ -0,0 +1,465 @@ + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..e02136a --- /dev/null +++ b/pom.xml @@ -0,0 +1,57 @@ + + + 4.0.0 + + groupId + redisPool + 1.0-SNAPSHOT + + + 8 + 8 + UTF-8 + + + + + + org.springframework.boot + spring-boot-starter + 2.4.3 + + + + org.springframework.boot + spring-boot-starter-test + 2.4.3 + + + + redis.clients + jedis + 3.7.1 + + + + org.springframework.boot + spring-boot-starter-web + 2.4.3 + + + + org.springframework.boot + spring-boot-starter-tomcat + 2.4.3 + + + junit + junit + 4.13.2 + test + + + + + diff --git a/redisPool.iml b/redisPool.iml new file mode 100644 index 0000000..a80f8af --- /dev/null +++ b/redisPool.iml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/src/main/java/com/lhj/ai/IRedisPool.java b/src/main/java/com/lhj/ai/IRedisPool.java new file mode 100644 index 0000000..9cf1e6f --- /dev/null +++ b/src/main/java/com/lhj/ai/IRedisPool.java @@ -0,0 +1,23 @@ +package com.lhj.ai; + +import redis.clients.jedis.Jedis; + +/** + * @version: java version 1.8 + * @Author: Mr Orange + * @description: + * @date: 2023-10-29 14:35 + */ +public interface IRedisPool { + public void init(int maxTotal,long maxWaitMillis); + /** + * 获取 连接 + * */ + public Jedis getResource()throws Exception; + /** + * 取得连接 + * */ + public void release(Jedis jedis); + + +} diff --git a/src/main/java/com/lhj/ai/PoolApplication.java b/src/main/java/com/lhj/ai/PoolApplication.java new file mode 100644 index 0000000..660b49b --- /dev/null +++ b/src/main/java/com/lhj/ai/PoolApplication.java @@ -0,0 +1,17 @@ +package com.lhj.ai; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @version: java version 1.8 + * @Author: Mr Orange + * @description: + * @date: 2023-10-29 19:35 + */ +@SpringBootApplication +public class PoolApplication { + public static void main(String[] args) { + SpringApplication.run(PoolApplication.class); + } +} diff --git a/src/main/java/com/lhj/ai/myRedisPool.java b/src/main/java/com/lhj/ai/myRedisPool.java new file mode 100644 index 0000000..5cc8309 --- /dev/null +++ b/src/main/java/com/lhj/ai/myRedisPool.java @@ -0,0 +1,81 @@ +package com.lhj.ai; + +import redis.clients.jedis.Jedis; + +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicInteger; + +/** + * @version: java version 1.8 + * @Author: Mr Orange + * @description: + * @date: 2023-10-29 16:20 + */ +public class myRedisPool implements IRedisPool{ + private int maxTotal; + private long maxWautMillis; + //定义一个空闲的连接集合; + private LinkedBlockingQueue idleObjects = null; + private LinkedBlockingQueue activObjects = null; + + private AtomicInteger count = new AtomicInteger(); + @Override + public void init(int maxTotal, long maxWaitMillis) { + this.maxTotal = maxTotal; + this.maxWautMillis = maxWaitMillis; + idleObjects = new LinkedBlockingQueue(maxTotal); + activObjects = new LinkedBlockingQueue(maxTotal); + } + + @Override + public Jedis getResource() throws Exception { + //伪代码 理思路 + //第一步,记录开始时间戳,用于判断超时时间. + //第二步, + long startTime = System.currentTimeMillis(); + Jedis redis = null; + while (true){ + redis = idleObjects.poll(); + if (redis != null){ + activObjects.offer(redis); + return redis; + } + if (count.get() < maxTotal){ + if (count.incrementAndGet() <= maxTotal){ + new Jedis("192.168.31.128",6379); + System.out.println("redis 创建了一个连接"); + activObjects.offer(redis); + return redis; + }else { + count.decrementAndGet(); + } + } + //4.如果连接池慢了,等待其他线程释放连接到空闲连接集合中,如果说是一定时间之内,可以的等到一个空闲的连接,将连接放入到活动连接集合中,返回该连接 + try { + idleObjects.poll(maxWautMillis - (System.currentTimeMillis() - startTime), TimeUnit.MILLISECONDS); + if (redis !=null){ + activObjects.offer(redis); + return redis; + } + }catch (Exception e){ + e.printStackTrace(); + } + //5.如果等待时间超过了我们最长等待时间,抛出等待超时异常. + if (maxWautMillis < (System.currentTimeMillis() - startTime)){ + throw new Exception("time,超过最长等待连接时间"); + }else { + continue; + } + + } + + } + + @Override + public void release(Jedis jedis) { + if (activObjects.remove(jedis)){ + idleObjects.offer(jedis); + } + } +} diff --git a/src/test/java/IRedisPoolTest.java b/src/test/java/IRedisPoolTest.java new file mode 100644 index 0000000..d35f856 --- /dev/null +++ b/src/test/java/IRedisPoolTest.java @@ -0,0 +1,58 @@ +import com.lhj.ai.IRedisPool; +import org.junit.jupiter.api.Test; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.boot.test.context.SpringBootTest; +import redis.clients.jedis.Jedis; + +import java.util.concurrent.CountDownLatch; + +/** + * @version: java version 1.8 + * @Author: Mr Orange + * @description: + * @date: 2023-10-29 15:05 + */ +@SpringBootTest +public class IRedisPoolTest { + @Qualifier("myRedisPool") + @Autowired + private IRedisPool pool; + + private final static int THRAD_NUM = 50; + + private CountDownLatch cd1 = new CountDownLatch(THRAD_NUM); + + + @Test + public void test() throws Exception { + pool.init(20, 2000); + for (int i = 0; i < THRAD_NUM; i++) { + + new Thread(new Runnable() { + @Override + public void run() { + try { + cd1.await(); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + Jedis jedis = null; + try { + jedis = pool.getResource(); + jedis.incr("pooltest.incr"); + + } catch (Exception e) { + throw new RuntimeException(e); + } finally { + pool.release(jedis); + } + + } + }).start(); + cd1.countDown(); + + } + Thread.sleep(2000); + } +} diff --git a/target/classes/classpath.index b/target/classes/classpath.index new file mode 100644 index 0000000000000000000000000000000000000000..4058d7b019f9605818dff7f26813c98cad31bb32 GIT binary patch literal 132 zcmb1OU}RumUV4u3>?G3!a)Ejq73!XWE(naB7u++fkeOASg@z%Ho83!Z%dH}~{qy_v4Pb_m!h^zqkhsECgjTj(O?QOeo~sSVa4Ibmp0eq>ipKN z>N+Q+i;LyY%7r2-3<;`a&nAjgVOCSAOf6)w1@c*z4E#oUNSxc&Gl(X%h$y`4ng-geDR|u!XkpO4vlOBTN^mbn>^<2Krb2 Caz`rw literal 0 HcmV?d00001 diff --git a/target/classes/com/lhj/ai/PoolApplication.class b/target/classes/com/lhj/ai/PoolApplication.class new file mode 100644 index 0000000000000000000000000000000000000000..095bfee2d26673905b6fc567f4426b76789932a0 GIT binary patch literal 716 zcmZ`%O-~y!5PeQU7B&IWK=}rVTi{S%dZ|(&(MUb5O4XqBz{$IqjniE_@_O6;El#Z} zwLgF#g*sl4x|i&*9z*-B(#oANGzTXW zhStbjONRAGY5AedV`(o%oDtHGOd_(0u*&Zr!IqnzAj=UqHUVRsB z1Ppu6H^|U?+Esx4E)H<`A9WGWWa1c3pRMPif|@&BiY;k!@t`)iQ6`FFxL{T%3p=F- zo&4_j=&@0Mdo>G!Jw3!R8uUE;*8sf=1QeHP$0;+)OQ%1;ZYz3)V!HxY5z@N*Z~z@z y0V`O=8X^AYHQs=c242Lm-*Tu=HQoMmTh4x!A-VUPj|u z)lrj@NYd6+^Q7t+V!tR1xMu`A>ynzCiJND}&)PXhqm71W%Tq#T7N}EGh|W~4vG}30nm*|owk0Uex~k(28X4*YJ>DeL zKNYP!<*M35pE~IU!?I$HNC+>1GBDZEO4I%MS0SykHI+g0wZu$Y>Mw zqF^gp6+Dm43RF!rES^))j7<`vMXweqKw%;s<4;L;z zxH|Lbi-q5Q`1t-^ZUyLrEBQxPZV4BN`yp%zwZ%)1+&{5VXc5-VGTp>dm9j{q36a8O zH&W-au1=b&7W-P%)#JB-jl$O;Fln27EUHV zsWdFj(KBrE9xHuB$ZMD1O1TbSl1|SUBSQ3?oX$2RUH zZ0C=zfIdZCai=*}KMOh5G>Z}vf9o%(;MU)oN5xR< zk6ecGsN^Jni(Q4?8nL^E=6RG4N2;pU{XU1t&`qq3ROeB{vz2#ihbZ##E1|88x_%SS z1keXA>KpGuX;afs6g{sL0wF9GH)L_4VizFbt_UuGQcO{SLH!uQ8yXA=lceH5^0PDU&ggf4 zlzLu@v~{5~eeb?=@4NThCGY!>&tCyt#!3geF|MNr6FQ18bxdMP!$l33bhP2J03av zJH@yyVb$lFQ$Ym%ow2s;^us9BVLX#9OyjP67i~ zs07pTTWqUW_nv{?Qx|3Auu7JK8R6|GJcU5wI&1ITU)L4WC z-|>RT^|#70t^}JJ?irZFpn)UE80b^dJQg(EH}C+10>g)=Byg&3uu}D7cSj!NrTi@# zC}By%LjxAdOktOOi`lmc*LOmaH?WLH1|H)HIoEw1IAO<|Gs#X7svADq*p^Pr4%H#@ z@M|6J|8F&$f~{4;V6S$gyEz!AN0DW1ZO4%jCvcK8cdX;U{cFlT9 zY6AbM5a`^J@rsO+2@)8}fPjD&N>ADmr*b%Vh}--+ z&hV+|0UHd_+pA`hFG!02J{%=_jM6O63egM2cMydSNWDpHj&p6J4R9JKxE`-r;UrG+ zMEk@WKU550u;xo-(1J8|&kAoLKBDD4(y!5FeL>sv;sA zD}I8J!fOnbmHn8qUv5&3e|wX7*U^Pm^kW<|l+^x!F=w!t>@8#pzIR<*N62!NQkGRX z&nzy`I!~m)J0@=O-JHP~E1*1>c#4ZjrUgdnMhAv4%)Dk3>2#9)v;FM*ahsJrOYJ#E t8ANMY!$`+Z#z<+%YTSi}(UOJ>J*-HMHYvs}a8L7X9wQ4?Kfx%;?-$(KVe)%4ImhUF%r-PH4Ws0C>TSQ#B5xm1xOW7Rx{gy-V8HaGrfZE z{tMrH@l~rds8sm_eDW9gLo7=@J=u^#v5KwQ+kJcPIrpA>d*;`_e*Oi(b*xlS#+)

vsA^ijfmnF0KHzxCr5-u3XFhXo(~SoGoJeP?dFxDVX!j)x_Ipb^J9tw$=$ zbS6;hBuOMN+6hE+Krw913QRWJ>T@N#)&%k2WVy0P z!y?zL3ZJZ~P7mbY+YfaoZ-$4v0%LhU+Fh0*+ue?_I+dzpWRJ;LVW_igVrFJWV7~V6 zR8yzaS=cB1IoGV?nmU2&|K{nhCEYaC_l;}C&~dd_U84nVo;=nhvC{Rz4Z-StE7$VD z-{pBOFu)Lo16;&dfLC!z;L0iHCNOZk28XSCSPpOx_c@T9BU16UT;EBxYVqheU}Dxm zK6K_mfCerFc<9VWXdZ)qyw%nr2RZbD@o0RUa;@Pm%}Xb?jgQ^c5-8Ui4_(;Me;dxz z(b}^K=GF4GiQWBLaPehc?UeXR`25nkvq zyv+Rt?hEt^uFKq)c*a)KzDDm(?gN9<2PjS-qO@6^J3!wLD14XWF4OwN0#!ziGA9ra zO9aMog{!~>*@`*aSFFgzE>3?BQ5_zJ_Y*256c;a6=f1}HA^gol^lvg(aDcNo#8*C>hczGnRXm!XvZ+XdPm4ViEF6w+a~GXz&sZC{c`n;FlUudCv&~b z-mB~lKC7VcC#vEP7WpP!C%$&nrYWjAgK50gYlh_Nq?KJ+-*QvP>u?=)`dzMP+RJ#` gX(#v{Ts;9SP64J!nWvaJs%Mt|Apbro`?>P>58k&$1^@s6 literal 0 HcmV?d00001 diff --git a/target/test-classes/classpath.index b/target/test-classes/classpath.index new file mode 100644 index 0000000000000000000000000000000000000000..52d717c0c6ffad4a3bc5e6fbfc398591e02c19b5 GIT binary patch literal 98 icmb1OU}QiAa{E_3@Vo8Et%NE}G|%J@Oli0zhy?&p*9Eu$ literal 0 HcmV?d00001