在项目当中要做单点登陆，所以使用到了redis，在项目当中使用了连接池进行连接，下面进行说明
一.连接池构建
需要注意的是连接池需要在项目初始化的时候进行，连接池的构建由JedisPool对象来完成，并提供了一个getJedis的方法。
package com.mall.common;
import com.mall.util.PropertiesUtil;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* redis连接池
*/
public class RedisPool {
//tomcat 启动时JedisPool可以加载进来
private static JedisPool pool;
//最大连接数
private static Integer maxTotal=Integer.parseInt(PropertiesUtil.getProperty("redis.max.total","20"));
//最大空闲的连接数
private static Integer maxIdle=Integer.parseInt(PropertiesUtil.getProperty("redis.max.idle","10"));
//最小空闲连接数
private static Integer minIdle=Integer.parseInt(PropertiesUtil.getProperty("redis.min.idle","2"));
//从jedis连接池获取连接时，校验并返回可用的连接
private static Boolean testOnBorrow=Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.borrow","true"));
//把连接放回jedis连接池时，校验并返回可用的连接
private static Boolean testOnReturn=Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.return","true"));
private static String redisIp=PropertiesUtil.getProperty("redis.ip");
private static Integer redisPort=Integer.parseInt(PropertiesUtil.getProperty("redis.port"));
private static void initPool(){
JedisPoolConfig config=new JedisPoolConfig();
config.setMaxTotal(maxTotal);//默认8
config.setMaxIdle(maxIdle);//默认8
config.setMinIdle(minIdle);//默认0
config.setTestOnBorrow(testOnBorrow);//默认false
config.setTestOnReturn(testOnReturn);//默认false
//默认就是true，连接耗尽的时候是否阻塞，false会报异常，true阻塞直到超时，超时会报超时异常
config.setBlockWhenExhausted(true);
pool=new JedisPool(config,redisIp,redisPort,1000*2);
}
//类在加载到jvm的时候加载连接池
static {
initPool();
}
//获取redis
public static Jedis getJedis(){
return pool.getResource();
}
//将redis放回连接池,释放资源
public static void close(Jedis jedis){
if(jedis !=null){
jedis.close();
}
}
public static void main(String[] args) {
Jedis jedis=pool.getResource();// Jedis jedis=RedisPool.getJedis()
jedis.set("name","codeSheep");
close(jedis);
pool.destroy();//销毁连接池当中的所有连接
System.out.println("program is end");
}
}
****************************redis参数****************************
#redis config start
redis.ip=127.0.0.1
redis.port=6379
redis.max.total=20
redis.max.idle=10
redis.min.idle=2
redis.test.borrow=true
redis.test.return=true
二.redis工具类封装
工具类比较简单，一般都是从连接池获取redis连接，然后执行操作，其次关闭连接。
package com.mall.util;
import com.mall.common.RedisPool;
import lombok.extern.slf4j.Slf4j;
import redis.clients.jedis.Jedis;
@Slf4j
public class RedisPoolUtil {
public static String set(String key,String value){
Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
String result=jedis.set(key,value);
RedisPool.close(jedis);
return result;
}
public static String get(String key){
Jedis jedis=RedisPool.getJedis();
String value=jedis.get(key);
RedisPool.close(jedis);
return value;
}
//exTime的单位是s,设置key的值为value，存活时间是exTime
public static String setEx(String key,String value,int exTime){
Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
//设置key的值为value，存活时间是exTime
String result=jedis.setex(key,exTime,value);
RedisPool.close(jedis);
return result;
}
//重置key的有效期
public static Long expire(String key,int exTime){
Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
//设置key的值为value，存活时间是exTime
Long result=jedis.expire(key,exTime);
RedisPool.close(jedis);
return result;
}
//删除key
public static Long del(String key){
Jedis jedis=RedisPool.getJedis();//拿到一个redis的连接
//删除key
Long result=jedis.del(key);
RedisPool.close(jedis);
return result;
}
public static void main(String[] args) {
String result=RedisPoolUtil.set("sex","男");
String value=RedisPoolUtil.get("sex");
System.out.println(value);
RedisPoolUtil.setEx("zhandouli","10000",60*10);
RedisPoolUtil.expire("sex",60*20);
RedisPoolUtil.del("sex");
System.out.println("end");
}
}
结果正确显示
