前言

es我们已经在前文中有所了解，和es有相似功能的是Redis，他们都不是纯粹的数据库。两者使用场景也是存在一定的差异的，本文目的并不重点说明他们之间的差异，但会简要说明，重点还是在对Redis的了解和学习上。学完本篇，你将了解Redis的特点和作用，掌握Redis的基础用法，这将有助于你在后续的项目中更好的使用Redis。建议大家都动手和博主一起实操，莫要养成眼高手低的毛病，下面，让我们提起精神，一起开始这场Redis盛宴吧。

Redis

什么是Redis

Redis全名Remote Dictionary Server，即远程字典服务，是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的api。

其官网：Redis

虽然Redis也是数据库，但又有别于我们所知的Mysql等关系型数据库，Redis是一款基于内存的NoSQL数据存储服务，也就是非关系型的数据库，这点要搞搞清楚。

为什么使用Redis

相信大家在学习sql的时候都有过这样的经历，往数据库插入50w条数据，然后去条件检索某些数据，效率如何？大家心里多少还是有点x数的，试想，这种暴力型操作要是出现在我们常用的一些网站和应用上，且每次请求到这么做，那该是何等的疯狂？

说到这里，其实还没有说出Redis的主要应用场景，每每想到这个，总是会跳出另一个东西：ES。算了，咱们看下面的对比吧，有对比才有伤害啊！

Redis和ES的区别

Redis使用场景

因为Redis是基于内存运行的，说起内存，你应该知道，其运行效率远高于和硬盘的交互。这也就导致了Redis运行效率非常高。

Redis同样支持将数据存储在硬盘上，支持主从和分布式使用，但在事务上有着严重不足，所以在关系比较复杂的地方就不适合使用Redis，但却可以配合关系型数据库做缓存，也就是通过复杂SQL查找到数据缓存在Redis。

此类缓存数据，我准备用一个绝对一些的词，必须是稳定型，通用型，高频次数据，比如类别，商品信息，资讯信息等。如果每次请求都会变，每个人又都不一样的数据，不太建议存储在Redis，不是不行，只是不建议，因为会占用大量的内存，造成数据的冗余，还不利于做数据同步。

ES使用场景

ES是非关系型数据库，我们通常说他是一个引擎，实时搜索引擎，他是把数据按照一定的规律存储起来，达到比关系型数据库查询效率更高的目的。

ES扩展容易，前文中曾使用了ik插件，ES同样支持主从，由于其存储的数据结构特点，所以其查询效率非常高，在微服务这种大数据形态下的表现尤为优秀，可以快速实现数据的整合，对于日志和数据分析非常友好，对于实时状态的高也并发有着极强的适应能力，且延迟也很低。

想了解ES的童鞋可以点击下面链接前往查看：Java开发 - Elasticsearch初体验

Redis安装

由于博主是Mac电脑，这里就以Mac为例，windows没试过，Windows的童鞋可自行百度安装。

• 打开终端，输入：brew install redis
• 测试安装成功输入：redis-server，看到Redis 的启动日志则说明安装成功，通过Ctrl-C可停止此redis
• 使用 launchd 启动Redis：brew services start redis 暂停Redis：brew services stop redis                                                                                                               查看Redis信息：brew services info redis

其实博主觉得这么做挺麻烦的，有个东西叫：Docker Desktop

直接安装这个，Mac电脑省去了安装虚拟机的麻烦，直接在此软件内安装各种服务，不要太爽：

数据库，Nacos，senta等都可以在这里安装并且一键启动，推荐大家去装一个，就不用每一个东西都要自己装，太麻烦了。

还有个Redis的客户端也推荐大家装一下 ：

此软件在Mac上App Store是收费的，推荐安装方式如下：

brew install --cask another-redis-desktop-manager

安装后就可以找到启动图标了，Windows可在网上自行搜索，其工作页面如下：

可看到目前我们是启动状态，客户端连接数是1。

最好弄好了这些东西后再来跟着学下去，这种可视化工具可以在我们调用接口时看到存储在Redis中的数据，非常方便。

Redis缓存

缓存淘汰

Redis帮助我们解决了一些三高的问题，但在访问量非常大的时候，Redis要在同一时间保存大量的数据，但Redis内存并不是无限的，一旦内存占满，可能会发生什么？降速？阻塞？宕机？都有可能，所以在连续不断的存入新数据的同时，还要将不使用的老数据及时的从内存中删除，这就需要一个淘汰策略。

好在Redis提供了这种机制，我们看看有哪些淘汰策略：

noeviction：返回错误**(默认)**
allkeys-random：所有数据中随机删除数据
volatile-random：所有过期时间的数据库中随机删除数据
volatile-ttl：删除剩余有效时间最少的数据
allkeys-lru：所有数据中删除上次使用时间最久的数据
volatile-lru：所有过期时间的数据中删除上次使用时间最久的数据
allkeys-lfu：所有数据中删除使用频率最少的
volatile-lfu：所有过期时间的数据中删除使用频率最少的

通过合理的选择以上参数配置Redis，可以有效解决这个问题，但也需要时刻监测Redis内存情况，现在的云服务做得都很好，可以提前预警通知。

缓存穿透

我们在使用Redis时，将数据库中查询出来的数据保存在Redis中，但Redis有自己的淘汰策略，所以这些数据并不会无限期保存。

正常来说，访问的请求会先去Redis中拿数据，拿不到才会去数据库中查找，再将查到的数据存储到Redis中，一旦这样的请求数量非常多的时候，数据库的压力就会变大，我们可以认为，其表现的现象即为Redis失效，没有工作，当然算是失效了，而这种情况，我们称之为缓存穿透。

开发中当然要避免缓存穿透，简单点，可以将查询回来为空的数据在Redis中存为null，防止Redis被反复穿透，但这也有缺点，比如反复更换查询关键字，反复穿透依然存在，当然，这只是特例，虽然实际中发生的概率不会太高，但还是要防范利用此情况攻击服务器的可能。

