SpringBoot中搭建Redis缓存

2018-04-18 744

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();
}
}

[html] view plain copy

//PS:redis默认有一些key已经存在里面，不能删除，所以后面在添加key的时候用一个统一的标识符这样将自己添加的删除
Iterator it = jedis.keys("redis*").iterator(); //带*号清除所有，如果写有前缀就匹配出来sy*
while (it.hasNext()) {
String key = (String) it.next();
kit.delByCache(key); //删除key
logger.info(new Date()+"：将redis缓存"+key+"值删除成功！");
}
returnResource(jedis);
}
/**自定义的一些 get set del 方法，方便使用在其他地方直接调用**/
public JSONObject getByCache(String key) {
String result = safeGet(key);
if (result != null) {
return (JSONObject) JSONObject.parse(result);
}
return null;
}
public String getByCacheToString(String key) {
String result = safeGet(key);
if (result != null) {
return result;
}
return null;
}
public List<JSONObject> getArrayByCache(String key) {
String result = safeGet(key);
if (result != null) {
resultList = JSONArray.parseArray(result, JSONObject.class);
return resultList;
}
return null;
}
public JSONArray getJSONArrayByCache(String key) {
String result = safeGet(key);
if (result != null) {
return JSONArray.parseArray(result);
}
return null;
}
public void setByCache(String key, String s) {
safeSet(key, 86400, s);
}
public void setByCacheOneHour(String key, String s) {
safeSet(key, 3600, s);
}
public void setByCacheOneHour(String key, List<JSONObject> json) {
safeSet(key, 86400, JSONObject.toJSONString(json));
resultList = json;
}
public void setByCache(String key, JSONObject json) {
safeSet(key, 86400, JSONObject.toJSONString(json));
}
public void setByCache(String key, List<JSONObject> list) {
safeSet(key, 86400, JSONObject.toJSONString(list));
resultList = list;
}
public void setByCache(String key, JSONArray array) {
safeSet(key, 86400, JSONArray.toJSONString(array));
}
public void setByCacheCusTime(String key, String s, int time) {
safeSet(key, time, s);
}
public void delByCache(String key) {
//该方法删除指定的key
if (null != safeGet(key)) {
safeDel(key);
}
}
//该方法用来清除所有相关redis的key
public void delRedisRelevantKey(){
clearCache();
}
public JSONObject toJSON(JSONObject db) {
return (JSONObject) JSONObject.toJSON(db);
}
public List<JSONObject> toJSON(List<JSONObject> list) {
List<JSONObject> json = new ArrayList<>();
for (JSONObject aList : list) {
json.add((JSONObject) JSONObject.toJSON(aList));
}
return json;
}
public boolean notNull() {
return resultList != null && resultList.size() > 0;
}
public List<JSONObject> getResult() {
return resultList;
}
public static void main(String[] args) {
//clearCache(); 到这里自己去测试一下是否可以
}
}

之前看过其它大神的文章，都是将缓存地址放到application.properties、还有什么application.yml里面，但是我试过到我这里取不到地址，试过很多方式取不到所以才决定地址放到外面，我个人觉得影响应该不会很大。

里面也写了很多公共方法方便调用管理。如果这里测试没问题那就运用到业务流程存储数据。

RedisUtil.java

这个类用来写redis公共方法

[html] view plain copy

