框架 Spring Boot 技术入门到整合 9-1 springboot整合缓存redis
0 课程地址
https://www.imooc.com/video/16790/0
1 课程重点
关于redis的介绍转载:
https://www.cnblogs.com/powertoolsteam/p/redis.html
2 课程准备(相关安装包链接失效的话,可以找我要)
2.1 redis安装包(在本地启动redis服务)
https://github.com/MicrosoftArchive/redis/releases
2.2 redis可视化工具
http://www.downza.cn/soft/210734.html
3 课程demo
3.1 字符串案例
pom.xml引入依赖
<!-- 引入 redis 依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
application.properties配置
############################################################
#
# REDIS 配置
#
############################################################
# Redis数据库索引(默认为0)
spring.redis.database=1
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码(默认为空)
spring.redis.password=
# 连接池最大连接数(使用负值表示没有限制)
spring.redis.pool.max-active=1000
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=10
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=2
# 连接超时时间(毫秒)
spring.redis.timeout=100
RedisController
package com.example.demo.controller; import java.util.ArrayList; import java.util.Date; import java.util.List; import com.example.demo.bean.User; import com.example.demo.pojo.SysUser; import com.example.demo.tools.JSONResult; import com.example.demo.tools.JsonUtils; import com.example.demo.tools.RedisOperator; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("redis") public class RedisController { @Autowired private StringRedisTemplate strRedis; @Autowired private RedisOperator redis; @RequestMapping("/testString") public JSONResult testString() { strRedis.opsForValue().set("imooc-cache", "hello 慕课网~~~~~~"); return JSONResult.ok(strRedis.opsForValue().get("imooc-cache")); } @RequestMapping("/test") public JSONResult test() { strRedis.opsForValue().set("imooc-cache", "hello 慕课网~~~~~~"); SysUser user = new SysUser(); user.setId("100111"); user.setUsername("imooc"); user.setPassword("abc123"); user.setIsDelete(0); user.setRegistTime(new Date()); strRedis.opsForValue().set("json:user", JsonUtils.objectToJson(user)); SysUser jsonUser = JsonUtils.jsonToPojo(strRedis.opsForValue().get("json:user"), SysUser.class); return JSONResult.ok(jsonUser); } @RequestMapping("/getJsonList") public JSONResult getJsonList() { User user = new User(); user.setUserAge(18); user.setUserName("慕课网"); user.setPassWord("123456"); user.setBirthDay(new Date()); User u1 = new User(); u1.setUserAge(19); u1.setUserName("imooc"); u1.setPassWord("123456"); u1.setBirthDay(new Date()); User u2 = new User(); u2.setUserAge(17); u2.setUserName("hello imooc"); u2.setPassWord("123456"); u2.setBirthDay(new Date()); List<User> userList = new ArrayList<>(); userList.add(user); userList.add(u1); userList.add(u2); redis.set("json:info:userlist", JsonUtils.objectToJson(userList), 2000); String userListJson = redis.get("json:info:userlist"); List<User> userListBorn = JsonUtils.jsonToList(userListJson, User.class); return JSONResult.ok(userListBorn); } }
RedisOperator
package com.example.demo.tools; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisKeyValueTemplate; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; /** * * @Title: RedisOperator.java * @Package com.itzixi.web.component * @Description: 使用redisTemplate的操作实现类 Copyright: Copyright (c) 2016 * Company:FURUIBOKE.SCIENCE.AND.TECHNOLOGY * * @author leechenxiang * @date 2017年9月29日 下午2:25:03 * @version V1.0 */ @Component public class RedisOperator { // @Autowired // private RedisTemplate<String, Object> redisTemplate; @Autowired private StringRedisTemplate redisTemplate; // Key(键),简单的key-value操作 /** * 实现命令:TTL key,以秒为单位,返回给定 key的剩余生存时间(TTL, time to live)。 * * @param key * @return */ public long ttl(String key) { return redisTemplate.getExpire(key); } /** * 实现命令:expire 设置过期时间,单位秒 * * @param key * @return */ public void expire(String key, long timeout) { redisTemplate.expire(key, timeout, TimeUnit.SECONDS); } /** * 实现命令:INCR key,增加key一次 * * @param key * @return */ public long incr(String key, long delta) { return redisTemplate.opsForValue().increment(key, delta); } /** * 实现命令:KEYS pattern,查找所有符合给定模式 pattern的 key */ public Set<String> keys(String pattern) { return redisTemplate.keys(pattern); } /** * 实现命令:DEL key,删除一个key * * @param key */ public void del(String key) { redisTemplate.delete(key); } // String(字符串) /** * 实现命令:SET key value,设置一个key-value(将字符串值 value关联到 key) * * @param key * @param value */ public void set(String key, String value) { redisTemplate.opsForValue().set(key, value); } /** * 实现命令:SET key value EX seconds,设置key-value和超时时间(秒) * * @param key * @param value * @param timeout * (以秒为单位) */ public void set(String key, String value, long timeout) { redisTemplate.opsForValue().set(key, value, timeout, TimeUnit.SECONDS); } /** * 实现命令:GET key,返回 key所关联的字符串值。 * * @param key * @return value */ public String get(String key) { return (String)redisTemplate.opsForValue().get(key); } // Hash(哈希表) /** * 实现命令:HSET key field value,将哈希表 key中的域 field的值设为 value * * @param key * @param field * @param value */ public void hset(String key, String field, Object value) { redisTemplate.opsForHash().put(key, field, value); } /** * 实现命令:HGET key field,返回哈希表 key中给定域 field的值 * * @param key * @param field * @return */ public String hget(String key, String field) { return (String) redisTemplate.opsForHash().get(key, field); } /** * 实现命令:HDEL key field [field ...],删除哈希表 key 中的一个或多个指定域,不存在的域将被忽略。 * * @param key * @param fields */ public void hdel(String key, Object... fields) { redisTemplate.opsForHash().delete(key, fields); } /** * 实现命令:HGETALL key,返回哈希表 key中,所有的域和值。 * * @param key * @return */ public Map<Object, Object> hgetall(String key) { return redisTemplate.opsForHash().entries(key); } // List(列表) /** * 实现命令:LPUSH key value,将一个值 value插入到列表 key的表头 * * @param key * @param value * @return 执行 LPUSH命令后,列表的长度。 */ public long lpush(String key, String value) { return redisTemplate.opsForList().leftPush(key, value); } /** * 实现命令:LPOP key,移除并返回列表 key的头元素。 * * @param key * @return 列表key的头元素。 */ public String lpop(String key) { return (String)redisTemplate.opsForList().leftPop(key); } /** * 实现命令:RPUSH key value,将一个值 value插入到列表 key的表尾(最右边)。 * * @param key * @param value * @return 执行 LPUSH命令后,列表的长度。 */ public long rpush(String key, String value) { return redisTemplate.opsForList().rightPush(key, value); } }
测试结果:
3.2 对象案例
pom.xml(同上)
applications.xml(同上)
RedisController
package com.example.demo.controller; import java.util.ArrayList; import java.util.Date; import java.util.List; import com.example.demo.bean.User; import com.example.demo.pojo.SysUser; import com.example.demo.tools.JSONResult; import com.example.demo.tools.JsonUtils; import com.example.demo.tools.RedisOperator; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("redis") public class RedisController { @Autowired private StringRedisTemplate strRedis; @Autowired private RedisOperator redis; @RequestMapping("/testString") public JSONResult testString() { strRedis.opsForValue().set("imooc-cache", "hello 慕课网~~~~~~"); return JSONResult.ok(strRedis.opsForValue().get("imooc-cache")); } @RequestMapping("/testObject") public JSONResult testObject() { strRedis.opsForValue().set("imooc-cache", "hello 慕课网~~~~~~"); SysUser user = new SysUser(); user.setId("100111"); user.setUsername("imooc"); user.setPassword("abc123"); user.setIsDelete(0); user.setRegistTime(new Date()); strRedis.opsForValue().set("json:user", JsonUtils.objectToJson(user)); SysUser jsonUser = JsonUtils.jsonToPojo(strRedis.opsForValue().get("json:user"), SysUser.class); return JSONResult.ok(jsonUser); } @RequestMapping("/getJsonList") public JSONResult getJsonList() { User user = new User(); user.setUserAge(18); user.setUserName("慕课网"); user.setPassWord("123456"); user.setBirthDay(new Date()); User u1 = new User(); u1.setUserAge(19); u1.setUserName("imooc"); u1.setPassWord("123456"); u1.setBirthDay(new Date()); User u2 = new User(); u2.setUserAge(17); u2.setUserName("hello imooc"); u2.setPassWord("123456"); u2.setBirthDay(new Date()); List<User> userList = new ArrayList<>(); userList.add(user); userList.add(u1); userList.add(u2); redis.set("json:info:userlist", JsonUtils.objectToJson(userList), 2000); String userListJson = redis.get("json:info:userlist"); List<User> userListBorn = JsonUtils.jsonToList(userListJson, User.class); return JSONResult.ok(userListBorn); } }
JsonUtils
package com.example.demo.tools; import java.util.List; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JavaType; import com.fasterxml.jackson.databind.ObjectMapper; /** * * @Title: JsonUtils.java * @Package com.lee.utils * @Description: 自定义响应结构, 转换类 * Copyright: Copyright (c) 2016 * Company:Nathan.Lee.Salvatore * * @author leechenxiang * @date 2016年4月29日 下午11:05:03 * @version V1.0 */ public class JsonUtils { // 定义jackson对象 private static final ObjectMapper MAPPER = new ObjectMapper(); /** * 将对象转换成json字符串。 * <p>Title: pojoToJson</p> * <p>Description: </p> * @param data * @return */ public static String objectToJson(Object data) { try { String string = MAPPER.writeValueAsString(data); return string; } catch (JsonProcessingException e) { e.printStackTrace(); } return null; } /** * 将json结果集转化为对象 * * @param jsonData json数据 * @param clazz 对象中的object类型 * @return */ public static <T> T jsonToPojo(String jsonData, Class<T> beanType) { try { T t = MAPPER.readValue(jsonData, beanType); return t; } catch (Exception e) { e.printStackTrace(); } return null; } /** * 将json数据转换成pojo对象list * <p>Title: jsonToList</p> * <p>Description: </p> * @param jsonData * @param beanType * @return */ public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) { JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType); try { List<T> list = MAPPER.readValue(jsonData, javaType); return list; } catch (Exception e) { e.printStackTrace(); } return null; } }
测试结果: