首页 文章 精选 留言 我的

SpringBoot中搭建Redis缓存

2018-04-18 695

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

  1. <!--redis配置-->
  2. <dependency>
  3.     <groupId>org.springframework.boot</groupId>
  4.     <artifactId>spring-boot-starter-redis</artifactId>  <!-- 可以不需要加入版本号 -->
  5. </dependency>
  7.  <dependency>
  8.         <groupId>redis.clients</groupId>
  9.         <artifactId>jedis</artifactId>
  10.          <version>2.5.2</version>
  11.     </dependency>

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

CacheKit.java:

[html] view plain copy

  1. package com.zcwl.redis;
  3. import java.util.ArrayList;
  4. import java.util.Date;
  5. import java.util.Iterator;
  6. import java.util.List;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  11. import com.alibaba.fastjson.JSONArray;
  12. import com.alibaba.fastjson.JSONObject;
  14. import redis.clients.jedis.Jedis;
  15. import redis.clients.jedis.JedisPool;
  16. import redis.clients.jedis.JedisPoolConfig;
  17. import redis.clients.jedis.exceptions.JedisConnectionException;
  19. public class CacheKit {
  21.     private static Logger logger = LoggerFactory.getLogger(CacheKit.class);
  23.     private List<JSONObject> resultList;
  25.     private static JedisPool pool;
  28.      /**
  29.      * 初始化Redis连接池
  30.      */
  31.     private static void initializePool() {
  32.         //redisURL 与 redisPort 的配置文件
  34.         JedisPoolConfig config = new JedisPoolConfig();
  35.         //设置最大连接数（100个足够用了，没必要设置太大）
  36.         config.setMaxTotal(100);
  37.         //最大空闲连接数
  38.         config.setMaxIdle(10);
  39.         //获取Jedis连接的最大等待时间（50秒）
  40.         config.setMaxWaitMillis(50 * 1000);
  41.         //在获取Jedis连接时，自动检验连接是否可用
  42.         config.setTestOnBorrow(true);
  43.         //在将连接放回池中前，自动检验连接是否有效
  44.         config.setTestOnReturn(true);
  45.         //自动测试池中的空闲连接是否都是可用连接
  46.         config.setTestWhileIdle(true);
  47.         //创建连接池
  48.         //pool = new JedisPool(config, "120.88.166.244",6379);  //连接阿里云服务器上面的缓存（如果本地在使用地址，本地运行将会把本地缓存数据同步在线上缓存中）
  49.         pool = new JedisPool(config, "127.0.0.1",6379); //本地缓存（更新需要将这个注释起来，解开上面地址）
  50.     }
  53.     /**
  54.      * 多线程环境同步初始化（保证项目中有且仅有一个连接池）
  55.      */
  56.     private static synchronized void poolInit() {
  57.         if (null == pool) {
  58.             initializePool();
  59.         }
  60.     }
  62.     /**
  63.      * 获取Jedis实例
  64.      */
  65.     private static Jedis getJedis() {
  66.         if (null == pool) {
  67.             poolInit();
  68.         }
  70.         int timeoutCount = 0;
  71.         while (true) {
  72.             try {
  73.                 if (null != pool) {
  74.                     return pool.getResource();
  75.                 }
  76.             } catch (Exception e) {
  77.                 if (e instanceof JedisConnectionException) {
  78.                     timeoutCount++;
  79.                     logger.warn("getJedis timeoutCount={}", timeoutCount);
  80.                     if (timeoutCount > 3) {
  81.                         break;
  82.                     }
  83.                 } else {
  84.                    /* logger.warn("jedisInfo ... NumActive=" + pool.getResource().get("")
  85.                             + ", NumIdle=" + pool.getNumIdle()
  86.                             + ", NumWaiters=" + pool.getNumWaiters()
  87.                             + ", isClosed=" + pool.isClosed());  */
  88.                     logger.warn(pool.getResource()+"//"+pool);
  89.                     logger.error("GetJedis error,", e);
  90.                     break;
  91.                 }
  92.             }
  93.             break;
  94.         }
  95.         return null;
  96.     }
  99.     /**
  100.      * 释放Jedis资源
  101.      *
  102.      * @param jedis
  103.      */
  104.     private static void returnResource(Jedis jedis) {
  105.         if (null != jedis) {
  106.             pool.returnResourceObject(jedis);
  107.         }
  108.     }
  110.     /**
  111.      * 绝对获取方法（保证一定能够使用可用的连接获取到 目标数据）
  112.      * Jedis连接使用后放回
  113.      * @param key
  114.      * @return
  115.      */
  116.     private String safeGet(String key) {
  117.         Jedis jedis = getJedis();
  118.         while (true) {
  119.             if (null != jedis) {
  120.                 break;
  121.             } else {
  122.                 jedis = getJedis();
  123.             }
  124.         }
  125.         String value = jedis.get(key);
  126.         returnResource(jedis);
  127.         return value;
  128.     }
  131.     /**
  132.      * 绝对设置方法（保证一定能够使用可用的链接设置 数据）
  133.      * Jedis连接使用后返回连接池
  134.      * @param key
  135.      * @param time
  136.      * @param value
  137.      */
  138.     public void safeSet(String key, int time, String value) {
  139.         Jedis jedis = getJedis();
  140.         while (true) {
  141.             if (null != jedis) {
  142.                 break;
  143.             } else {
  144.                 jedis = getJedis();
  145.             }
  146.         }
  147.         jedis.setex(key, time, value);
  148.         returnResource(jedis);
  149.     }
  151.     /**
  152.      * 绝对删除方法（保证删除绝对有效）
  153.      * Jedis连接使用后返回连接池</span>
  154.      * @param key
  155.      */
  156.     private void safeDel(String key) {
  157.         Jedis jedis = getJedis();
  158.         while (true) {
  159.             if (null != jedis) {
  160.                 break;
  161.             } else {
  162.                 jedis = getJedis();
  163.             }
  164.         }
  165.         jedis.del(key);
  166.         returnResource(jedis);
  167.     }
  169.     /**
  170.      * 清除所有缓存
  171.      */
  172.     private static void clearCache(){
  173.         CacheKit kit = new CacheKit();
  174.         Jedis jedis = getJedis();
  175.         while (true) {
  176.             if (null != jedis) {
  177.                 break;
  178.             } else {
  179.                 jedis = getJedis();
  180.             }
  181.         }

[html] view plain copy

  1.        //PS:redis默认有一些key已经存在里面，不能删除，所以后面在添加key的时候用一个统一的标识符这样将自己添加的删除
  2.         Iterator it = jedis.keys("redis*").iterator();  //带*号清除所有，如果写有前缀就匹配出来sy*
  3.         while (it.hasNext()) {
  4.             String key = (String) it.next();
  5.             kit.delByCache(key);    //删除key
  6.             logger.info(new Date()+"：将redis缓存"+key+"值删除成功！");
  7.         }
  8.         returnResource(jedis);
  9.     }
  12.     /**自定义的一些 get set del 方法，方便使用  在其他地方直接调用**/
  13.     public JSONObject getByCache(String key) {
  14.         String result = safeGet(key);
  15.         if (result != null) {
  16.             return (JSONObject) JSONObject.parse(result);
  17.         }
  18.         return null;
  19.     }
  21.     public String getByCacheToString(String key) {
  22.         String result = safeGet(key);
  23.         if (result != null) {
  24.             return result;
  25.         }
  26.         return null;
  28.     }
  30.     public List<JSONObject> getArrayByCache(String key) {
  31.         String result = safeGet(key);
  32.         if (result != null) {
  33.             resultList = JSONArray.parseArray(result, JSONObject.class);
  34.             return resultList;
  35.         }
  36.         return null;
  37.     }
  39.     public JSONArray getJSONArrayByCache(String key) {
  40.         String result = safeGet(key);
  41.         if (result != null) {
  42.             return JSONArray.parseArray(result);
  43.         }
  44.         return null;
  45.     }
  47.     public void setByCache(String key, String s) {
  48.         safeSet(key, 86400, s);
  49.     }
  51.     public void setByCacheOneHour(String key, String s) {
  52.         safeSet(key, 3600, s);
  53.     }
  55.     public void setByCacheOneHour(String key, List<JSONObject> json) {
  56.         safeSet(key, 86400, JSONObject.toJSONString(json));
  57.         resultList = json;
  58.     }
  60.     public void setByCache(String key, JSONObject json) {
  61.         safeSet(key, 86400, JSONObject.toJSONString(json));
  62.     }
  64.     public void setByCache(String key, List<JSONObject> list) {
  65.         safeSet(key, 86400, JSONObject.toJSONString(list));
  66.         resultList = list;
  67.     }
  69.     public void setByCache(String key, JSONArray array) {
  70.         safeSet(key, 86400, JSONArray.toJSONString(array));
  71.     }
  73.     public void setByCacheCusTime(String key, String s, int time) {
  74.         safeSet(key, time, s);
  75.     }
  77.     public void delByCache(String key) {
  78.         //该方法删除指定的key
  79.         if (null != safeGet(key)) {
  80.             safeDel(key);
  81.         }
  82.     }
  84.     //该方法用来清除所有相关redis的key
  85.     public void delRedisRelevantKey(){
  86.         clearCache();
  87.     }
  89.     public JSONObject toJSON(JSONObject db) {
  90.         return (JSONObject) JSONObject.toJSON(db);
  91.     }
  93.     public List<JSONObject> toJSON(List<JSONObject> list) {
  94.         List<JSONObject> json = new ArrayList<>();
  95.         for (JSONObject aList : list) {
  96.             json.add((JSONObject) JSONObject.toJSON(aList));
  97.         }
  98.         return json;
  99.     }
  101.     public boolean notNull() {
  102.         return resultList != null && resultList.size() > 0;
  103.     }
  105.     public List<JSONObject> getResult() {
  106.         return resultList;
  107.     }
  109.     public static void main(String[] args) {
  110.         //clearCache();  到这里自己去测试一下是否可以
  111.     }
  113. }

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

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