package com.zcwl.redis;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.zcwl.goods.dto.GoodsBrand;
import net.sf.json.JSONObject;
/**
* redis缓存公共方法
* @author Liangth
*/
public class RedisUtil {
private static Logger log = LoggerFactory.getLogger(RedisUtil.class);
//redisSyIndexBrand 命名分解 redis（用来清除缓存时候，查找） SY（代表首页比如商城：SC）后面随机变化
private static final String index_Brand = "redisSyIndexBrand"; //首页推荐品牌
private static CacheKit kit = new CacheKit();
/**
* 首页推荐品牌
* start
*/
//缓存数据
public void saveIndexBrand(List<GoodsBrand> goodsBrand){
try {
List<JSONObject> array = new ArrayList<JSONObject>();
for (int i = 0; i < goodsBrand.size(); i++) {
JSONObject object = new JSONObject();
object.put("id", goodsBrand.get(i).getId());
object.put("brandName", goodsBrand.get(i).getBrandName());
object.put("brandImg", goodsBrand.get(i).getBrandImg());
if(goodsBrand.get(i).getCountryImgUrl()==null){
object.put("countryImgUrl", "");
}else{
object.put("countryImgUrl", goodsBrand.get(i).getCountryImgUrl());
}
object.put("specialType", goodsBrand.get(i).getSpecialType());
array.add(object);
}
kit.setByCache(index_Brand, array.toString());
log.info(new Date()+"：缓存数据首页推荐品牌成功。key："+index_Brand);
} catch (Exception e) {
log.error("数据缓存首页推荐品牌异常，请检查RedisUtil方法!。key："+index_Brand);
}
}
//读取缓存
public List<GoodsBrand> readIndexBrand(){
List<GoodsBrand> goodsBrand = new ArrayList<GoodsBrand>();
try {
List<com.alibaba.fastjson.JSONObject> list = kit.getArrayByCache(index_Brand);
for (int i = 0; i < list.size(); i++) {
GoodsBrand brand = new GoodsBrand();
brand.setId(Integer.parseInt(list.get(i).get("id").toString()));
brand.setBrandName(list.get(i).get("brandName").toString());
brand.setBrandImg(list.get(i).get("brandImg").toString());
if(list.get(i).get("countryImgUrl").toString() != null){
brand.setCountryImgUrl(list.get(i).get("countryImgUrl").toString());
}else{
brand.setCountryImgUrl("");
}
brand.setSpecialType(list.get(i).get("specialType").toString());
goodsBrand.add(brand);
}
log.info(new Date()+"：读取缓存数据首页推荐品牌成功。key："+index_Brand);
} catch (Exception e) {
// TODO: handle exception
log.error("读取缓存首页推荐品牌异常，请检查RedisUtil方法!。key："+index_Brand);
}
return goodsBrand;
}
/**
* end
*/
}

注意：redis数据结构以key-value存储，所以将自己的数据结构转换成这种方式去存储，

3）：在控制器里面去调用上面接口

这里应该都看得懂，我就不解释啦。里面有打印那些提示，在控制台查看缓存功能是不是成功了！

4）清除缓存

我这里暂时没有做到数据库和redis数据的实时同步。

现在有两个方案可以更新：

（1）如果后台改动数据需要马上更新，那我们就可以在前台触发事件来调用后台清理缓存接口

（2）还有设置一个定时器调用接口，到某个时间段来同步数据

原文地址http://www.bieryun.com/3209.html

微信关注我们

原文链接：https://yq.aliyun.com/articles/582977

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Java 获取本机内外网ip

1. 获取本机内网网ip public class Test { public static void main(String[] args) throws IOException { System.out.println("内外ip：" + getIp()); System.out.println("外网ip：" + getMyIP()); } /** * 获取本机内网ip * @return * @throws UnknownHostException */ private static String getIp() throws UnknownHostException { String ip = InetAddress.getLocalHost().getHostAddress(); return ip; } /** * 获取本机外网ip * @return */ private static String getMyIP() throws IOException { String url = "http://ip.chinaz.com/getip.aspx"; InputSt...

2018-04-19

672

参考文献:https://segmentfault.com/a/1190000009577990http://www.codesec.net/view/172245.htmlhttp://www.freebuf.com/articles/web/126347.html https://www.jianshu.com:80/writer https:协议; www:子域名; jianshu主域名; 80:端口号; 跨域:用户对不同协议或不同域名或不同端口号的资源进行访问同源策略规定：XHR对象(ajax功能实现所依赖的对象)只能访问与包含它的页面位于同一域中的资源，有利于预防一些恶意行为。同源：即同一域，即相同协议&相同端口&相同域名&相同子域名 XHR对象:XMLHttpRequest 对象提供了对 HTTP 协议的完全的访问，包括 POST ,HEAD,GET。XHR 可以同步或异步地返回 Web 服务器的响应，并且能够以文本或者一个 DOM 文档的形式返回内容。XHR接口强制要求每个请求都具备严格的HTTP语义–应用提供数据和URL，浏览器格式化请求并管...

2018-04-19

705

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

SpringBoot中搭建Redis缓存

（一）SpringBoot中搭建Redis缓存

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

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

Java 获取本机内外网ip

JSONP利用

相关文章

发表评论

资源下载

优质分享App

Mario

Nacos

Spring

欢迎您来访！