最好的做法是通过增加布隆过滤器来解决此问题，在业务进入时，提前判断用户查询的信息是否存在于数据库中，如果没有，直接返回，不再走完整的路径。

缓存击穿

缓存穿透和缓存击穿很类似，我们正常的流程是先访问Redis，Redis没有就去数据库查询，这种情况，数据库是可以查到数据的，此种现象就叫击穿，而少量的击穿并不是问题。

缓存雪崩

上面的击穿在同一时间大量发生，就变成了雪崩，数据库短时间内出现很多新的查询请求，就会发生性能问题。

这是由于Redis缓存淘汰策略把过期的数据大批量清空导致的，它本身不算异常，只是我们要避免同一时间大量的过期情况出现，所以在设置过期时间时，在基础时间上增加10分钟或30分钟以内的随机时间来解决这个问题，时间你可以自己定。

Redis持久化

存储特点

Redis是在内存中运行的，这和我们所有的软件都是一样的，内存可以保存，但Redis保存的数据却并不是在内存上，试想我们的电脑手机，关机后再打开还能恢复打开时的样子吗？这自然是不能的。

所以，为了解决断电重启等问题，Redis支持了持久化，将需要保存的数据保存在服务器硬盘上。

针对以上硬盘保存数据的特点，Redis在重新启动后恢复数据的方式有两种，我们来看看是哪两种。

RDB

RDB全称Redis Database Backup，中文名叫数据库快照，它可以将Redis数据库数据转化为二进制数据保存在硬盘上，生成一个dump.rdb的文件，想使用此恢复模式需要提前在Redis安装程序的配置文件中进行配置才能生效。

基于此模式，由于是整体Redis数据的二进制格式，所以数据恢复是整体恢复的，非常方便。但也因此存在了一个大文件的通病：读写效率不高。快照的备份不能实时进行，所以断电重启恢复只能恢复最后一次生成的rdb文件数据。可能会造成短时间的数据丢失。

AOF

AOF全称Append Only File，它的策略不是缓存数据，而是将所有命令日志备份下来，在数据丢失后，可以根据运行过的日志恢复为断电前的状态，注意一点：这种保存日志的策略也不是实时的，数据量比较大时会分批分次进行缓存。

实际中，我们一般设置1s发送一次日志，断电最多丢失1s数据。为了降低日志对内存的占用，AOF支持AOF rewrite，也就是说，如果你是删除数据，那完全没有留日志的必要，但默认时有日志的，所以，可以将这些删除操作的日志删除。

存储原理

存储原理博主简单给大家说说，想要深入了解的推荐这篇博客：Redis存储原理深入剖析 - 墨天轮

也可以自行查找。

Redis将内存划分为16384个槽，类似哈希槽，将要存储的数据的key通过CRC16算法处理，得到一个0~16383之间的值，然后将这条数据存储到对应的槽中，下次查找的时候也是通过CRC16算法处理过的数字去对应槽中查找当前key是否存在，因为有可能直接一次就找到对应key，所以这种存储查找方式效率非常高。这也是一种散列算法，和数据库主键查找的原理很类似。推荐读一下博主这篇博客：Java开发 - 数据库索引的数据结构

Redis集群

Redis我们一般说起来都会说Redis服务器，所以，Redis本质上也是一台服务器，Redis即服务器，服务器即Redis。服务器宕机，Redis肯定也好不到哪里去。如果只有一台Redis服务器，那将会面临一定的风险，比如系统崩溃。

主从

为了解决单Redis服务器可能存在的问题，我们一般会使用一台备用机，这就叫做主从。主从状态下，备用机Redis会实时同步主机Redis的数据，如果主机掉线，备用机就可以起到预备队的效果。但这也存在一定的问题，主机正常工作时，从机就在那里歇着，主机累的喘不过来气，肯定不愿意，从机的钱不是也白花了吗？如下图：

读写分离

为了解决从机不干活的问题，我们一般会将读写分离，主机可读可写，从机也可以读取，这样不仅让从机干活，还减轻了主机的压力，提高了项目运行的流畅度。如下图：

哨兵

此时，还存在一个问题，主机宕机后，需要人手动切换到从机，要是及时发现还好，要是不及时，将会造成严重的后果。这时候，我们需要一个可以自动切换到从机的机制：哨兵模式。如下图：

哨兵每隔固定时间向主从节点发送请求，如果节点正常相应，则说明节点正常工作，否则，将视为节点异常，启将自动切换备用机。

有时候，因为网络问题或者其他因素会导致哨兵接受请求返回异常而切换备用机，这不仅没起到保护的作用，还降低了Redis的工作效率，这时，有两种方式来解决：一是多次请求后都返回异常再切换备用机，二是采用多个哨兵的形式，当多台哨兵都认为某台机器存在异常，再切换到备用机。但是切记一点，哨兵不能和Redis在同一台服务器上，否则服务器异常哨兵也将离线。

 哨兵的配置推荐看看这篇博客：Redis中的哨兵模式 - 简书 

Redis基本使用

下面，我们就来看看Redis有哪些API，具体该怎么使用。在原来微服务项目中，上一篇Quartz是在stock子项目下运行的，Redis我们也在stock子项目下添加吧，你也可以选择其他模块，或者独立建一个项目也是可以的。

添加依赖

    org.springframework.boot    spring-boot-starter-data-redis

请注意，博主依赖中没有添加version信息是因为主工程中对版本进行了管理，如果你单独创建的项目是需要加上版本的，其他依赖在需要时按需添加。

添加配置

