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 29Nov201814:53:42.490# oO0OoO0OoO0Oo Redis is starting oO0OoO0OoO0Oo
   
3. 25336:C 29Nov201814:53:42.490# Redis version=5.0.2, bits=64, commit=00000000, modified=0, pid=25336, just started
   
4. 25336:C 29Nov201814: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 29Nov201814:53:42.491*Increased maximum number of open files to 10032(it was originally set to 256).
   
6.                _._                                                  
   
7.           _.-``__ ''-._                                            
   
8.      _.-``    `.  `_.  ''-._           Redis5.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. 
    
24. 25336:M 29Nov201814:53:42.492# Server initialized
    
25. 25336:M 29Nov201814:53:42.492*Ready to accept connections
    

初始化项目

始界面初始化一个项目

这里选择的是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. 
   
10. apply plugin:'java-library'
    
11. apply plugin:'org.springframework.boot'
    
12. apply plugin:'io.spring.dependency-management'
    
13. 
    
14. group='com.example'
    
15. version ='0.0.1-SNAPSHOT'
    
16. sourceCompatibility =1.8
    
17. 
    
18. repositories {
    
19.    maven { url 'http://maven.aliyun.com/nexus/content/groups/public/'}
    
20. }
    
21. 
    
22. dependencies {
    
23.    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
    
24.    implementation 'org.springframework.boot:spring-boot-starter-data-redis'
    
25.    implementation 'org.springframework.boot:spring-boot-starter-web'
    
26.    implementation 'mysql:mysql-connector-java'
    
27.    implementation 'org.projectlombok:lombok'
    
28.    implementation 'org.apache.commons:commons-pool2:2.4.2'
    
29.    implementation 'com.alibaba:fastjson:1.2.51'
    
30.    testImplementation 'org.springframework.boot:spring-boot-starter-test'
    
31. }
    

开始使用

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

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

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

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

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

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

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

1. package com.example.springbootredisdemo.config;
   
2. 
   
3. import org.springframework.beans.factory.annotation.Autowired;
   
4. import org.springframework.context.annotation.Bean;
   
5. import org.springframework.context.annotation.Configuration;
   
6. import org.springframework.data.redis.core.RedisTemplate;
   
7. import org.springframework.data.redis.serializer.GenericToStringSerializer;
   
8. import org.springframework.data.redis.serializer.RedisSerializer;
   
9. import org.springframework.data.redis.serializer.StringRedisSerializer;
   
10. 
    
11. @Configuration
    
12. publicclassRedisConfig{
    
13. 
    
14.    privatefinalRedisTemplate redisTemplate;
    
15. 
    
16.    @Autowired
    
17.    publicRedisConfig(RedisTemplate redisTemplate){
    
18.        this.redisTemplate = redisTemplate;
    
19.    }
    
20. 
    
21.    @Bean
    
22.    @SuppressWarnings("unchecked")
    
23.    publicRedisTemplate<String,Object> redisTemplate(){
    
24.        RedisSerializer<String> stringSerializer =newStringRedisSerializer();
    
25.        RedisSerializer<Object> jsonString =newGenericToStringSerializer<>(Object.class);
    
26.        redisTemplate.setKeySerializer(stringSerializer);
    
27.        redisTemplate.setValueSerializer(jsonString);
    
28.        redisTemplate.setHashKeySerializer(stringSerializer);
    
29.        redisTemplate.setHashValueSerializer(jsonString);
    
30.        return redisTemplate;
    
31.    }
    
32. 
    
33. }
    

再去执行一下刚刚的方法

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

opsForList()添加操作

1.    @Test
   
2.    publicvoidCsetListRedis(){
   
3.        List<String> trap =newArrayList<>();
   
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.    }
    

opsForList()删除操作

1.    @Test
   
2.    publicvoidDlistRedisRemove(){
   
3.        redisTemplate.opsForList().remove("userlist",0,"张无忌");
   
4.    }
   
5. 
   

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

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

opsForSet()添加操作

利用了set值的不可重复

1.    @Test
   
2.    publicvoidCsetRedis(){
   
3.        List<String> trap =newArrayList<>();
   
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.    }
    

结果

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

opsForSet()的删除操作

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

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

opsForHash()操作

1.    //opsForHash()操作
   
2.    @Test
   
3.    publicvoidFhashRedisAdd(){
   
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.    }
    

结果

