jedis 連接池的使用

簡單的使用連接池

// redis連接池的配置首先要創(chuàng)建一個連接池配置對象
        JedisPoolConfig config = new JedisPoolConfig();

        // 創(chuàng)建Jedis連接池對象
        JedisPool jedisPool = new JedisPool(config, "localhost", 6379);

        // 獲取連接
        Jedis jedis = jedisPool.getResource();

        // 使用
        jedis.set("demo", "demo111");

        // 關(guān)閉,歸還連接到連接池
        jedis.close();

模板方法的使用方式

如果在每個需要使用jedis的地方都需要獲取jedisPool宠互,然后獲取連接常侦,操作完成之后,還需要將連接使用歹啼,大量的重復的工作,如何避免大量的重復代碼呢?

@FunctionalInterface
public interface JedisCallback<T> {
    public T invoke(Jedis jedis);
}

public class JedisOperation {

    private JedisPool jedisPool;

    public void init() {
        // 比較特殊的是,redis連接池的配置首先要創(chuàng)建一個連接池配置對象
        JedisPoolConfig config = new JedisPoolConfig();
        // 當然這里還有設置屬性的代碼
        // 創(chuàng)建Jedis連接池對象
        jedisPool = new JedisPool(config, "localhost", 6379);
    }

    public <T> T execute(JedisCallback<T> callback) {
        Jedis jedis = jedisPool.getResource();
        try {
            return callback.invoke(jedis);
        }
        catch (Exception ex) {
            throw new RuntimeException("");
        }
        finally {
            jedis.close();
        }
    }
}

在需要使用jedis的地方使用以下方式螟加。

JedisOperation jedisOperation = new JedisOperation();
jedisOperation.init();
String demo = jedisOperation.execute(jedis -> jedis.get("demo"));

System.out.printf(demo);

JedisOperation 可以與spring整合,通過注入的方式使用熊泵。

動態(tài)代理的使用方式

雖然使用以上方式可以復用一些代碼,但是還是需要在 jedisOperation.execute 等一大串代碼甸昏,有沒有更簡單的方式呢顽分?
可以通過動態(tài)代理的方式代理Jedis對象,在Jedis相關(guān)的操作前后獲取鏈接和釋放鏈接施蜜。
Jdk動態(tài)代理要通過接口的方式實現(xiàn)卒蘸,需要找到Jedis的接口,通過代理該接口翻默,達到操作Jedis的功能缸沃。Jedis實現(xiàn)的接口多,為了實現(xiàn)這么多接口的功能修械,可以定義一個接口趾牧,繼承Jedis的接口,在通過代理改接口肯污,達到調(diào)用Jedis的功能翘单。

public interface IJedis extends JedisCommands, MultiKeyCommands {

}

public class JedisProxy<T> implements InvocationHandler {


    private JedisPool jedisPool;

    public void init() {
        // 比較特殊的是吨枉,redis連接池的配置首先要創(chuàng)建一個連接池配置對象
        JedisPoolConfig config = new JedisPoolConfig();
        // 當然這里還有設置屬性的代碼
        // 創(chuàng)建Jedis連接池對象
        jedisPool = new JedisPool(config, "localhost", 6379);
    }

    private Class<T> jedisInterface;

    public Class<T> getJedisInterface() {
        return jedisInterface;
    }

    public JedisProxy(Class<T> jedisInterface) {
        this.jedisInterface = jedisInterface;
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        Jedis jedis = jedisPool.getResource();

        try {
            return method.invoke(jedis, args);
        }

        catch (InvocationTargetException e) {
            throw new RuntimeException("出現(xiàn)異常");
        }
        catch (Exception e) {
            throw new RuntimeException("出現(xiàn)異常");
        }
        finally {
            jedis.close();
        }
    }
}
public class JedisProxyFactory<T> {

    private IJedis iJedis;