spring:  redis:    database: 0    host: localhost    port: 6379    passWord:    jedis:      pool:        #最大连接数        max-active: 8        #最大阻塞等待时间(负数表示没限制)        max-wait: -1        #最大空闲        max-idle: 8        #最小空闲        min-idle: 0        #连接超时时间        timeout: 10000    cache:      redis:        time-to-live: 360000000

推荐这篇博客：SpringDataRedis知识概括，可以去了解下Redis配置相关的详细信息，博主觉得写得还是很全面的。

创建配置类

操作Redis需要使用RedisTemplate对象，我们在config包下创建RedisConfiguration类：

package com.codingfire.cloud.stock.config;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.RedisSerializer;import java.io.Serializable;@Configurationpublic class RedisConfiguration {    @Bean    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {        RedisTemplate redisTemplate = new RedisTemplate<>();        redisTemplate.setConnectionFactory(redisConnectionFactory);        redisTemplate.seTKEySerializer(RedisSerializer.string());        redisTemplate.setValueSerializer(RedisSerializer.JSON());        return redisTemplate;    }}

固定模式，也没啥好说的，只是需要使用这样一个实例来操作Redis。

编写测试方法 

由于我们之前删除了用于测试的文件夹，还是需要新建的，选择src，新建，file：

选择test/java，新建测试类：

package com.codingfire.cloud.stock;import org.springframework.boot.test.context.SpringBootTest;@SpringBootTestpublic class CloudStockApplicationTests {    }

 包名，路径和格式注意下，不要错了。下面我们来添加Redis的测试方法。

存储普通字符串：

package com.codingfire.cloud.stock;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.data.redis.core.RedisTemplate;import org.junit.jupiter.api.Test;import java.io.Serializable;import java.util.concurrent.TimeUnit;@SpringBootTestclass CloudStockApplicationTests {    @Autowired    RedisTemplate redisTemplate;    @Test    void testSetValue() {        redisTemplate.opsForValue().set("name", "codingfire");    }}

运行测试方法，成功后我们去Redis客户端看看有没有什么变化：

这个就是我们测试方法中存入的数据，表示我们已经将此字符串存入Redis中。有问题的童鞋看看自己的Redis有没有启动连接。