RedisUtil.java

这个类用来写redis公共方法

[html] view plain copy

  1. package com.zcwl.redis;
  3. import java.util.ArrayList;
  4. import java.util.Date;
  5. import java.util.List;
  7. import org.slf4j.Logger;
  8. import org.slf4j.LoggerFactory;
  10. import com.zcwl.goods.dto.GoodsBrand;
  12. import net.sf.json.JSONObject;
  14. /**
  15.  * redis缓存公共方法
  16.  * @author Liangth
  17.  */
  19. public class RedisUtil {
  21.     private static Logger log = LoggerFactory.getLogger(RedisUtil.class);
  23.     //redisSyIndexBrand    命名分解  redis（用来清除缓存时候，查找） SY（代表首页比如商城：SC） 后面随机变化
  24.     private static final String index_Brand = "redisSyIndexBrand";      //首页推荐品牌
  26.     private static CacheKit kit = new CacheKit();
  28.     /**
  29.      * 首页推荐品牌
  30.      * start
  31.      */
  32.     //缓存数据
  33.     public void saveIndexBrand(List<GoodsBrand> goodsBrand){
  34.         try {
  35.             List<JSONObject> array = new ArrayList<JSONObject>();
  36.             for (int i = 0; i < goodsBrand.size(); i++) {
  37.                 JSONObject object = new JSONObject();
  38.                 object.put("id", goodsBrand.get(i).getId());
  39.                 object.put("brandName", goodsBrand.get(i).getBrandName());
  40.                 object.put("brandImg", goodsBrand.get(i).getBrandImg());
  41.                 if(goodsBrand.get(i).getCountryImgUrl()==null){
  42.                     object.put("countryImgUrl", "");
  43.                 }else{
  44.                     object.put("countryImgUrl", goodsBrand.get(i).getCountryImgUrl());
  45.                 }
  46.                 object.put("specialType", goodsBrand.get(i).getSpecialType());
  47.                 array.add(object);
  48.             }
  49.             kit.setByCache(index_Brand, array.toString());
  50.             log.info(new Date()+"：缓存数据首页推荐品牌成功。key："+index_Brand);
  51.         } catch (Exception e) {
  52.             log.error("数据缓存首页推荐品牌异常，请检查RedisUtil方法!。key："+index_Brand);
  53.         }
  54.     }
  56.     //读取缓存
  57.     public List<GoodsBrand> readIndexBrand(){
  58.         List<GoodsBrand> goodsBrand = new ArrayList<GoodsBrand>();
  59.         try {
  60.             List<com.alibaba.fastjson.JSONObject> list = kit.getArrayByCache(index_Brand);
  61.             for (int i = 0; i < list.size(); i++) {
  62.                 GoodsBrand brand = new GoodsBrand();
  63.                 brand.setId(Integer.parseInt(list.get(i).get("id").toString()));
  64.                 brand.setBrandName(list.get(i).get("brandName").toString());
  65.                 brand.setBrandImg(list.get(i).get("brandImg").toString());
  66.                 if(list.get(i).get("countryImgUrl").toString() != null){
  67.                     brand.setCountryImgUrl(list.get(i).get("countryImgUrl").toString());
  68.                 }else{
  69.                     brand.setCountryImgUrl("");
  70.                 }
  71.                 brand.setSpecialType(list.get(i).get("specialType").toString());
  72.                 goodsBrand.add(brand);
  73.             }
  74.             log.info(new Date()+"：读取缓存数据首页推荐品牌成功。key："+index_Brand);
  75.         } catch (Exception e) {
  76.             // TODO: handle exception
  77.             log.error("读取缓存首页推荐品牌异常，请检查RedisUtil方法!。key："+index_Brand);
  78.         }
  79.         return goodsBrand;
  80.     }
  82.     /**
  83.      * end
  84.      */
  86. }

注意：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
622
上一篇

JSONP利用

参考文献: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
669
下一篇

相关文章

发表评论

资源下载

更多资源
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

时间: 2025-12-17 大小: 1MB 下载: 2次
Spring

Spring

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

时间: 2025-12-17 大小: 5MB 下载: 1次
Rocky Linux

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2025-12-17 大小: 1.42GB 下载: 1次
Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

时间: 2025-12-03 大小: 9.84MB 下载: 39次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
Redis SpringCloud Gemini3 Rocky Nacos3 DeepSeek SpringBoot4 OpenAi Docker Service Mesh HarmonyOS6 Kubernetes Jdk25

欢迎您！

登录后，您将获得更多功能！

热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273