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、添加配置文件
# 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 (Windows)
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
这里也简单写一下 Linux 安装Redis 的方案
............................................................................................................(有时间再写)
好,到这里,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("1xjb@qq.com");
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");
}
}