SpringBoot学习（七）——springboot快速整合Redis-成都创新互联网站建设

成都创新互联网站制作

028-86922220

关于创新互联

多方位宣传企业产品与服务 突出企业形象

公司简介 公司的服务 荣誉资质 新闻动态 联系我们

SpringBoot学习（七）——springboot快速整合Redis

redis缓存

@[toc]

创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都网站制作、网站建设、峡江网络推广、成都微信小程序、峡江网络营销、峡江企业策划、峡江品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供峡江建站搭建服务，24小时服务热线：13518219792，官方网址：www.cdcxhl.com

创新互联专业为企业提供延边朝鲜族网站建设、延边朝鲜族做网站、延边朝鲜族网站设计、延边朝鲜族网站制作等企业网站建设、网页设计与制作、延边朝鲜族企业网站模板建站服务，十载延边朝鲜族做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。

市中网站制作公司哪家好，找创新互联！从网页设计、网站建设、微信开发、APP开发、成都响应式网站建设公司等网站项目制作，到程序开发，运营维护。创新互联从2013年成立到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联。

成都创新互联公司是一家专注于成都网站建设、网站建设与策划设计,泰和网站建设哪家好?成都创新互联公司做网站,专注于网站建设十年,网设计领域的专业建站公司;建站业务涵盖:泰和等地区。泰和做网站价格咨询:13518219792

创新互联2013年开创至今，先为新市等服务建站，新市等地企业，进行企业商务咨询服务。为新市企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

创新互联专注于中大型企业的网站制作、成都网站制作和网站改版、网站营销服务，追求商业策划与数据分析、创意艺术与技术开发的融合，累计客户上千多家，服务满意度达97%。帮助广大客户顺利对接上互联网浪潮，准确优选出符合自己需要的互联网运用，我们将一直专注品牌网站建设和互联网程序开发，在前进的路上，与客户一起成长！

简介

redis是一个高性能的key-value数据库

优势

  • 性能强，适合高度的读写操作（读的速度是110000次/s,写的速度是81000次/s ）。

  • 支持较为丰富的数据类型（如二进制的Strings, Lists, Hashes, Sets ,Ordered Sets）

  • 一定的事物能力（要么执行成功要么完全不执行）。
劣势
  • 内存数据库访问快，但也消耗硬件内存资源

注：redis的单线程仅仅是说在网络请求这一模块上用一个请求处理客户端的请求，但比如说持久化它就会重开一个线程/进程去进行处理。

引入redis缓存

点击链接 下载 redis 的 window 版，下载好后，放入你平时放软件的位置，解压出来即安装完成。（需要注意的是放入的文件目录，当前用户要是可读可写的权限，比如window下的C:\Program Files (x86)，这个目录默认只有管理员权限才能读写，redis运行时要在该目录下实时写入日志文件的，若无权限读写，则会操作不成功）

SpringBoot学习（七）—— springboot快速整合Redis

解压出来的目录如下所示，因为是Windows端的，可双击exe文件开启客户端，服务端。

SpringBoot学习（七）—— springboot快速整合Redis

因为这是 springboot 整合 redis 系列，所以双击打开服务端即可，别关闭打开的 cmd 窗口。
SpringBoot学习（七）—— springboot快速整合Redis

在pom.xml中加入


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

在application.properties中添加

# Redis
#Redis服务器地址
spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码（默认为空）
spring.redis.password=
#Redis数据库索引（默认为0）
spring.redis.database=0  
#连接池最大连接数（使用负值表示没有限制）
spring.redis.jedis.pool.max-active=50
#连接池最大阻塞等待时间（使用负值表示没有限制）
spring.redis.jedis.pool.max-wait=3000
#连接池中的最大空闲连接
spring.redis.jedis.pool.max-idle=20
#连接池中的最小空闲连接
spring.redis.jedis.pool.min-idle=5
#连接超时时间（毫秒）
spring.redis.timeout=4000

代码实战

新增代码后的目录如下所示

SpringBoot学习（七）—— springboot快速整合Redis

这里先说明一下主要类的作用，Springboot 提供了 RedisTemplate 类来操作 Redis，但是该类既无注释解释，命名规律也不够 “望文生义” 。 所以写了个 RedisUtil 来封装一些常用的方法， RedisConfig 主要是将默认的自动注入改为手动注入并加入序列化，避免一些中文乱码问题。

这里特别说一说 RedisUtil 类，搜索 springboot 和 redis 的文章，这个需要自己封装的类网上大多写的非常混乱，而且前后的封装逻辑不一致， 我估计是某位博主从至少三个人那里复制粘贴糅合起来的，然后大家都跟着这位博主复制粘贴，反而成了热门文章。我猜测大家看它是个工具类，而且六百行左右，大多没有仔细琢磨，能简单测试通过即可，但是稍加思考，发现问题真的不少，很容易误导那些喜欢 “拿来主义” 的 “萌新” 。

