java 操作redis （Spring 连接池）

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd"> <context:property-placeholder location="classpath*:/jedis/jedis.properties" />
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!--最大连接数 -->
<property name="maxTotal" value="${redis.pool.maxActive}" />
<!--最大空闲连接数 -->
<property name="maxIdle" value="${redis.pool.maxIdle}" />
<!--初始化连接数 -->
<property name="minIdle" value="${redis.pool.minIdle}" />
<!--最大等待时间 -->
<property name="maxWaitMillis" value="${redis.pool.maxWait}" />
<!--定时对线程池中空闲的链接进行validateObject校验 -->
<property name="testWhileIdle" value="true" />
<property name="testOnBorrow" value="true" />
<!--在进行returnObject对返回的connection进行validateObject校验 -->
<property name="testOnReturn" value="true" />
</bean>

<bean id="jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="destroy">
<constructor-arg index="0" ref="jedisPoolConfig" />
<constructor-arg index="1" value="${redis.host}" />
<constructor-arg index="2" value="${redis.port}" type="int" />
<constructor-arg index="3" value="${redis.timeout}" type="int" />
</bean>

</beans>

redis.host=${redis.host}
redis.port=${redis.port}
redis.password=${redis.password}
redis.timeout=${redis.timeout}
redis.pool.maxActive=${redis.pool.maxActive}
redis.pool.maxIdle=${redis.pool.maxIdle}
redis.pool.minIdle=${redis.pool.minIdle}
redis.pool.maxWait=${redis.pool.maxWait}

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fctx.ordercenter_common.utils.JsonUtil;
import com.fctx.ordercenter_webapp.common.lib.WebConfigConstant;

/**
* @Title: JedisCacheClient.java
* @Package com.tctx.common.redis
* @Description: redis 操作数据库配置类
*/
@Component("jedisCacheClient")
public class JedisCacheClient {

private Logger log = Logger.getLogger(JedisCacheClient.class);

@Autowired
private JedisPool jedisPool;

/**
*
* setVExpire(设置key值，同时设置失效时间 秒)
* @Title: setVExpire
* @param @param key
* @param @param value
* @param @param seconds
* @param index 具体数据库
* @return void
* @throws
*/
public <V> void setVExpire(String key, V value,int seconds,int index) {
String json = JSON.toJSONString(value);
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(index);
jedis.set(WebConfigConstant.PROJECT+key, json);
jedis.expire(WebConfigConstant.PROJECT+key, seconds);
} catch (Exception e) {
log.error("setV初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}

}
/**
*
* (存入redis数据)
* @Title: setV
* @param @param key
* @param @param value
* @param index 具体数据库
* @return void
* @throws
*/
public <V> void setV(String key, V value,int index) {
String json = JSON.toJSONString(value);
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(index);
jedis.set(WebConfigConstant.PROJECT+key, json);
} catch (Exception e) {
log.error("setV初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}

}

/**
*
* getV(获取redis数据信息)
* @Title: getV
* @param @param key
* @param index 具体数据库 0:常用数据存储      3：session数据存储
* @param @return
* @return V
* @throws
*/
@SuppressWarnings("unchecked")
public <V> V getV(String key,int index) {
String value = "";
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(index);
value = jedis.get(WebConfigConstant.PROJECT+key);
} catch (Exception e) {
log.error("getV初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
return (V)JSONObject.parse(value);
}
/**
*
* getVString(返回json字符串)
* @Title: getVString
* @param @param key
* @param @param index
* @param @return
* @return String
* @throws
*/
public String getVStr(String key,int index) {
String value = "";
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(index);
value = jedis.get(WebConfigConstant.PROJECT+key);
} catch (Exception e) {
log.error("getVString初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
return value;
}

/**
*
* Push(存入 数据到队列中)
*
* @Title: Push
* @param @param key
* @param @param value
* @return void
* @throws
*/
public <V> void Push(String key, V value) {
String json = JSON.toJSONString(value);
Jedis jedis = null;
try {
log.info("存入 数据到队列中");
jedis = jedisPool.getResource();
jedis.select(15);
jedis.lpush(key, json);
} catch (Exception e) {
log.error("Push初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
}
/**
*
* Push(存入 数据到队列中)
*
* @Title: PushV
* @param  key
* @param value
* @param dBNum
* @return void
* @throws
*/
public <V> void PushV(String key, V value,int dBNum) {
String json = JSON.toJSONString(value);
Jedis jedis = null;
try {
log.info("存入 数据到队列中");
jedis = jedisPool.getResource();
jedis.select(dBNum);
jedis.lpush(key, json);
} catch (Exception e) {
log.error("Push初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
}

/**
*
* Push(存入 数据到队列中)
*
* @Title: Push
* @param @param key
* @param @param value
* @return void
* @throws
*/
public <V> void PushEmail(String key, V value) {
String json = JsonUtil.entity2Json(value);
Jedis jedis = null;
try {
log.info("存入 数据到队列中");
jedis = jedisPool.getResource();
jedis.select(15);
jedis.lpush(key, json);
} catch (Exception e) {
log.error("Push初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
}

/**
*
* Pop(从队列中取值)
*
* @Title: Pop
* @param @param key
* @param @return
* @return V
* @throws
*/
@SuppressWarnings("unchecked")
public <V> V Pop(String key) {
String value = "";
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(15);
value = jedis.rpop(WebConfigConstant.PROJECT+key);
} catch (Exception e) {
log.error("Pop初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}
return (V) value;
}

/**
*
* expireKey(限时存入redis服务器)
*
* @Title: expireKey
* @param @param key
* @param @param seconds
* @return void
* @throws
*/
public void expireKey(String key, int seconds) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
jedis.select(3);
jedis.expire(WebConfigConstant.PROJECT+key, seconds);
} catch (Exception e) {
log.error("Pop初始化jedis异常：" + e);
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} finally {
closeJedis(jedis);
}

}

/**
*
* closeJedis(释放redis资源)
*
* @Title: closeJedis
* @param @param jedis
* @return void
* @throws
*/
public void closeJedis(Jedis jedis) {
try {
if (jedis != null) {
jedisPool.returnBrokenResource(jedis);
}
} catch (Exception e) {
log.error("释放资源异常：" + e);
}
}

public void setJedisPool(JedisPool jedisPool) {
this.jedisPool = jedisPool;
}

}