import java.io.IOException;

import java.util.Set;



import org.springframework.beans.factory.InitializingBean;

import org.springframework.util.Assert;



import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;



import com.my.utils.serialization.KryoSerializationUtils;



public class JedisCache implements InitializingBean {





    private JedisPool jedisPool;



    public void setJedisPool(JedisPool jedisPool) {



        this.jedisPool = jedisPool;

    }



    public void putObject(String key, Object object) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            jedis.set(key.getBytes(), KryoSerializationUtils.serialize(object));

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

    }



    public void putObject(String key, Object object, int expirationInSeconds) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            jedis.setex(key.getBytes(), expirationInSeconds, KryoSerializationUtils.serialize(object));

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

    }



    public Object getObject(String key) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            return (Object) KryoSerializationUtils.deserialize(jedis.get(key.getBytes()));

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

        return null;

    }



    public void removeObject(String key) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            jedis.del(key.getBytes());

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

    }



    public boolean exists(String key) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            return jedis.exists(key.getBytes());

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

        return false;

    }



    public long expire(String key, int expirationInSeconds) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            return jedis.expire(key.getBytes(), expirationInSeconds);

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

        return 0L;

    }



    public Set keys(final String pattern) {



        Jedis jedis = null;

        try {



            jedis = jedisPool.getResource();

            return jedis.keys(pattern);

        }

        catch (Exception ex) {



            handleException(ex, jedisPool, jedis);

        }

        finally {



            if (jedis != null && jedis.isConnected()) {



                jedisPool.returnResource(jedis);

            }

        }

        return null;

    }



    /**

     * 运行时异常，IO异常，销毁jedis对象

     *

     * @param ex

     * @param jedisPool

     * @param jedis

     */

    private void handleException(Exception ex, JedisPool jedisPool, Jedis jedis) {



        if (jedis == null)

            throw new NullPointerException("jedis is null, please check the redis server.");

        if (ex instanceof IOException) {



            jedisPool.returnBrokenResource(jedis); //销毁该对象

        }

    }



    @Override

    public void afterPropertiesSet() throws Exception {



        Assert.notNull(jedisPool);

    }

}

[b]application-bean.xml[/b]