spring Boot 2.x | 集成 redis

spring Boot 项目中加入redis

集成redis

  • 新建springboot项目
  • 引入redis依赖:spring-boot-starter-data-redis
  • 配置文件中配置相关属性
pom.xml引入依赖

新建项目后,在pom.xml中引入redis依赖 spring-boot-starter-data-redis ,pom.xml完整依赖如下:

<dependencies>
    <!--Redis 依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <!-- web 依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.1</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
配置文件
spring:
  redis:
    port: 6379
    host: 127.0.0.1

springboot中提供了两个redis操作的api:RedisTemplate,StringRedisTemplate

使用StringRedisTemplate编写一个工具类
/**
 * @auther: chenmingyu
 * @date: 2018/11/11 12:04
 * @description: redis工具类
 */
@Component("redisUtils")
public class RedisUtils {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    /**
     * 获取key
     * @param key
     * @return
     */
    public String get(String key){
        try {
            if(StringUtils.isBlank(key)){
                return null;
            }
            return stringRedisTemplate.opsForValue().get(key);
        }catch (Exception e){
            System.out.println(String.format("获取字符串异常! key :%s",key));
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 设置key
     * @param key
     * @param value
     */
    public Boolean set(String key,String value){
        try {
            if(StringUtils.isBlank(key)||StringUtils.isBlank(value)){
                return false;
            }
            stringRedisTemplate.opsForValue().set(key,value);
            return true;
        }catch (Exception e){
            System.out.println(String.format("设置字符串异常! key :%s ,value:%s",key,value));
            e.printStackTrace();
        }
        return false;
    }
    /**
     * 删除key
     * @param key
     */
    public Boolean delete(String key){
        try {
            if(StringUtils.isBlank(key)){
                return false;
            }
            return stringRedisTemplate.delete(key);
        }catch (Exception e){
            System.out.println(String.format("删除key异常! key :%s ",key));
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 设置缓存,时间单位为秒
     * @param key
     * @param value
     * @param time
     * @return
     */
    public Boolean setEX(String key,String value,Long time){
        try {
            if(StringUtils.isBlank(key)||StringUtils.isBlank(value)){
                return false;
            }
            stringRedisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
            return true;
        }catch (Exception e){
            System.out.println(String.format("设置缓存异常! key :%s ,value:%s,times:%s",key));
            e.printStackTrace();
        }
        return false;
    }

    /**
     * 获取key缓存时间,时间单位为秒
     * @param key
     * @return
     */
    public Long getExpireTime(String key){
        try {
            if(StringUtils.isBlank(key)){
                return null;
            }
            return stringRedisTemplate.getExpire(key,TimeUnit.SECONDS);
        }catch (Exception e){
            System.out.println(String.format("获取key缓存时间异常! key :%s",key));
            e.printStackTrace();
        }
        return null;
    }
}

StringRedisTemplate继承自RedisTemplate,StringRedisTemplate中的所有数据类型都是字符串类型,比如key,value,list,hash,set里存的元素都是字符串,与RedisTemplate不同的是StringRedisTemplate改变了序列化方式,StringRedisTemplate使用StringRedisSerializer序列化key,value,List,Hash,Set等数据结构中的元素。

使用junit测试
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootRedisApplicationTests {

    @Resource
    private RedisUtils redisUtils;


    @Test
    public void testSet() {
        Boolean flag = redisUtils.set("mingyu","mingyu");
        System.out.println("testSet:"+flag);
    }

    @Test
    public void testGet() {
        String value = redisUtils.get("mingyu");
        System.out.println("testGet:"+value);
    }

    @Test
    public void testDelete() {
        Boolean flag = redisUtils.delete("mingyu");
        System.out.println("testDelete:"+flag);
    }

    @Test
    public void testSetEX() {
        Boolean flag = redisUtils.setEX("mingyu","cmy",1000L);
        System.out.println("testSetEX:"+flag);
    }

    @Test
    public void testGetExpireTime() {
        Long time = redisUtils.getExpireTime("mingyu");
        System.out.println("testSetEX:"+time);
    }
}
文章作者: 陈明羽
文章链接: https://chenmingyu.top/springboot-redis/
版权声明: 本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 陈明羽
打赏
  • 微信

评论