redis 连接池

Author: clxmm

jedis/pom.xml

@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>redis</artifactId>
+        <groupId>org.clxmm</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>jedis</artifactId>
+
+
+
+    <dependencies>
+
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>3.2.0</version>
+            <type>jar</type>
+            <scope>compile</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>

jedis/src/main/java/org/clxmm/jedis/CallWithJedis.java

@@ -0,0 +1,14 @@
+package org.clxmm.jedis;
+
+import redis.clients.jedis.Jedis;
+
+/**
+ * @author clx
+ * @date 2020-06-13 20:09
+ */
+public interface CallWithJedis {
+
+    void call(Jedis jedis);
+
+
+}

jedis/src/main/java/org/clxmm/jedis/JedisPoolTest.java

@@ -0,0 +1,64 @@
+package org.clxmm.jedis;
+
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+
+/**
+ * @author clx
+ * @date 2020-06-13 15:40
+ */
+public class JedisPoolTest {
+
+
+/*    public static void main(String[] args) {
+
+        //1. 构造一个 Jedis 连接池
+        JedisPool pool = new JedisPool("127.0.0.1", 6379);
+        //2. 从连接池中获取一个 Jedis 连接
+        Jedis jedis = pool.getResource();
+        jedis.auth("123456");
+
+        try {
+            //3 .jedis 操作
+            String ping = jedis.ping();
+            System.out.println(ping);
+
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (jedis != null) {
+                //4. 归还连接
+                jedis.close();
+            }
+        }
+
+    }*/
+
+
+    public static void main(String[] args) {
+        Redis redis = new Redis();
+        redis.execute(jedis -> {
+            jedis.auth("123456");
+            String ping = jedis.ping();
+            System.out.println(ping);
+        });
+
+    }
+
+    public static void main1(String[] args) {
+
+        //1. 构造一个 Jedis 连接池
+        JedisPool pool = new JedisPool("127.0.0.1", 6379);
+        //2. 从连接池中获取一个 Jedis 连接
+
+        try (Jedis jedis = pool.getResource()) {
+            jedis.auth("123456");
+            String ping = jedis.ping();
+            System.out.println(ping);
+        }
+
+    }
+
+
+}

jedis/src/main/java/org/clxmm/jedis/MyJedis.java

@@ -0,0 +1,24 @@
+package org.clxmm.jedis;
+
+import redis.clients.jedis.Jedis;
+
+/**
+ * @author clx
+ * @date 2020-06-13 15:34
+ */
+public class MyJedis {
+
+
+    public static void main(String[] args) {
+
+        // 构造一个jedis 对象，默认端口不用配置
+        Jedis jedis = new Jedis("127.0.0.1", 6379);
+        //2. 密码验证
+        jedis.auth("123456");
+        String ping = jedis.ping();
+        //4.返回 pong 表示连接成功
+        System.out.println(ping);
+    }
+
+
+}

jedis/src/main/java/org/clxmm/jedis/Redis.java

@@ -0,0 +1,35 @@
+package org.clxmm.jedis;
+
+import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+
+/**
+ * @author clx
+ * @date 2020-06-13 20:10
+ */
+public class Redis {
+    private JedisPool pool;
+
+    public Redis() {
+        GenericObjectPoolConfig config = new GenericObjectPoolConfig();
+        //连接池最大空闲数
+        config.setMaxIdle(300);
+        //最大连接数·
+        config.setMaxTotal(1_000);
+        //最大等待时间 -1 表示没有限制
+        config.setMaxWaitMillis(30_000);
+        //空闲时间检查有效性
+        config.setTestOnBorrow(true);
+
+        pool = new JedisPool(config, "127.0.0.1", 6379, 30_000, "123456");
+    }
+
+    public void execute(CallWithJedis withJedis) {
+        try (Jedis jedis = pool.getResource()) {
+            withJedis.call(jedis);
+        }
+    }
+
+
+}

pom.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.clxmm</groupId>
+    <artifactId>redis</artifactId>
+    <packaging>pom</packaging>
+    <version>1.0-SNAPSHOT</version>
+    <modules>
+        <module>jedis</module>
+    </modules>
+
+
+</project>