spring redis 连接和连接池配置使用

redis的使用方式方法有很多，我这里只用了这一种

jar包

redis

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.5.2</version>
</dependency>

连接池

<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.9.0</version>
</dependency>

redis 连接池配置

<bean id="redisConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig" lazy-init="true"><property name="maxTotal" value="${redis.pool.maxTotal}"/><property name="maxIdle" value="${redis.pool.maxIdle}"/><property name="minIdle" value="${redis.pool.minIdle}"/><property name="maxWaitMillis" value="${redis.pool.maxWaitMillis}"/><property name="testOnBorrow" value="${redis.pool.testOnBorrow}"/><property name="testOnReturn" value="${redis.pool.testOnReturn}"/><property name="timeBetweenEvictionRunsMillis" value="${redis.pool.timeBetweenEvictionRunsMillis}"/><property name="testWhileIdle" value="${redis.pool.testWhileIdle}"/><property name="numTestsPerEvictionRun" value="${redis.pool.numTestsPerEvictionRun}"/></bean>

redis bean

<bean id="jedisPool" class="redis.clients.jedis.JedisPool" lazy-init="true"><constructor-arg index="0" ref="redisConfig"/><constructor-arg index="1" value="${redis.hostname}"/><constructor-arg index="2" value="${redis.port}"/><constructor-arg index="3" value="${redis.timeout}"/><constructor-arg index="4" value="${redis.password}"/><constructor-arg index="5" value="${redis.database}"/>
</bean>

redis 客户端

实现了两个方法，一个有返回值一个没有返回值，可以自定义实现方法

下面都自动关闭了连接，也可以不设置关闭，如果不关闭连接的话连接池会自动关闭连接设置超时时间

@Lazy(value = true)
@Component
public class RedisClient {private Logger log = LoggerFactory.getLogger(RedisClient.class);@Resourceprivate  JedisPool jedisPool;public  <T> T use(Function<Jedis, T> function) {Jedis jedis = jedisPool.getResource();try{T t = function.apply(jedis);return t;}catch (Exception e){log.error(e.getMessage(),e);}finally {jedis.close();}return null;}public void voidUse(Consumer<Jedis> function) {Jedis jedis = jedisPool.getResource();try {function.accept(jedis);}catch (Exception e){log.error(e.getMessage(),e);}finally {jedis.close();}}public void setStringVal(String key,String val){this.voidUse(e->{e.set(key, val);});}public String setStringValRet(String key,String val){return this.use(e->{return e.set(key, val);});}public String getStringVal(String key){return this.use(e->{return e.get(key);});}/*** redis 操作 hash*///hmsetpublic String hmSetByMap(String key, Map<String,String> map){return this.use(e->{return e.hmset(key,map);});}public String hmSet(String key, String field,String val){return this.use(e->{Map<String,String> map = new HashMap<>();map.put(field,val);return e.hmset(key,map);});}//hgetallpublic Map<String, String>  hGetAll(String key){return this.use(e->{return e.hgetAll(key);});}//hdelpublic Long hDel(String key,String ...field){return this.use(e->{return e.hdel(key,field);});}//hexistspublic Boolean hexists(String key,String field){return this.use(e->{return e.hexists(key,field);});}//expirepublic long expire(String key,int time){return this.use(e->{return e.expire(key,time);});}//keyspublic Set<String> keys(String pattern){return this.use(e->{return e.keys(pattern);});}//delpublic long del(String key){return this.use(e->{return  e.del(key);});}public long del(String ...key){return this.use(e->{return  e.del(key);});}}

使用redis

@Resource
private RedisClient redisClient;
//删除public boolean deleteByUserCode(String key) {long count = redisClient.hDel(WHITE_KEY_LIST,key);return count>0;}
//保存public boolean save(String account,String userCode) {String ret = redisClient.hmSet(WHITE_KEY_LIST,userCode,account);return "OK".equals(ret);}