java使用redis一般都是通過redis.clients.jedis.Jedis來連線redis伺服器，通過redis.clients.jedis.Jedis提供的方法使用redis

但是每次執行完jedis裡面的方法之後必須關閉連結，釋放資源，否則連結一旦用完下次再使用redis程式會堵塞，但是手動關閉連結或出現很多的重複程式碼，並且有些時候也會忘記關閉

解決方法就是使用代理模式來解決這一問題

代理有兩種：java的Proxy類和Spring的Enhancer

區別就是前者只能代理基於介面的類，也就是說代理的類必須是介面，否則無法代理

後者是Spring的代理類，彌補java的Proxy只能代理介面的缺陷

Enhancer使用非常簡單，只要使用了Spring就會有，全類目是org.springframework.cglib.proxy.Enhancer

package com.xiaogang.report.proxy;

import com.xiaogang.report.handler.JedisHandler;
import org.springframework.cglib.proxy.Callback;
import org.springframework.cglib.proxy.Enhancer;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * jedis代理，自動關閉jedis連線
 */
public class JedisProxy {

    private JedisPool jedisPool;

    public JedisProxy(JedisPool jedisPool) {
        this.jedisPool = jedisPool;
    }

    public Jedis createProxy() throws Exception{
        Enhancer enhancer = new Enhancer();
        //設定代理的父類，就設定需要代理的類
        enhancer.setSuperclass(Jedis.class);
        //設定自定義的代理方法
        Callback callback = new JedisHandler(jedisPool);
        enhancer.setCallback(callback);

        Object o = enhancer.create();
        Jedis jedis = null;
        if (o instanceof Jedis){
            jedis = (Jedis) o;
        }
        return jedis;
    }

}
 

package com.xiaogang.report.handler;

import org.springframework.cglib.proxy.InvocationHandler;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

import java.lang.reflect.Method;

/**
 * jedis代理，自動關閉資源
 */
public class JedisHandler implements InvocationHandler {

    private JedisPool jedisPool;

    public JedisHandler(JedisPool jedisPool){
        this.jedisPool = jedisPool;
    }

    /**
     * 當使用jedis方法的時候，實際呼叫的這裡的方法
     * @param proxy
     * @param method
     * @param args
     * @return
     * @throws Throwable
     */
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        System.out.println("JedisHandler.invoke -----start");
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            Object invoke = method.invoke(jedis, args);
            System.out.println("代理方法獲得的結果："+invoke);
            return invoke;
        }finally {
            if (jedis != null) {
                jedis.close();
                System.out.println("關閉jedis連線");
            }
            System.out.println("JedisHandler.invoke -----end");
        }
    }
}
 

以後獲取Jedis物件通過new JedisProxy().createProxy()，使用jedis的方法都會自動關閉連線了

執行結果

JedisHandler.invoke -----start
代理方法獲得的結果：[email protected]
關閉jedis連線
JedisHandler.invoke -----end