    public T newInstance(JedisProxy<T> jedisProxy) {
        return (T) Proxy.newProxyInstance(jedisProxy.getJedisInterface().getClassLoader(), new Class[] {jedisProxy.getJedisInterface()}, jedisProxy);
    }
}

在要使用的地方直接調(diào)用IJedis接口就好了,IJedis繼承了Jedis的實現(xiàn)接口哄芜∶餐ぃ可像使用Jedis方式一樣使用IJedis。

JedisProxy<IJedis> jedisProxy = new JedisProxy<>(IJedis.class);
jedisProxy.init();

JedisProxyFactory jedisProxyFactory = new JedisProxyFactory();
IJedis jedis = (IJedis) jedisProxyFactory.newInstance(jedisProxy);
String demo = jedis.get("demo");

System.out.println(demo);

IJedis 可與spring整合认臊,通過注入的方式使用

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末圃庭,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子失晴,更是在濱河造成了極大的恐慌剧腻,老刑警劉巖,帶你破解...
    沈念sama閱讀 216,692評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件师坎,死亡現(xiàn)場離奇詭異恕酸,居然都是意外死亡,警方通過查閱死者的電腦和手機胯陋,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,482評論 3 392
  • 文/潘曉璐 我一進店門蕊温,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人遏乔,你說我怎么就攤上這事义矛。” “怎么了盟萨?”我有些...
    開封第一講書人閱讀 162,995評論 0 353
  • 文/不壞的土叔 我叫張陵凉翻,是天一觀的道長。 經(jīng)常有香客問我捻激,道長制轰,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,223評論 1 292
  • 正文 為了忘掉前任胞谭,我火速辦了婚禮垃杖,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘丈屹。我一直安慰自己调俘,他們只是感情好,可當我...
    茶點故事閱讀 67,245評論 6 388
  • 文/花漫 我一把揭開白布旺垒。 她就那樣靜靜地躺著彩库,像睡著了一般。 火紅的嫁衣襯著肌膚如雪先蒋。 梳的紋絲不亂的頭發(fā)上骇钦,一...
    開封第一講書人閱讀 51,208評論 1 299
  • 那天,我揣著相機與錄音竞漾,去河邊找鬼司忱。 笑死皇忿,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的坦仍。 我是一名探鬼主播鳍烁,決...
    沈念sama閱讀 40,091評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼繁扎!你這毒婦竟也來了幔荒?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 38,929評論 0 274
  • 序言:老撾萬榮一對情侶失蹤梳玫,失蹤者是張志新(化名)和其女友劉穎爹梁,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體提澎,經(jīng)...
    沈念sama閱讀 45,346評論 1 311
  • 正文 獨居荒郊野嶺守林人離奇死亡姚垃,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,570評論 2 333
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了盼忌。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片积糯。...
    茶點故事閱讀 39,739評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖谦纱,靈堂內(nèi)的尸體忽然破棺而出看成,到底是詐尸還是另有隱情,我是刑警寧澤跨嘉,帶...
    沈念sama閱讀 35,437評論 5 344
  • 正文 年R本政府宣布川慌,位于F島的核電站,受9級特大地震影響祠乃,放射性物質(zhì)發(fā)生泄漏梦重。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,037評論 3 326
  • 文/蒙蒙 一亮瓷、第九天 我趴在偏房一處隱蔽的房頂上張望琴拧。 院中可真熱鬧,春花似錦寺庄、人聲如沸艾蓝。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,677評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至亮靴,卻和暖如春馍盟,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背茧吊。 一陣腳步聲響...
    開封第一講書人閱讀 32,833評論 1 269
  • 我被黑心中介騙來泰國打工贞岭, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留八毯,地道東北人。 一個月前我還...
    沈念sama閱讀 47,760評論 2 369
  • 正文 我出身青樓瞄桨,卻偏偏與公主長得像话速,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子芯侥,可洞房花燭夜當晚...
    茶點故事閱讀 44,647評論 2 354

推薦閱讀更多精彩內(nèi)容