虽然我这个系列也是快速上手系列，但我理解的快速上手，就是把让人云里雾里的概念讲直白，然后先暂时跳过那些需要深入的，避免刚入手的畏难情绪，把整个操作流程写的清楚明白，给别人讲一千遍道一万句，不如让他对着现成的程序跑一遍，我一直认为：对着一片空白的屏幕学习程序，只会让人愈加焦虑，最好的办法是一边运行，一边深入。

所以我选取了 redis 五大类型中的String，Hash，Set，List，几乎覆盖每个类型，而 SortedSet 没有选取是因为这是有序的Set，可以自己类比。工具类我统一提供的是取值，添加值，删除值，命名规律绝对可以让你 “望文生义” ，其实还有很多方法，这里我不全写出来，是因为五大数据类型都有一堆方法，你不一定用得上，而且很占篇幅，在这里，授人以鱼不如授人以渔，你仔细看看 RedisUtil 的工具类，就会发现规律，比如操作String，大多是先调用opsForValue()方法，操作Hash，大多先调用opsForHash()方法，把项目代码下载到本地，idea里面点进去，就能看到相关的一堆方法。工具类只是重新调用了，换了个名字，加了些逻辑处理。

别看是热门文章就盲从，我举几个刚才说的问题，

SpringBoot学习（七）—— springboot快速整合Redis

SpringBoot学习（七）—— springboot快速整合Redis
还有这个的注释说明风格也不统一，给人的感觉看着容易云里雾里的，网上的工具类还用的都是这一个，真的是哭笑不得，大家抄来抄去，都是方案整合商，就不要……

下面开始代码示范

RedisController.java

package com.example.controller;

import com.example.service.IRedisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

@Controller
@RequestMapping("redis")
public class RedisController {

    @Autowired
    private IRedisService redisService;

    @RequestMapping("/redisString")
    public void redisString() {
        this.redisService.redisString();
    }

    @RequestMapping("/redisHash")
    public void redisHash() {
        this.redisService.redisHash();
    }

    @RequestMapping("/redisSet")
    public void redisSet() {
        this.redisService.redisSet();
    }

    @RequestMapping("/redisList")
    public void redisList() {
        this.redisService.redisList();
    }

    @RequestMapping("/redisSortedSet")
    public void redisSortedSet() {
        //有序的set，故而省略
    }

}

IRedisService.java

package com.example.service;

public interface IRedisService {

    void redisString();

    void redisHash();

    void redisSet();

    void redisList();

    void redisSortedSet();

}

RedisServiceIml.java

package com.example.service;

import com.example.util.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;
import java.util.Set;

@Service("redisService")
public class RedisServiceIml implements IRedisService {
    @Autowired
    private RedisTemplate redisTemplate;

    @Resource
    private RedisUtil redisUtil;

    public void redisString() {
        //添加值
        redisUtil.stringSet("AAA", "这是一个String类型的值");
        //取值
        Object value = redisUtil.stringGet("AAA");
        System.out.println(value);
    }

    public void redisHash() {
        //添加值
        redisUtil.hashSet("BBB", "test1", "原hash值1");
        redisUtil.hashSet("BBB", "test2", "新hash值1");
        redisUtil.hashSet("BBB", "test1", "原hash值2");
        redisUtil.hashSet("BBB", "test2", "新hash值2");
        //取值
        Object value1 = redisUtil.hashGet("BBB", "test1");
        Object value2 = redisUtil.hashGet("BBB", "test2");
        System.out.println(value1);
        System.out.println(value2);
    }

    public void redisSet() {
        //添值
        redisUtil.setSet("CCC", "这是一组Set集合的第一个");
        redisUtil.setSet("CCC", "这是一组Set集合的第二个");
        redisUtil.setSet("CCC", "这是一组Set集合的第三个");
        //取值
        Set vaule = redisUtil.setGet("CCC");
        System.out.println(vaule);
    }

    public void redisList() {
        //添加值
        redisUtil.listSet("DDD", "这是一组List集合的第一个");
        redisUtil.listSet("DDD", "这是一组List集合的第二个");
        redisUtil.listSet("DDD", "这是一组List集合的第三个");
        //取值
        List list = redisUtil.listGet("DDD", 0, -1);
        System.out.println(list);
    }

    public void redisSortedSet() {
        //有序的set，故而省略
    }

}

RedisConfig.java

package com.example.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
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.*;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory factory) {

        RedisTemplate template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);

        //序列化和反序列化redis中的值
        Jackson2JsonRedisSerializer jackson = new Jackson2JsonRedisSerializer(Object.class);
        //Java对象转换成JSON结构
        ObjectMapper objectMapper = new ObjectMapper();
        // 指定要序列化的域
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson.setObjectMapper(objectMapper);

        // 值采用json序列化
        template.setValueSerializer(jackson);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());

        // 设置hash key和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jackson);
        template.afterPropertiesSet();

        return template;
    }

}

RedisUtil.java

package com.example.util;

import java.util.List;
import java.util.Set;
import java.util.concurrent.TimeUnit;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

@Component
public class RedisUtil {

    @Autowired
    private RedisTemplate redisTemplate;