测试类SpringbootRedisDemoApplicationTests

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

1. package com.example.springbootredisdemo;
   
2. 
   
3. import com.example.springbootredisdemo.service.NovelService;
   
4. import lombok.extern.slf4j.Slf4j;
   
5. import org.junit.FixMethodOrder;
   
6. import org.junit.Test;
   
7. import org.junit.runner.RunWith;
   
8. import org.junit.runners.MethodSorters;
   
9. import org.springframework.beans.factory.annotation.Autowired;
   
10. import org.springframework.boot.test.context.SpringBootTest;
    
11. import org.springframework.data.redis.core.RedisTemplate;
    
12. import org.springframework.test.context.junit4.SpringRunner;
    
13. 
    
14. import java.util.ArrayList;
    
15. import java.util.List;
    
16. 
    
17. //根据测试方法名字搞定执行顺序
    
18. @FixMethodOrder(MethodSorters.NAME_ASCENDING)
    
19. @RunWith(SpringRunner.class)
    
20. @SpringBootTest
    
21. @Slf4j
    
22. publicclassSpringbootRedisDemoApplicationTests{
    
23. 
    
24.    @Autowired
    
25.    privateNovelService novelService;
    
26. 
    
27.    @Autowired
    
28.    privateRedisTemplate<String,Object> redisTemplate;
    
29. 
    
30.    privatefinalstaticString KEY ="username";
    
31.    privatefinalstaticString VALUE ="test";
    
32. 
    
33. 
    
34.    @Test
    
35.    publicvoidAstringRedis(){
    
36.        redisTemplate.opsForValue().set(KEY,VALUE);
    
37.        log.info("string set存储:{}->{}",KEY,VALUE);
    
38.        redisTemplate.opsForValue().get(KEY);
    
39.        log.info("string 根据{}取出{}",KEY,VALUE);
    
40.    }
    
41. 
    
42.    @Test
    
43.    publicvoidBlistRedis(){
    
44.        List<String> trap =newArrayList<>();
    
45.        trap.add("张三");
    
46.        trap.add("张三");
    
47.        trap.add("张无忌");
    
48.        trap.add("新垣结衣");
    
49.        //循环向userlist左添加值
    
50.        trap.forEach(value->redisTemplate.opsForList().leftPush("userlist",value));
    
51. //        redisTemplate.opsForList().leftPushAll("userlist",trap);
    
52.        //向userlist右添加值
    
53.        redisTemplate.opsForList().rightPush("userlist","rightValue");
    
54.        //取出userlist的值
    
55.        log.info("userlist->{}",redisTemplate.opsForList().range("userlist",0,10));
    
56.    }
    
57. 
    
58.    @Test
    
59.    publicvoidCsetRedis(){
    
60.        List<String> trap =newArrayList<>();
    
61.        trap.add("张三");
    
62.        trap.add("里斯");
    
63.        trap.add("里斯");
    
64.        trap.add("张无忌");
    
65.        trap.add("新垣结衣");
    
66.        System.out.print(trap.toString());
    
67.        //循环向userlist左添加值
    
68.        trap.forEach(value->redisTemplate.opsForSet().add("userSet",value));
    
69.        log.info("取出userSet->{}",redisTemplate.opsForSet().members("userSet"));
    
70.    }
    
71. 
    
72.    @Test
    
73.    publicvoidDlistRedisRemove(){
    
74.        redisTemplate.opsForList().remove("userlist",0,"张无忌");
    
75.    }
    
76. 
    
77. 
    
78.    @Test
    
79.    publicvoidEsetRedisRemove(){
    
80.        redisTemplate.opsForSet().remove("userSet","张无忌");
    
81.    }
    
82. 
    
83.    //opsForHash()操作
    
84.    @Test
    
85.    publicvoidFhashRedisAdd(){
    
86.        //添加
    
87.        redisTemplate.opsForHash().put("user","phone",10086);
    
88.        redisTemplate.opsForHash().put("user","address","Shanghai");
    
89.        redisTemplate.opsForHash().put("user","del","mubaba");
    
90.        redisTemplate.opsForHash().put("user","dada","达达");
    
91.        //修改
    
92.        redisTemplate.opsForHash().put("user","address","Beijing");
    
93.        //删除
    
94.        redisTemplate.opsForHash().delete("user","del","dada");
    
95.    }
    
96. }
    

小知识

方法名字前加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