Spring全家桶系列--SpringBoot入门Redis

首先,Redis是什么?


Redis是一个开源的,基于内存的键值数据存储,用作数据库,缓存和消息代理。在实现方面,Key-Value存储代表NoSQL空间中最大和最老的成员之一。Redis支持数据结构,如字符串,散列,列表,集和带范围查询的有序集。


在spring data redis的框架,可以很容易地编写,通过提供一个抽象的数据存储使用Redis的键值存储的Spring应用程序。 非关系型数据库,基于内存,存取数据的速度不是关系型数据库所能比拟的 redis是键值对(key-value)的数据库


有5中主要数据类型:


  • 字符串类型 string
  • 散列类型 hash
  • 列表类型 list
  • 集合类型 set
  • 有序集合类型 zset


redis缓存为啥速度快


这么说吧,别人问你什么是“redis”,如果你知道,你可以直接吧啦吧啦一大堆,其实这个时候你的大脑就类似redis缓存,别人问的“redis”就是key,你说出来的结果就是value,而你如果不知道,你就去上网查,然后再告诉别人,这就类似于查询数据库了,你查了再告诉别人当然慢了!


你把脑袋里的东西写进笔记就类似redis持久化保存了;


你过了两个月把这玩意忘了,就是redis的定期删除了;


引自:https://blog.csdn.net/angleflyyy/article/details/81627785


准备工作


项目工具环境:

  • IDEA 2018.2
  • Gradle 4+
  • JDK1.8以上
  • redis服务器


设置Redis服务器


redis下载地址:https://redis.io/download


如果你的电脑是Mac:

  1. brew install redis