    //===============缓存相关方法===============

    //指定缓存失效时间
    public boolean expire(String key, long time) {
        try {
            if (time > 0) {
                redisTemplate.expire(key, time, TimeUnit.SECONDS);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //根据key获取过期时间,返回0代表为永久有效
    public long getExpire(String key) {
        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
    }

    //===============数据类型为String的相关方法===============

    //根据key值获取缓存值
    public Object stringGet(String key) {
        return key == null ? null : redisTemplate.opsForValue().get(key);
    }

    //根据key值存入数据类型为String的缓存值
    public boolean stringSet(String key, Object value) {
        try {
            redisTemplate.opsForValue().set(key, value);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //根据key值存入数据类型为String的缓存值并设置时间
    public boolean stringSetWithTime(String key, Object value, long time) {
        try {
            if (time > 0) {
                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
            } else {
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //删除缓存
    public void stringDelete(String... key) {
        if (key != null && key.length > 0) {
            if (key.length == 1) {
                redisTemplate.delete(key[0]);
            } else {
                redisTemplate.delete(CollectionUtils.arrayToList(key));
            }
        }
    }

    //===============数据类型为Hash的相关方法===============

    //根据key和item获取缓存值
    public Object hashGet(String key, String item) {
        return redisTemplate.opsForHash().get(key, item);
    }

    //根据key和item存入数据类型为Hash的缓存值
    public boolean hashSet(String key, String item, Object value) {
        try {
            redisTemplate.opsForHash().put(key, item, value);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //根据key和item存入数据类型为Hash的缓存值并设置时间
    public boolean hashSetWithTime(String key, String item, Object value, long time) {
        try {
            redisTemplate.opsForHash().put(key, item, value);
            if (time > 0) {
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //删除缓存
    public void hashDelete(String key, Object... item) {
        redisTemplate.opsForHash().delete(key, item);
    }

    //===============数据类型为SET的相关方法===============

    //根据key值获取缓存值
    public Set setGet(String key) {
        try {
            return redisTemplate.opsForSet().members(key);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    //根据key值存入数据类型为SET的缓存值
    public long setSet(String key, Object... values) {
        try {
            return redisTemplate.opsForSet().add(key, values);
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }

    //根据key值存入数据类型为SET的缓存值并设置时间
    public long setSetWithTime(String key, long time, Object... values) {
        try {
            Long count = redisTemplate.opsForSet().add(key, values);
            if (time > 0) {
                expire(key, time);
            }
            return count;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }

    //删除缓存
    public long setDelete(String key, Object... values) {
        try {
            Long count = redisTemplate.opsForSet().remove(key, values);
            return count;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }

    //===============数据类型为LIST的相关方法===============
    //获取List缓存的内容，从start到end，若从0到-1代表所有值
    public List listGet(String key, long start, long end) {
        try {
            return redisTemplate.opsForList().range(key, start, end);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    //根据key值存入数据类型为List的缓存值
    public boolean listSet(String key, Object value) {
        try {
            redisTemplate.opsForList().rightPush(key, value);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //根据key值存入数据类型为List的缓存值并设置时间
    public boolean listSetWithTime(String key, Object value, long time) {
        try {
            redisTemplate.opsForList().rightPush(key, value);
            if (time > 0) {
                expire(key, time);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    //删除缓存
    public long listDelete(String key, long count, Object value) {
        try {
            Long remove = redisTemplate.opsForList().remove(key, count, value);
            return remove;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }

}
启动项目后，浏览器输入  http://localhost:8080/redis/redisString ，（前台会报错，是因为这个请求只是触发后台的业务逻辑，没有前台页面展示）操作 String 类型的效果图如下所示；
SpringBoot学习（七）—— springboot快速整合Redis
启动项目后，浏览器输入  http://localhost:8080/redis/redisHash ，操作 Hash 类型的效果图如下所示；（注意一下，我之前代码写的是插入了四个值，只打印出来两个，是因为如果key值和item值一样，新来的值会覆盖原来的值，对比图和代码，你品，你细品。）
SpringBoot学习（七）—— springboot快速整合Redis
启动项目后，浏览器输入  http://localhost:8080/redis/redisSet ，操作 Set 类型的效果图如下所示；（Set是无序的）
SpringBoot学习（七）—— springboot快速整合Redis
启动项目后，浏览器输入  http://localhost:8080/redis/redisList ，操作 List 类型的效果图如下所示；
SpringBoot学习（七）—— springboot快速整合Redis
注：如果是根据本文系列文章来的，因为一开始就配置好了spring security，所以记得将该地址配给所登录的用户。或者开一个超级管理员账号，可以访问项目的任意目录，使用该管理员账号访问这些地址。
这是该学习系列的所有代码，如果有不明白的，想自己实操丰富其中内容的，可以下载到本地，
GitHub      ，         码云
            
            
                        

            网页题目：SpringBoot学习（七）——springboot快速整合Redis            

            当前路径：http://kswsj.cn/article/igchdp.html
        
    
    

        
其他资讯