SpringBoot对常用的数据库支持外,对NoSQL 数据库也进行了封装自动化。
redis介绍
Redis是目前业界使用最广泛的内存数据存储。相比memcached,Redis支持更丰富的数据结构,例如hashes, lists, sets等,同时支持数据持久化。除此之外,Redis还提供一些类数据库的特性,比如事务,HA,主从库。可以说Redis兼具了缓存系统和数据库的一些特性,因此有着丰富的应用场景。本文介绍Redis在Spring Boot中两个典型的应用场景。
如何使用
1、引入 spring-boot-starter-redis
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2、添加配置文件
![](/qrcode.jpg)
# REDIS (RedisProperties)
# Redis数据库索引(默认为0)
spring.redis.database=0
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码(默认为空)
spring.redis.password=
# 连接池最大连接数(使用负值表示没有限制)
spring.redis.pool.max-active=8
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0
# 连接超时时间(毫秒)
spring.redis.timeout=1000
3、安装 Redis
Redis 官网:https://redis.io/,官网提供的是linux版本的,下载windows版本的地址如下。
Redis windows下载地址:https://github.com/MicrosoftArchive/redis/releases
1、安装。
运行对话框输入"cmd",打开命令提示符对话框。定位到redis解压缩后的文件夹中。输入“redis-server.exe redis.windows.conf”出现如下界面即成功启动。
2、测试是否安装成功(使用客户端进行测试)
方法一: 安装redis服务的dos窗口不要关闭。另外打开一个dos窗口,定位到解压缩后的redis文件夹,输入“redis-cli.exe -h 127.0.0.1 -p 6379”
方法二:直接在安装目录找到redis-cli.exe,双击打开
输入set a '1'回车保存成功,输入get a获取Redis内的值。
如下图表示成功
3、因为redis是key/value形式的内存数据库,所以,在设置/读取值的时候,需要使用set/get key value的形式
如果能正常设置/读取,则证明redis已经安装完成。
4、每次使用都需要这样开启Redis 服务,挺麻烦的,那就继续看:
1)安装服务:redis-server --service-install redis.windows.conf--loglevel verbose
2)启动服务:redis-server --service-start
3)卸载服务:redis-server --service-uninstall
好,到这里,Redis 的基本准备已经可以了,接下来就是怎样去写入缓存,怎样拿出缓存的问题了,我看了很多人的用法,都不一样,这个方案,是我认为比较合适的方案,里面包含了 Redis 的所有使用方式,大家可以参考一
@Component public class RedisUtil { @Autowired private RedisTemplate redisTemplate; /** * 写入缓存 * @param key 键 * @param value 值 * @return */ public boolean set(final String key, Object value) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 写入缓存设置时效时间 * @param key 键 * @param value 值 * @param expireTime 过期时间(秒) * @return */ public boolean set(final String key, Object value, Long expireTime) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); redisTemplate.expire(key, expireTime, TimeUnit.SECONDS); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 批量删除对应的value * @param keys 键s */ public void remove(final String... keys) { for (String key : keys) { remove(key); } } /** * 批量删除key * @param pattern */ public void removePattern(final String pattern) { Set<Serializable> keys = redisTemplate.keys(pattern); if (keys.size() > 0) redisTemplate.delete(keys); } /** * 删除对应的value * @param key 键 */ public void remove(final String key) { if (exists(key)) { redisTemplate.delete(key); } } /** * 判断缓存中是否有对应的value * @param key 键 * @return */ public boolean exists(final String key) { return redisTemplate.hasKey(key); } /** * 读取缓存 * @param key 键 * @return */ public Object get(final String key) { Object result = null; ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); result = operations.get(key); return result; } /** * 哈希 添加 * @param key 键 * @param hashKey has键 * @param value 值 */ public void hmSet(String key, Object hashKey, Object value){ HashOperations<String, Object, Object> hash = redisTemplate.opsForHash(); hash.put(key,hashKey,value); } /** * 哈希获取数据 * @param key 键 * @param hashKey has键 * @return */ public Object hmGet(String key, Object hashKey){ HashOperations<String, Object, Object> hash = redisTemplate.opsForHash(); return hash.get(key,hashKey); } /** * 列表添加 * @param k 键 * @param v 值 */ public void lPush(String k,Object v){ ListOperations<String, Object> list = redisTemplate.opsForList(); list.rightPush(k,v); } /** * 列表获取 * @param k 键 * @param l * @param l1 * @return */ public List<Object> lRange(String k, long l, long l1){ ListOperations<String, Object> list = redisTemplate.opsForList(); return list.range(k,l,l1); } /** * 集合添加 * @param key 键 * @param value 值 */ public void add(String key,Object value){ SetOperations<String, Object> set = redisTemplate.opsForSet(); set.add(key,value); } /** * 集合获取 * @param key 键 * @return */ public Set<Object> setMembers(String key){ SetOperations<String, Object> set = redisTemplate.opsForSet(); return set.members(key); } /** * 有序集合添加 * @param key * @param value * @param scoure */ public void zAdd(String key,Object value,double scoure){ ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); zset.add(key,value,scoure); } /** * 有序集合获取 * @param key * @param scoure * @param scoure1 * @return */ public Set<Object> rangeByScore(String key,double scoure,double scoure1){ ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); return zset.rangeByScore(key, scoure, scoure1); } }
4、好了,接下来就可以直接使用了,我是直接用浏览器或者 PostMan 来测试的,配合我第二节的 User 类来使用
@RestController public class TestRedisController { @Autowired private UserDao userDao; @Autowired private RedisUtil redisUtil; @RequestMapping("/testSetRedis") public void testSetRedis () { redisUtil.set("key","value22222"); } @RequestMapping("/testGetRedis") public Object getSetRedis () { return redisUtil.get("key"); } @RequestMapping("/testRegister") public void testRegister () { User user = new User(); user.setUserName("xjb1"); user.setPassword("123456"); user.setEmail("[email protected]"); user.setNickName("xjb1"); user.setRegTime(new Date().toString()); userDao.save(user); // new User 并添加到数据库后,将主键返回,并且保存到 缓存,设置有效时间 redisUtil.set(user.getId().toString(), user, 10l); } @RequestMapping("/testGetUserByRedis") public Object testGetUserByRedis () { // 这里写得比较死,真实开发中,有很多方式获取缓存的key return redisUtil.get("61"); } }