SpringBoot中搭建Redis缓存

（一）SpringBoot中搭建Redis缓存

这篇文章讲述如何在Springboot中搭建redis，参考了很多大神的文章但是运用在我的项目里却不能发挥出来
，可能框架原因把，因为是在项目搭建完成后再来搭的redis的。搭建redis我感觉我这篇文章比较简单、方便、容易维护话不多说进入正题。

1)、以下链接是如何在window本地搭建redis进行测试http://www.bieryun.com/3206.html

注意：在导入jedis-2.6.2.jar、spring-data-redis-1.4.2.RELEASE.jar 如果你下载的版本太低可能会提示版本有误（解决方法只要重新下一个高版本就行了），我这个版本应该是没错的。之前

spring-data-redis-1.4.2.RELEASE.jar 我是下载1.0.0所以太低了。

2）在Springboot运用redis方法进行缓存操作

第一步：在pom.xml文件中配置redis

[html] view plain copy

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-redis</artifactId>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.5.2</version>
</dependency>

第二步：初始化Redis连接池，操作redis

CacheKit.java:

[html] view plain copy

package com.zcwl.redis;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.exceptions.JedisConnectionException;
public class CacheKit {
private static Logger logger = LoggerFactory.getLogger(CacheKit.class);
private List<JSONObject> resultList;
private static JedisPool pool;
/**
* 初始化Redis连接池
*/
private static void initializePool() {
//redisURL 与 redisPort 的配置文件
JedisPoolConfig config = new JedisPoolConfig();
//设置最大连接数（100个足够用了，没必要设置太大）
config.setMaxTotal(100);
//最大空闲连接数
config.setMaxIdle(10);
//获取Jedis连接的最大等待时间（50秒）
config.setMaxWaitMillis(50 * 1000);
//在获取Jedis连接时，自动检验连接是否可用
config.setTestOnBorrow(true);
//在将连接放回池中前，自动检验连接是否有效
config.setTestOnReturn(true);
//自动测试池中的空闲连接是否都是可用连接
config.setTestWhileIdle(true);
//创建连接池
//pool = new JedisPool(config, "120.88.166.244",6379); //连接阿里云服务器上面的缓存（如果本地在使用地址，本地运行将会把本地缓存数据同步在线上缓存中）
pool = new JedisPool(config, "127.0.0.1",6379); //本地缓存（更新需要将这个注释起来，解开上面地址）
}
/**
* 多线程环境同步初始化（保证项目中有且仅有一个连接池）
*/
private static synchronized void poolInit() {
if (null == pool) {
initializePool();
}
}
/**
* 获取Jedis实例
*/
private static Jedis getJedis() {
if (null == pool) {
poolInit();
}
int timeoutCount = 0;
while (true) {
try {
if (null != pool) {
return pool.getResource();
}
} catch (Exception e) {
if (e instanceof JedisConnectionException) {
timeoutCount++;
logger.warn("getJedis timeoutCount={}", timeoutCount);
if (timeoutCount > 3) {
break;
}
} else {
/* logger.warn("jedisInfo ... NumActive=" + pool.getResource().get("")
+ ", NumIdle=" + pool.getNumIdle()
+ ", NumWaiters=" + pool.getNumWaiters()
+ ", isClosed=" + pool.isClosed()); */
logger.warn(pool.getResource()+"//"+pool);
logger.error("GetJedis error,", e);
break;
}
}
break;
}
return null;
}
/**
* 释放Jedis资源
*
* @param jedis
*/
private static void returnResource(Jedis jedis) {
if (null != jedis) {
pool.returnResourceObject(jedis);
}
}
/**
* 绝对获取方法（保证一定能够使用可用的连接获取到目标数据）
* Jedis连接使用后放回
* @param key
* @return
*/
private String safeGet(String key) {
Jedis jedis = getJedis();
while (true) {
if (null != jedis) {
break;
} else {
jedis = getJedis();
}
}
String value = jedis.get(key);
returnResource(jedis);
return value;
}
/**
* 绝对设置方法（保证一定能够使用可用的链接设置数据）
* Jedis连接使用后返回连接池
* @param key
* @param time
* @param value
*/
public void safeSet(String key, int time, String value) {
Jedis jedis = getJedis();
while (true) {
if (null != jedis) {
break;
} else {
jedis = getJedis();
}
}
jedis.setex(key, time, value);
returnResource(jedis);
}
/**
* 绝对删除方法（保证删除绝对有效）
* Jedis连接使用后返回连接池</span>
* @param key
*/
private void safeDel(String key) {
Jedis jedis = getJedis();
while (true) {
if (null != jedis) {
break;
} else {
jedis = getJedis();
}
}
jedis.del(key);
returnResource(jedis);
}
/**
* 清除所有缓存
*/
private static void clearCache(){
CacheKit kit = new CacheKit();
Jedis jedis = getJedis();
while (true) {
if (null != jedis) {
break;
} else {
jedis = getJedis();
}
}