有存就有取，我们去把刚才存进去的字符串取出来：

    @Test    void testGetValue() {        // 当key存在时，可获取到有效值        // 当key不存在时，获取到的结果将是null        Serializable name = redisTemplate.opsForValue().get("name");        System.out.println("get value --> " + name);    }

运行测试方法，查看控制台输出：

get value --> codingfire

成功从Redis取到了我们存入的数据。

不知道你注意到没，我们前面的配置类里面对Redis的存取类型做了限制：

redis存储类型很有限，不过好在string和json几乎能满足所有的需要，下面我们来存取对象类型试试：

    @Test    void testSetAdminValue() {        AdminLoginDTO adminLoginDTO = new AdminLoginDTO();        adminLoginDTO.setUsername("codingfire");        adminLoginDTO.setPassword("123456");        redisTemplate.opsForValue().set("user", adminLoginDTO);    }    @Test    void testGetAdminValue() {        // 当key存在时，可获取到有效值        // 当key不存在时，获取到的结果将是null        Serializable user = redisTemplate.opsForValue().get("user");        System.out.println("get value --> " + user);        if (user != null) {            AdminLoginDTO adminLoginDTO = (AdminLoginDTO) user;            System.out.println("get value --> " + adminLoginDTO);        }    }

分别运行以上存取对象类型方法，看看Redis客户端和控制台会输出什么。

存储对象后Redis客户端：

获取对象后控制台输出：

两次输出一样为什么还要强转呢？不强转你就不知道获取的对象类型，也无法直接使用序列化后对象进行数据的操作。

有添加就有删除，那么删除Redis中数据该怎么做呢：

    @Test    void testDeleteKey() {        // 删除key时，将返回“是否成功删除”        // 当key存在时，将返回true        // 当key不存在时，将返回false        Boolean result = redisTemplate.delete("name");        System.out.println("result --> " + result);    }

 运行此测试方法查看结果：

由于Redis中存在名为name的参数，所以result为true，对象类型的删除也是一样的操作。

接下来我们设置Redis的过期时间，时间到了就自动删除，我们通过查看源码得知，set有三个参数，第二个为过期时间，第三个为时间单位：

下面我来写代码：

    @Test    void testSetValueTimeout() {        redisTemplate.opsForValue().set("name", "codingfire",20, TimeUnit.SECONDS);    }

 运行测试方法，在Redis中能看到存入的数据，20s后，数据自动删除：

在客户端中能看到TTL，就是倒计时的意思，打开自动刷新功能，你能看见数字是在变化的。

在存储数据时还有一个特殊情况，比如分页数据，是一个数组，这该怎么存呢？Redis中ops是操作器，opsForValue可以操作普通字符串或对象类型，既然是对象，为什么不能操作数组？数组也是对象啊，博主也不死心，我们来试试看：

 好像成功了？为了对比这两种方式存储数组的能力我们来试试ospForList存数组后是否一样：

    @Test    void testRightPushList() {        // 存入List时，需要redisTemplate.opsForList()得到针对List的操作器        // 通过rightPush()可以向Redis中的List追加数据        // 每次调用rightPush()时使用的key必须是同一个，才能把多个数据放到同一个List中        List list = new ArrayList<>();        for (int i = 1; i <= 5; i++) {            AdminLoginDTO adminLoginDTO = new AdminLoginDTO();            adminLoginDTO.setUsername("name" + i);            list.add(adminLoginDTO);        }        String key = "UserList";        for (AdminLoginDTO adminLoginDTO : list) {            redisTemplate.opsForList().rightPush(key, adminLoginDTO);        }    }

运行测试代码后查看Redis客户端数据：

呀！数据展示的形式不一样啊，我们来获取并输出一下这两组数据，看看输出是否一样：

    @Test    void testGetListValue() {        // 调用opsForList()后再调用range(String key, long start, long end)方法取出List中的若干个数据，将得到List        // long start：起始下标（结果中将包含）        // long end：结束下标（结果中将包含），如果需要取至最后一个元素，可使用-1作为此参数值        List rangeList = redisTemplate.opsForList().range("UserList", 0, -1);        Serializable listSer = redisTemplate.opsForValue().get("list");        List list = (List) listSer;        System.out.println(rangeList);        System.out.println(list);        for (Serializable serializable : rangeList) {            System.out.println(serializable);        }        for (Serializable serializable : list) {            System.out.println(serializable);        }    }

 运行测试方法查看控制台输出：

从数据库，其实并没有什么太大的差别 ，但是请仔细看博主获取两个list的代码，秘密就藏在里面，也就是说：怎么存，怎么取，不通过数组专用方法的需要强转。这就是最终结论。大家不用自己试了，博主都一一试过了，opsForxxxxx用的不对就报错了。

最后再补充两个方法，一个是获取数组长度，一个是获取Redis中所有key的方法，注意：获取数组长度的方法必须是通过opsForList方法存进去的，否则此方法无效，且报错，看代码：

    @Test    void testListSize() {        // 获取List的长度，即List中的元素数量        String key = "UserList";        Long size = redisTemplate.opsForList().size(key);        System.out.println("size --> " + size);    }

运行结果：

获取所有Redis的key：

    @Test    void testKeys() {        // 调用keys()方法可以找出匹配模式的所有key        // 在模式中，可以使用星号作为通配符        Set keys = redisTemplate.keys("*");        for (String key : keys) {            System.out.println(key);        }    }

 此方法对ops无影响，只获取key，查看运行结果：

对比Redis客户端中所有key值：

完全一致，测试成功。

最后，关于Key的使用，通常建议使用冒号区分多层次，类似URL的设计方式，例如：

• 用户列表的Key：users:list或users
• 某个用户id（001）对应用户信息的Key：users:userId:001

但也不是绝对，可根据自己需要选择合适的组合方式，目的是使key不重复，且好理解。

到这里，Redis基础方法使用就讲解完了，但这毕竟只是基础方法，在实战中该怎么用还是个问题。下面，我们将在真实项目中去使用Redis。

Redis实战

开始前的思考

使用Redis可以提高查询效率，降低数据库的压力。基本上是用在高频查询的数据或是几乎不太会改变的数据上。所以，有些比较精密的经常需要变动的数据就不能使用Redis，比如购物类应用的创建订单，库存都属于此类数据。

所以在开始前确定哪些数据使用Redis，Redis中的数据从哪来是很重要的。关于Redis的调用，是写在业务逻辑层还是做一个单独的组件独立出来，这也是一个问题。

如果直接将访问Redis的代码写在Service中，首次开发时会很省事，但却不利于后期的维护。

如果将访问Redis的代码写的新的组件中，首次开发时会更麻烦，但有利于后期的维护。

所以你会怎么选呢？我们首先要知道，访问Redis的API都很简单，上面的基础使用大家基本应该是掌握了，也没什么难的，自定义组件虽然有利于后期维护，但代码量可能会很少，这个需要我们去衡量总体的工作量和后期的维护情况。

每一个项目都不一样，甚至有些小的项目根本不使用Redis都有可能，这并不是危言耸听，这个就教给大家自己选择了，今天，博主的目的是教会大家在项目中使用Redis。

创建Redis模块

博主准备以passport为基础，在其上使用Redis，虽然实际中不会在这么简单的模块用，不过该有的功能，博主是一步都不会省略的，照葫芦画瓢，其他的模块参照此模块就可以移植。passport是做单点登录的模块：Java开发 - 单点登录初体验（Spring Security + JWT）

没有此模块的童鞋可以先学此篇，也可以先看看博主代码，新建一个模块，照着往别的模块上面搬。

创建调用Redis接口

在passport包下创建repository包，repository下创建IPassportRedisRepository接口：

package com.codingfire.cloud.passport.repository;import com.codingfire.cloud.commons.pojo.passport.vo.AdminLoginVO;public interface IPassportRedisRepository {    String KEY_ADMIN_ITEM_PREFIX = "admins:item:";    // 将用户信息存入到Redis中    void save(AdminLoginVO adminLoginVO);    // 根据用户id获取用户信息    AdminLoginVO getAdminDetailsById(Long id);}

创建Redis实现类

在这一步之前，请大家添加Redis的依赖，并将上面代码中Redis的配置类RedisConfiguration复制到passport的config包下，在repository包下新建impl包，包下建PassportRedisRepositoryImpl实现类：

package com.codingfire.cloud.passport.repository.impl;import com.codingfire.cloud.commons.pojo.passport.vo.AdminLoginVO;import com.codingfire.cloud.passport.repository.IPassportRedisRepository;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Repository;import java.io.Serializable;@Repositorypublic class PassportRedisRepositoryImpl implements IPassportRedisRepository {    @Autowired    private RedisTemplate redisTemplate;    @Override    public void save(AdminLoginVO adminLoginVO) {        String key = KEY_ADMIN_ITEM_PREFIX + adminLoginVO();        redisTemplate.opsForValue().set(key, adminLoginVO);    }    @Override    public AdminLoginVO getAdminDetailsById(Long id) {        String key = KEY_ADMIN_ITEM_PREFIX + id;        Serializable result = redisTemplate.opsForValue().get(key);        if (result == null) {            return null;        } else {            AdminLoginVO adminLoginVO = (AdminLoginVO) result;            return adminLoginVO;        }    }}

测试以上代码

下面在test文件夹下depassport包下新建一个测试类PassportRedisRepositoryTests:

package com.codingfire.cloud.passport;import com.codingfire.cloud.commons.pojo.passport.dto.AdminLoginDTO;import com.codingfire.cloud.commons.pojo.passport.vo.AdminLoginVO;import com.codingfire.cloud.passport.repository.IPassportRedisRepository;import org.junit.jupiter.api.Assertions;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;@SpringBootTestclass PassportRedisRepositoryTests {    @Autowired    IPassportRedisRepository repository;    @Test    void testGetAdminDetailsByIdSuccessfully() {        testSave();        Long id = 2L;        AdminLoginDTO admin = repository.getAdminDetailsById(id);        System.out.println(admin);    }    @Test    void testGetAdminDetailsByIdReturnNull() {        Long id = -1L;        AdminLoginVO adminLoginVO = repository.getAdminDetailsById(id);        Assertions.assertNull(adminLoginVO);    }    private void testSave() {        AdminLoginVO adminLoginVO = new AdminLoginVO();        adminLoginVO.setId(2L);        adminLoginVO.setUsername("codeliu");        adminLoginVO.setPassword("123456");        repository.save(adminLoginVO);    }}

 运行第一个方法，先存储，后查找：

控制器输出我们存入的数据，看看Redis客户端有没有数据：

可以看到室友层级的key，这种key的命名方式我们在上面已经讲过，有利于数据分层，便于观察。

让Redis在业务中体现调用逻辑

业务逻辑思考

下面，我们结合接口的调用来做个修改，在接口的调用过程中，我们去使用Redis。我们打开IAdminService类，在里面添加一个新的方法：

    AdminLoginVO getAdminDetailsById(Long id);

接着打开AdminServiceImpl类，在里面实现接口方法：

    @Override    public AdminLoginVO getAdminDetailsById(Long id) {        //         ===== 以下是原有代码，只从数据库中获取数据 =====//        AdminLoginVO adminLoginVO = adminMapper.getLoginInfoByUserId(id);//         if (adminLoginVO == null) {//             throw new CloudServiceException(ResponseCode.ERR_INTERNAL_SERVER_ERROR,//                     "获取用户信息失败，尝试访问的数据不存在！");//         }//         return adminLoginVO;        // ===== 以下是新的业务，将从Redis中获取数据 =====        // 从repsotiroy中调用方法，根据id获取缓存的数据        // 判断缓存中是否存在与此id对应的key        // 有：表示明确的存入过某数据，此数据可能是有效数据，也可能是null        // -- 判断此key对应的数据是否为null        // -- 是：表示明确的存入了null值，则此id对应的数据确实不存在，则抛出异常        // -- 否：表示明确的存入了有效数据，则返回此数据即可        // 无：表示从未向缓存中写入此id对应的数据，在数据库中，此id可能存在数据，也可能不存在        // 从mapper中调用方法，根据id获取数据库的数据        // 判断从数据库中获取的结果是否为null        // 是：数据库也没有此数据，先向缓存中写入错误数据（null），再抛出异常        // 将从数据库中查询到的结果存入到缓存中        // 返回查询结果        return null;    }

大家看看实现的逻辑，这个很重要。

看完后，为了保证项目能运行，我们还有两步需要做。

添加调用SQL的方法

AdminMapper添加如下方法：

    AdminLoginVO getLoginInfoByUserId(Long id);

添加SQL

AdminMapper.xml添加如下SQL：

    select        from admin    left join admin_role    on admin.id = admin_role.admin_id    left join role_permission    on admin_role.role_id = role_permission.role_id    left join permission    on role_permission.permission_id = permission.id    where id=#{id}   
避免缓存穿透
 
在IPassportRedisRepository接口中添加如下方法：
 
        boolean exists(Long id);        void saveEmptyValue(Long id);
 
在PassportRedisRepositoryImpl类中添加实现方法如下：
 
    @Override    public boolean exists(Long id) {        String key = KEY_ADMIN_ITEM_PREFIX + id;        return redisTemplate.hasKey(key);    }    @Override    public void saveEmptyValue(Long id) {        String key = KEY_ADMIN_ITEM_PREFIX + id;        redisTemplate.opsForValue().set(key, null);    }
 
其实我们在上面说过，这种设置null的方法能一定程度上防止缓存反复穿透，但却并不是最好的解决办法，常规做法应该是通过布隆过滤器来做。
 
业务实现
 
    @Override    public AdminLoginVO getAdminDetailsById(Long id) {//         ===== 以下是原有代码，只从数据库中获取数据 =====//        AdminLoginVO adminLoginVO = adminMapper.getLoginInfoByUserId(id);//         if (adminLoginVO == null) {//             throw new CloudServiceException(ResponseCode.ERR_INTERNAL_SERVER_ERROR,//                     "获取用户信息失败，尝试访问的数据不存在！");//         }//         return adminLoginVO;// ===== 以下是新的业务，将从Redis中获取数据 =====        log.debug("根据id（{}）获取用户详情……", id);        // 从repository中调用方法，根据id获取缓存的数据        // 判断缓存中是否存在与此id对应的key        boolean exists = redisRepository.exists(id);        if (exists) {            // 有：表示明确的存入过某数据，此数据可能是有效数据，也可能是null            // -- 判断此key对应的数据是否为null            AdminLoginVO cacheResult = redisRepository.getAdminDetailsById(id);            if (cacheResult == null) {                // -- 是：表示明确的存入了null值，则此id对应的数据确实不存在，则抛出异常                log.warn("在缓存中存在此id（）对应的Key，却是null值，则抛出异常", id);                throw new CloudServiceException(ResponseCode.ERR_INTERNAL_SERVER_ERROR,                        "获取用户详情失败，尝试访问的数据不存在！");            } else {                // -- 否：表示明确的存入了有效数据，则返回此数据即可                return cacheResult;            }        }        // 缓存中没有此id匹配的数据        // 从mapper中调用方法，根据id获取数据库的数据        log.debug("没有命中缓存，则从数据库查询数据……");        AdminLoginVO dbResult = adminMapper.getAdminInfoByUserId(id);        // 判断从数据库中获取的结果是否为null        if (dbResult == null) {            // 是：数据库也没有此数据，先向缓存中写入错误数据，再抛出异常            log.warn("数据库中也无此数据（id={}），先向缓存中写入错误数据", id);            redisRepository.saveEmptyValue(id);            log.warn("抛出异常");            throw new CloudServiceException(ResponseCode.ERR_INTERNAL_SERVER_ERROR,                    "获取用户信息失败，尝试访问的数据不存在！");        }        // 将从数据库中查询到的结果存入到缓存中        log.debug("已经从数据库查询到匹配的数据，将数据存入缓存……");        redisRepository.save(dbResult);        // 返回查询结果        log.debug("返回查询到数据：{}", dbResult);        return dbResult;    }
 
到这里，基于业务调用的Redis业务调用流程代码就结束了，你可以在controller中添加新的方法来调用此接口完成测试，博主不再写了。
 
但此时还有一个问题，我们不能让每次数据查询的时候再去存Redis，否则第一次查询的时候Redis是空的。基于此，我们需要在系统启动时就把数据存入Redis中，此法叫做缓存预热。
 
缓存预热
 
创建预热类
 
缓存预热需要确定哪些数据在系统启动时就存入数据，我们在Spring Boot内自定义一个组件，他需要实现实现ApplicationRunner，我们和启动类平级建一个这样的类，名字叫CachePreLoad:
 
package com.codingfire.cloud.passport;import org.springframework.boot.ApplicationArguments;import org.springframework.boot.ApplicationRunner;public class CachePreLoad implements ApplicationRunner {    @Override    public void run(ApplicationArguments args) throws Exception {        System.out.println("CachePreLoad.run()");    }}
 
此类用于启动项目时提前预热资源，run方法是重写的启动类方法，启动时此方法会被调用，可在这里写存储Redis相关的内容。
 
但却不可将业务实现直接写在这个类中，为了项目代码整体的一致性，我们还将预热的业务以接口和实现的形式写在Redis单独的Repository组件内。
 
在写之前，为了防止童鞋们迷惑，博主需要解释一个问题，我个人也感觉使用用户模块做Redis不太恰当，应该是使用店铺列表，商品列表，品牌列表这样不太会变的数据做Redis，考虑到再加入新的表增加大家学习难度，所以才在用户表上面做文章，好在这个用户表也很简单，大家在真实场景中可以根据这里的代码转嫁到其他的业务下即可，万不可钻牛角尖。此处数据只做案例讲解使用，并非真实使用场景，但代码绝对是业务级别的。下面，我们来在Redis组件中增加预热的代码。
 
添加Redis操作接口
 
在IPassportRedisRepository接口中增加以下接口：
 
        String KEY_ADMIN_LIST = "admins:list";        void save(List admins);        void deleteAllItem();        Boolean deleteList();
 
实现Redis操作接口
 
接口增加完了，实现类报错，需要实现新增加的方法：
 
    @Override    public void save(List admins) {        for (AdminLoginVO admin : admins) {            redisTemplate.opsForList().rightPush(KEY_ADMIN_LIST, admin);        }    }    @Override    public void deleteAllItem() {        Set keys = redisTemplate.keys(KEY_ADMIN_ITEM_PREFIX + "*");        redisTemplate.delete(keys);    }    @Override    public Boolean deleteList() {        return redisTemplate.delete(KEY_ADMIN_LIST);    }
 
添加调用SQL方法
 
在IAdminMapper接口中增加方法：
 
    @Select("select * from admin")    List list();
 
由于比较简单，就把SQL直接写在注解里来。
 
添加预热调用接口
 
在IAdminService接口中增加预热方法：
 
    void preloadCache();
 
实现预热方法
 
在AdminServiceImpl实现类中实现上面的接口方法：
 
    @Override    public void preloadCache() {        log.debug("删除缓存中的用户列表……");        redisRepository.deleteList();        log.debug("删除缓存中的各独立的用户数据……");        redisRepository.deleteAllItem();        log.debug("从数据库查询用户列表……");        List list = adminMapper.list();        for (AdminLoginVO admin : list) {            log.debug("查询结果：{}", admin);            log.debug("将当前用户存入到Redis：{}", admin);            redisRepository.save(admin);        }        log.debug("将用户列表写入到Redis……");        redisRepository.save(list);        log.debug("将用户列表写入到Redis完成！");    }
 
启动时预热类调用预热方法 
 
最后一步，在预热缓存类中调用此预热方法：
 
package com.codingfire.cloud.passport;import com.codingfire.cloud.passport.service.IAdminService;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.ApplicationArguments;import org.springframework.boot.ApplicationRunner;import org.springframework.stereotype.Component;@Component@Slf4jpublic class CachePreLoad implements ApplicationRunner {    @Autowired    private IAdminService adminService;    @Override    public void run(ApplicationArguments args) throws Exception {        System.out.println("CachePreLoad.run()");        log.debug("准备执行缓存预热……");        adminService.preloadCache();        log.debug("缓存预热完成！");    }}
 
测试缓存预热
 
其实这一步测试是最简单的，我们什么都不需要做，直接启动项目就可以，项目启动后，我们在控制台会看到预热方法运行的输出：
 
 
 下面是启动前，Redis客户端内的参数列表：
 
 
 下面是项目启动后，Redis客户端内的参数列表：
 
 
 到这一步，若果你的测试结果和博主一样，那么恭喜你，你已经完成了Redis的基本学习，赶快到自己的项目中使用吧。
 
结语
 
Redis学习到这里就结束了，美中不足是少了布隆过滤器对Redis做的一个防止缓存穿透的操作，建议大家可以自己写写，后期博主会做个补充，建议大家不要等，自己动动手，也不算难。总体上，Redis整体上还算是比较简单的，用过几次其实就熟练了，很多东西都是调用API，再配合我们的业务逻辑来写。行吧，结语也不知道该写点啥，就是跟大家诉诉苦，太累了，坐的腰酸背疼，熬夜熬的眼疼，觉得写的不错，三连支持一下。
 
来源地址：https://blog.csdn.net/CodingFire/article/details/129351516


--结束END--
 本文标题: Java开发 - Redis初体验
 本文链接: https://lsjlt.com/news/399925.html(转载时请注明来源链接)
有问题或投稿请发送至:
邮箱/279061341@qq.com    QQ/279061341






猜你喜欢







Java开发 - Redis初体验
 
前言 es我们已经在前文中有所了解，和es有相似功能的是Redis，他们都不是纯粹的数据库。两者使用场景也是存在一定的差异的，本文目的并不重点说明他们之间的差异，但会简要说明，重点还是在对Redis的了解和学习上。学完本篇，你将了解Redi...

 




99+
2023-09-08

redis
数据库
redis实战
缓存预热
微服务








Java开发 - SpringCache初体验
 
前言 早些时候，博主介绍过Redis的使用：Java开发 - Redis初体验，Redie是基于缓存的一项技术，对于Redis，博主此处不再赘述，不了解的可以去看这篇文章，但Redis缓存并不是顶峰，本文要讲的内容就是Redis的辅助工具：...

 




99+
2023-09-05

Redis
SpringCache
缓存
CacheManager
Cacheable








Java开发 - Elasticsearch初体验
 
目录 前言 什么是es？ 为什么要使用es？ es查询的原理？ es需要准备什么？  es基本用法 创建工程 添加依赖 创建操作es的文件 使用ik分词插件 Spring Data 项目中引入Spring Data 添加依赖 添加配置 创建...

 




99+
2023-09-05

elasticsearch
大数据
搜索引擎
es
微服务








Java开发 - Quartz初体验
 
目录​​​​​​​ 前言 Quartz 什么是Quartz Quartz作用 Quartz结构 表达式 案例 Quartz实战 添加依赖 创建Job类 创建配置类 测试代码 扩展练习 结语   前言 在上一篇博客中，我们对单点登录有了初步了...

 




99+
2023-09-07

Quart
任务调度
scheduling
Job
JobDetail








Redis初体验
 

                Redis是一个速度非常快的非关系型数据库，它不仅性能强劲，而且还具有复制特性以及为解决问题而生的独一无二的数据模型。作为键值型数据库，Redis支持5中数据类型：字符串，列表，集合，Hash散列和有序集合...

 




99+
2024-04-02









Java开发 - 消息队列之RabbitMQ初体验
 
目录  前言 RabbitMQ 什么是RabbitMQ RabbitMQ特点 安装启动 RabbitMQ和Kafka的消息收发区别 RabbitMQ使用案例 添加依赖 添加配置 创建RabbitMQ配置类 RabbitMQ消息的发送 Rab...

 




99+
2023-09-16

java-rabbitmq
rabbitmq
java
消息队列
交换机








Windows Phone开发工具初体验
 

                        
                            Windows Phone开发工具是一套用于开发Windows Phone应用程序的集成开发环境。以下是我对该工具的初步体验：1. ...

 




99+
2023-09-08

Windows








Java开发 - 单点登录初体验（Spring Security + JWT）
 
目录​​​​​​​ 前言 为什么要登录 登录的种类 Cookie-Session Cookie-Session-local storage JWT令牌 几种登陆总结  用户身份认证与授权 创建工程 添加依赖 启动项目 Bcrypt算法的工具...

 




99+
2023-09-02

登录
JWT
Spring
Security
Token
Java登录








在Vue3中使用BabylonJs开发 3D的初体验
 

                            目录开始安装 Vue3安装 BabylonJs创建 Vue 组件: BabylonOne.vue创建 Babylon 类渲染场景修改 CSS 并添加相机和灯光结尾随着前端的发展，在 ...

 




99+
2024-04-02









TiDB 初体验
 

                
		
	...

 




99+
2024-04-02









IronPython初体验
 

介绍
在 C＃ 程序中嵌入 IronPython 得到了很好的支持。在本教程中，我们将展示如何完成这个项目。
首先，我们将展示两个非常基本的例子，说明如何执行一个不导入任何模块的非常简单的脚本。然后，再展示如何执行使用模块的脚本。
在 C...

 




99+
2023-01-30

初体验
IronPython








Python 初体验
 

广告：欢迎大家到 路飞学城 学习 Python～
很喜欢 Python “薪”时代 这个词～所以我们要拥抱 “人工智能”～拥抱 “Python～”
前提：下载 Python，如果是 Mac 电脑会自带 Python。
Hello Worl...

 




99+
2023-01-31

初体验
Python








JetBrainsFleet初体验
 

                            几天前获得了fleet的体验资格。长话短说，今天就来和你一起看看现在的fleet都有啥
先看名字–fleet
什么是fleet？
n. 舰队;捕鱼船队;(一国的)全部军舰，海军
看来...

 




99+
2024-04-02









初步体验Oracle
 

    Oracle 与Mysql 对比：
MySQL: 免费；小型企业；仅是数据库；轻
Oracle：收费， 中大型企业；数据库服务（权限，并发，事务，一致性）；更适合集群；重
共同点：都属于关系型数据库 RDBMS
 
非关系型数据库...

 




99+
2014-05-25

初步体验Oracle








Service Mesh 初体验
 
前言计算机软件技术发展到现在，软件架构的演进无不朝着让开发者能够更加轻松快捷地构建大型复杂应用的方向发展。容器技术最初是为了解决运行环境的不一致问题而产生的，随着不断地发展，围绕容器技术衍生出来越来越多的新方向。最近几年，云计算领域不断地出...

 




99+
2023-06-05









Egret3D之初体验
 

Ⅰ,Egret3D官方文档 : https://developer.egret.com/cn/docs/3d/docs/guide/getting-started-introduction/
Ⅱ,安装3D编辑器(以前叫paper , 现在...

 




99+
2023-01-31

之初
Egret3D








java Spring Boot的介绍与初体验
 

                            目录Spring Boot 介绍系统要求构建工具Servlet 容器初体验总结Spring Boot 介绍
Spring Boot用于创建可运行的、独立的、生产级的基于Spring的...

 




99+
2024-04-02









nodejs初步体验篇
 

                前言：写这篇文章的由来：
　　1.前段时间单位有新项目启动，服务端要做的工作不多也不算麻烦，就是处理一些中间层的服务，而且我们团队里面个个都会JavaScript，领导就决定试试服务器端的JavaScrip...

 




99+
2022-06-04

nodejs








springcloud初体验(真香)
 

                            一、微服务简介 

Ⅰ、我对微服务的理解

微服务是软件开发的一种架构方式，由单一的应用小程序构成的小服务；一个软件系统由多个服务组成；在微服务中，服务是细粒度的，协议是轻量级的(部...

 




99+
2024-04-02









Oracle 18c安装初体验
 

                
Oracle 18c在万众期待下终于开放下载了，目前提供Linux x86-64、Solaris（SPARC）、Solaris（x86-64）三个平台的下载：






安装包也是水涨船高，Linux版...

 




99+
2024-04-02














软考高级职称资格查询








热门wiki










mysql删除数据恢复

mysql删表能回滚吗

mysql找回删除的表

mysql不小心删除了表

mysql不小心把表删了怎么恢复数据

mysql数据表删除后能恢复么

mysql误删表数据恢复

mysql误删表恢复

mysql删除表怎么恢复

mysql删除表











近期文章










开源文档预览项目 kkFileView (9.9k star) ，快速入门

如何掌握人工智能的未知领域？

如何深入钻研数据库管理的复杂世界？

如何在 Web 开发中巧妙地使用缓存？

如何驯服并发编程的野兽？

如何破解算法设计的迷宫？

如何应对 C++ 中的指针管理挑战？

如何理解 Java 中垃圾回收的奥秘？

如何克服 Python 中的内存泄漏陷阱？

如何解决 JavaScript 中的异步难题？











推荐阅读











如何掌握人工智能的未知领域？

2024-04-01







如何深入钻研数据库管理的复杂世界？

2024-04-03







如何处理用户的会话管理知识点问题？

2024-04-03







AVL树（Java）

2024-01-21







身为Java“搬砖”程序员，你掌握了多线程吗？

2024-01-21







【网络安全必备 | 前端开发基础】一篇文章速学 JavaScript

2024-01-21







Java医院智能3D导诊系统源码 微信小程序源码

2024-01-21







《面试专题-----经典高频面试题收集一》解锁 Java 面试的关键：深度解析常见高频经典面试题（第一篇）

2024-01-21







JDK8和JDK17安装切换，IDEA配置多个版本JDK

2023-12-23







⑩【Redis Java客户端】：Jedis、SpringDataRedis、StringRedisTemplate

2023-12-23
















热门问答













1
回答

如何调试操作系统的错误？
操作系统




2023-11-15发布






1
回答

操作系统中的I/O系统是如何实现的？
操作系统




2023-11-15发布






1
回答

如何实现操作系统的内存管理？
操作系统




2023-11-15发布






1
回答

什么是虚拟内存，它对操作系统有什么影响？
操作系统




2023-11-15发布






1
回答

ASP中的MVC架构和WebForms架构有什么区别和使用场景？
ASP.NET




2023-11-15发布






1
回答

ASP中的数据验证和数据校验有什么不同？
ASP.NET




2023-11-15发布






1
回答

ASP中的ADO对象和DAO对象有什么区别和使用方法？
ASP.NET




2023-11-15发布






1
回答

Node.js中的包管理器NPM是什么？如何使用它进行依赖管理？
node.js




2023-11-15发布






1
回答

Vue.js中的动态组件是什么？如何使用它来动态渲染组件？
VUE




2023-11-15发布






1
回答

如何使用Vue.js实现懒加载和预加载？
VUE




2023-11-15发布













热门标签





Python操作PostgreSQL
Python连接PostgreSQL
Python连接和操作PostgreSQL
SQL建表语句
SQL建表语句使用
RedisTemplate使用
MySQL提取数据
JSON提取数据
MySQL从JSON提取数据
MySQL免密登录
MySQL免密登录配置
Oracle端口
Oracle修改端口
Oracle更换端口
Oracle更换监听端口
HBASE部署
HBASE集群部署
oracle中的trunc函数
oracle中trunc
winx64安装
格式化yyyy-mm-dd
mysql时间戳格式化yyyy-mm-dd
mysql8.0.15重置密码
mysql8.0.15修改密码
2059
Navicat连接MySQL出现2059
DBeaver导入数据
DBeaver导入excel大量数据
DBeaver导入excel数据
dbeaver导出











        

            

                

                    

                    
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。
                    
                
                

                    

                        

                            
前端
                            
后端
                            
数据库
                            
服务器
                            
操作系统
                            

                        
                    
                    

                        

                            
商务合作：279061341@qq.com
                            
网站地图
                            
投稿合作：279061341@qq.com
                            
标签大全
                            
虚位以待
                        
                    
                
                

                    

                        

                            

                            
官方手机版
                        
                        

                            

                            
微信公众号
                        
                        

                            

                            
商务合作
                        
                        

                    
                
                

            
        
        

            

                

                    

                        

                            Powered by
                            编程网
                            |
                            Copyright © 2018-2023, 版权所有.
                            |
网站地图 |
苏ICP备17033115号 
                        
                    
                
                

            
        
    
    

    

        返回顶部