然后运行redis服务器

  1. cuifuandeMacBook-Pro:~ cuifuan$ redis-server
  2. 25336:C 29 Nov 2018 14:53:42.490 # oO0OoO0OoO0Oo Redis is starting oO0OoO0OoO0Oo
  3. 25336:C 29 Nov 2018 14:53:42.490 # Redis version=5.0.2, bits=64, commit=00000000, modified=0, pid=25336, just started
  4. 25336:C 29 Nov 2018 14:53:42.490 # Warning: no config file specified, using the default config. In order to specify a config file use redis-server /path/to/redis.conf
  5. 25336:M 29 Nov 2018 14:53:42.491 * Increased maximum number of open files to 10032 (it was originally set to 256).
  6.                _._                                                  
  7.           _.-``__ ''-._                                            
  8.      _.-``    `.  `_.  ''-._           Redis 5.0.2 (00000000/0) 64 bit
  9.  .-`` .-```.  ```\/    _.,_ ''-._                                  
  10. (    '      ,       .-`  | `,    )     Running in standalone mode
  11. |`-._`-...-` __...-.``-._|'` _.-'|     Port: 6379
  12. |    `-._   `._    /     _.-'    |     PID: 25336
  13.  `-._    `-._  `-./  _.-'    _.-'                                  
  14. |`-._`-._    `-.__.-'    _.-'_.-'|                                  
  15. |    `-._`-._        _.-'_.-'    |           http://redis.io        
  16.  `-._    `-._`-.__.-'_.-'    _.-'                                  
  17. |`-._`-._    `-.__.-'    _.-'_.-'|                                  
  18. |    `-._`-._        _.-'_.-'    |                                  
  19.  `-._    `-._`-.__.-'_.-'    _.-'                                  
  20.      `-._    `-.__.-'    _.-'                                      
  21.          `-._        _.-'                                          
  22.              `-.__.-'                                              

  23. 25336:M 29 Nov 2018 14:53:42.492 # Server initialized
  24. 25336:M 29 Nov 2018 14:53:42.492 * Ready to accept connections


初始化项目


始界面初始化一个项目


Spring全家桶系列--SpringBoot入门Redis


这里选择的是Gradle,选择完成点击Generate Projrct生成项目,这个时候会自动下载一个压缩包给你,解压过后导入,导入IDEA教程:http://note.youdao.com/noteshare?id=74e2d65e2d22cd684c3fdd6695b3ecdf


Gradle 依赖管理


让我们在build.gradle中为我们正在构建的示例应用程序声明必要的依赖项

  1. buildscript {
  2.    repositories {
  3.        maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
  4.    }
  5.    dependencies {
  6.        classpath("org.springframework.boot:spring-boot-gradle-plugin:2.1.0.RELEASE")
  7.    }
  8. }

  9. apply plugin: 'java-library'
  10. apply plugin: 'org.springframework.boot'
  11. apply plugin: 'io.spring.dependency-management'

  12. group = 'com.example'
  13. version = '0.0.1-SNAPSHOT'
  14. sourceCompatibility = 1.8

  15. repositories {
  16.    maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
  17. }

  18. dependencies {
  19.    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
  20.    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
  21.    implementation 'org.springframework.boot:spring-boot-starter-web'
  22.    implementation 'mysql:mysql-connector-java'
  23.    implementation 'org.projectlombok:lombok'
  24.    implementation 'org.apache.commons:commons-pool2:2.4.2'
  25.    implementation 'com.alibaba:fastjson:1.2.51'
  26.    testImplementation 'org.springframework.boot:spring-boot-starter-test'
  27. }


开始使用


凭借着SpringBoot的开箱即用的特点,集成Redis也不例外


  • redisTemplate.opsForValue();//操作字符串
  • redisTemplate.opsForHash();//操作hash
  • redisTemplate.opsForList();//操作list
  • redisTemplate.opsForSet();//操作set
  • redisTemplate.opsForZSet();//操作有序set


Spring全家桶系列--SpringBoot入门Redis


在Spring的测试类中开始使用:


  1. redisTemplate.opsForValue().set("username","test");


执行过后发现存在redis中的数据:


Spring全家桶系列--SpringBoot入门Redis


是乱的,是因为在set后redis会序列化key和value,所以我们要在config中重写一下redisTemplate

src/main/java/com/example/springbootredisdemo/config/RedisConfig.java

  1. package com.example.springbootredisdemo.config;

  2. import org.springframework.beans.factory.annotation.Autowired;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.data.redis.core.RedisTemplate;
  6. import org.springframework.data.redis.serializer.GenericToStringSerializer;
  7. import org.springframework.data.redis.serializer.RedisSerializer;
  8. import org.springframework.data.redis.serializer.StringRedisSerializer;

  9. @Configuration
  10. public class RedisConfig {

  11.    private final RedisTemplate redisTemplate;

  12.    @Autowired
  13.    public RedisConfig(RedisTemplate redisTemplate) {
  14.        this.redisTemplate = redisTemplate;
  15.    }

  16.    @Bean
  17.    @SuppressWarnings("unchecked")
  18.    public RedisTemplate<String, Object> redisTemplate() {
  19.        RedisSerializer<String> stringSerializer = new StringRedisSerializer();
  20.        RedisSerializer<Object> jsonString = new GenericToStringSerializer<>(Object.class);
  21.        redisTemplate.setKeySerializer(stringSerializer);
  22.        redisTemplate.setValueSerializer(jsonString);
  23.        redisTemplate.setHashKeySerializer(stringSerializer);
  24.        redisTemplate.setHashValueSerializer(jsonString);
  25.        return redisTemplate;
  26.    }

  27. }


再去执行一下刚刚的方法


Spring全家桶系列--SpringBoot入门Redis


经过自定义的序列化之后可以了,没有乱码了

opsForList()添加操作
  1.    @Test
  2.    public void CsetListRedis(){
  3.        List<String> trap = new ArrayList<>();
  4.        trap.add("张三");
  5.        trap.add("张无忌");
  6.        trap.add("新垣结衣");
  7.        //循环向userlist左添加值
  8.        trap.forEach(value->redisTemplate.opsForList().leftPush("userlist",value));
  9.        //向userlist右添加值
  10.        redisTemplate.opsForList().rightPush("userlist","rightValue");
  11.        log.info("userlist->{}",redisTemplate.opsForList().range("userlist",0,10));
  12.    }


Spring全家桶系列--SpringBoot入门Redis


opsForList()删除操作
  1.    @Test
  2.    public void DlistRedisRemove(){
  3.        redisTemplate.opsForList().remove("userlist",0,"张无忌");
  4.    }


Spring全家桶系列--SpringBoot入门Redis


通过源码看这里有三个参数:

  • key 对应的是redis中存的key值
  • count 正数就是从左边开始删除 负数是从右面 例如-1就从右删除第一个值为value的,0代表删除全部值为value的
  • value 就是需要从list移除的值
opsForSet()添加操作

利用了set值的不可重复

  1.    @Test
  2.    public void CsetRedis(){
  3.        List<String> trap = new ArrayList<>();
  4.        trap.add("张三");
  5.        trap.add("里斯");
  6.        trap.add("里斯");
  7.        trap.add("张无忌");
  8.        trap.add("新垣结衣");
  9.        System.out.print(trap.toString());
  10.        //循环向userlist左添加值
  11.        trap.forEach(value->redisTemplate.opsForSet().add("userSet",value));
  12.        log.info("取出userSet->{}",redisTemplate.opsForSet().members("userSet"));
  13.    }


结果


Spring全家桶系列--SpringBoot入门Redis


符合了Set集合的无序和不可重复性

opsForSet()的删除操作

这个删除操作就比较容易了,直接根据set的key值,后面参数写其需要删除的value就可以

  1.    @Test
  2.    public void EsetRedisRemove(){
  3.        redisTemplate.opsForSet().remove("userSet","张无忌");
  4.    }

opsForHash()操作
  1.    //opsForHash()操作
  2.    @Test
  3.    public void FhashRedisAdd(){
  4.        //添加
  5.        redisTemplate.opsForHash().put("user","phone",10086);
  6.        redisTemplate.opsForHash().put("user","address","Shanghai");
  7.        redisTemplate.opsForHash().put("user","del","mubaba");
  8.        redisTemplate.opsForHash().put("user","dada","达达");
  9.        //修改
  10.        redisTemplate.opsForHash().put("user","address","Beijing");
  11.        //删除
  12.        redisTemplate.opsForHash().delete("user","del","dada");
  13.    }

结果


Spring全家桶系列--SpringBoot入门Redis


测试类SpringbootRedisDemoApplicationTests


src/test/java/com/example/springbootredisdemo/SpringbootRedisDemoApplicationTests.java


  1. package com.example.springbootredisdemo;

  2. import com.example.springbootredisdemo.service.NovelService;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.junit.FixMethodOrder;
  5. import org.junit.Test;
  6. import org.junit.runner.RunWith;
  7. import org.junit.runners.MethodSorters;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import org.springframework.data.redis.core.RedisTemplate;
  11. import org.springframework.test.context.junit4.SpringRunner;

  12. import java.util.ArrayList;
  13. import java.util.List;

  14. //根据测试方法名字搞定执行顺序
  15. @FixMethodOrder(MethodSorters.NAME_ASCENDING)
  16. @RunWith(SpringRunner.class)
  17. @SpringBootTest
  18. @Slf4j
  19. public class SpringbootRedisDemoApplicationTests {

  20.    @Autowired
  21.    private NovelService novelService;

  22.    @Autowired
  23.    private RedisTemplate<String,Object> redisTemplate;

  24.    private final static String KEY = "username";
  25.    private final static String VALUE = "test";


  26.    @Test
  27.    public void AstringRedis(){
  28.        redisTemplate.opsForValue().set(KEY,VALUE);
  29.        log.info("string set存储:{}->{}",KEY,VALUE);
  30.        redisTemplate.opsForValue().get(KEY);
  31.        log.info("string 根据{}取出{}",KEY,VALUE);
  32.    }

  33.    @Test
  34.    public void BlistRedis(){
  35.        List<String> trap = new ArrayList<>();
  36.        trap.add("张三");
  37.        trap.add("张三");
  38.        trap.add("张无忌");
  39.        trap.add("新垣结衣");
  40.        //循环向userlist左添加值
  41.        trap.forEach(value->redisTemplate.opsForList().leftPush("userlist",value));
  42. //        redisTemplate.opsForList().leftPushAll("userlist",trap);
  43.        //向userlist右添加值
  44.        redisTemplate.opsForList().rightPush("userlist","rightValue");
  45.        //取出userlist的值
  46.        log.info("userlist->{}",redisTemplate.opsForList().range("userlist",0,10));
  47.    }

  48.    @Test
  49.    public void CsetRedis(){
  50.        List<String> trap = new ArrayList<>();
  51.        trap.add("张三");
  52.        trap.add("里斯");
  53.        trap.add("里斯");
  54.        trap.add("张无忌");
  55.        trap.add("新垣结衣");
  56.        System.out.print(trap.toString());
  57.        //循环向userlist左添加值
  58.        trap.forEach(value->redisTemplate.opsForSet().add("userSet",value));
  59.        log.info("取出userSet->{}",redisTemplate.opsForSet().members("userSet"));
  60.    }

  61.    @Test
  62.    public void DlistRedisRemove(){
  63.        redisTemplate.opsForList().remove("userlist",0,"张无忌");
  64.    }


  65.    @Test
  66.    public void EsetRedisRemove(){
  67.        redisTemplate.opsForSet().remove("userSet","张无忌");
  68.    }

  69.    //opsForHash()操作
  70.    @Test
  71.    public void FhashRedisAdd(){
  72.        //添加
  73.        redisTemplate.opsForHash().put("user","phone",10086);
  74.        redisTemplate.opsForHash().put("user","address","Shanghai");
  75.        redisTemplate.opsForHash().put("user","del","mubaba");
  76.        redisTemplate.opsForHash().put("user","dada","达达");
  77.        //修改
  78.        redisTemplate.opsForHash().put("user","address","Beijing");
  79.        //删除
  80.        redisTemplate.opsForHash().delete("user","del","dada");
  81.    }
  82. }


小知识


方法名字前加ABCD...是为了让方法有执行顺序,根据测试方法名字搞定执行顺序,在方法上加注解 @FixMethodOrder(MethodSorters.NAME_ASCENDING)


日志注解@Slf4j是为了让日志书写更方便


  1. //之前写日志  
  2. log.info("输出a"+index+"b");
  3. //现在
  4. log.info("输出a{}b",index);


多个参数可以用多个{},总之,喜欢哪个用哪个,谢谢!


码云代码地址


https://gitee.com/cuifuan/SpringBoot


上一篇:深入剖析 Java 反序列化漏洞(下)


下一篇:SpringBoot整合RabbitMQ(二)单机抢票系统