展开被 SpringBoot 玩的日子 《 三 》 整合Redis

　　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");
    }
}