怎么用Java實現(xiàn)redis連接池

這篇文章主要介紹“怎么用Java實現(xiàn)redis連接池”，在日常操作中，相信很多人在怎么用Java實現(xiàn)redis連接池問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”怎么用Java實現(xiàn)redis連接池”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

1.Redis 客戶端

1.1.Redis Desktop Manager

使用稱手的工具，做起事來 事半功倍 ，用 redis-cli 自然不錯。我推薦一款我經(jīng)常用的 Redis 可視化工具，Redis Desktop Manager 。

2.Redis 連接池

2.2.0.連接池

池技術(shù)被廣泛使用在系統(tǒng)開發(fā)中，像 JDBC 連接池、線程池等。連連接池是創(chuàng)建和管理一個連接的緩沖池的技術(shù)，這些連接準備好被任何需要它們的線程使用。

在處理一個任務(wù)時，我們大多情況要在數(shù)毫秒級別就完成，如果重復創(chuàng)建、關(guān)閉資源，會占用較長時間和大量系統(tǒng)資源。

• 使用連接池優(yōu)勢

1. 減少連接創(chuàng)建時間

連接在系統(tǒng)初始化時就創(chuàng)建完成，需要時直接從池中取用，減少了時間開銷。

1. 簡化的編程模式

當使用連接池時，每一個單獨的線程能夠像創(chuàng)建了一個自己的 JDBC 連接一樣操作。

1. 受控的資源使用

連接池能夠控制一個模塊的資源占用率，不會讓一個模塊資源占用過高，導致整個系統(tǒng)崩潰。

2.1.Redis 連接池

2.1.1.前言引入

在以前沒有開源連接池時，很多人自寫連接池工具，簡單來說就是創(chuàng)建一個集合，存放一批連接，動態(tài)維護著。保證每個連接都是有效的。

2.1.2.Redis 連接池

本教程涉及到的一些代碼都是 Java 語言編寫。

maven 依賴，引入 pom.xml 文件

• pom.xml

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.3.0</version>
</dependency>

• RedisUtil.java

public final class RedisUtil {
    //IP 地址
    private static String ADDR = "127.0.0.1";
    //端口號
    private static int PORT = 6379;
    //redis 服務(wù)端密碼
    private static String PWD = "123456";
    //可用連接實例最大數(shù)目，默認為 8，若賦值 -1，表示不被限制
    private static Integer MAX_TOTAL = 1024;
    //控制一個連接池最多有多少個狀態(tài)為空閑的 jedis 實例，默認值為 8
    private static Integer MAX_IDLE = 200;
    //等待可用連接最大的等待時間，單位 ms，默認值 -1，表示永不超時，若等待超時拋出 JedisConnectionException
    private static Integer MAX_WAIT_MILLIS = 10000;
    //超時
    private static Integer TIMEOUT = 10000;
    //在用一個 jedis 實例時，是否提前進行 validate 操作，若結(jié)果為 true 則 jedis 實例可用
    private static Boolean TEST_ON_BORROW = true;
    //jedis 連接池
    private static JedisPool jedisPool = null;
    /**
     * 初始化 jedis 連接池的靜態(tài)塊,RedisPool 第一次類加載時執(zhí)行，以后便不再執(zhí)行
     */
    static {
        try {
            JedisPoolConfig conf = new JedisPoolConfig();
            /*
             * 高版本 jedis jar 中 JedisPoolConfig 沒有 setMaxActive 和 setMaxWait 屬性，因為官方在高版本               * 中啟用了此方法，用以下兩個屬性替換
             * maxActive ==> maxTotal
             * maxWait ==> maxWaitMillis
             */
            //設(shè)置連接實例最大數(shù)目
            conf.setMaxTotal(MAX_TOTAL);
            //設(shè)置最多多少空閑的 jedis 實例
            conf.setMaxIdle(MAX_IDLE);
            //設(shè)置等待可用連接的最大時間
            conf.setMaxWaitMillis(MAX_WAIT_MILLIS);
            //設(shè)置是否提前進行測試借用
            conf.setTestOnBorrow(TEST_ON_BORROW);
            //新建 jedis 連接池
            jedisPool = new JedisPool(conf, ADDR, PORT, TIMEOUT, PWD);
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
    /*
     * 獲取 jedis 實例來操作數(shù)據(jù)，每次使用完要將連接返回給連接池 jedis.close()
     * @return
     */
    public synchronized static Jedis getRedis() {
        try {
            if(jedisPool != null) {
                //獲取 jedis 實例
                Jedis jedis = jedisPool.getResource();
                return jedis;
            }
            else{
                System.out.println("沒有找到 Jedis 連接池！");
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
    /*
     * 用來回收 Jedis 對象資源，用戶需要用到此方法釋放資源，否則一直占用資源，在新版本中，`returnResource(jedis) 將被廢棄不推薦使用，`直接調(diào)用 `jedis.close();` 歸還連接到連接池。
     * @param Jedis jedis
     */
    public synchronized static void returnJedis(Jedis jedis) {
        try {
            if(jedis != null) {
                //回收 jedis 對象資源
                jedisPool.returnResource(jedis);
                System.out.println("Jedis 被成功回收！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

到此，關(guān)于“怎么用Java實現(xiàn)redis連接池”的學習就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關(guān)知識，請繼續(xù)關(guān)注億速云網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>