Spring实现Redis简单实例

Spring实现Redis简单实例

Redis安装

下载地址：https://github.com/tporadowski/redis/releases

启动命令：

// 进入Redis解压目录，cmd执行
redis-server.exe redis.windows.conf

详细参考：https://www.runoob.com/redis/redis-install.html

添加依赖

// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis
implementation group: 'org.springframework.boot', name: 'spring-boot-starter-data-redis', version: '2.5.6'
// https://mvnrepository.com/artifact/redis.clients/jedis
implementation group: 'redis.clients', name: 'jedis', version: '3.7.0'

配置application.yml

spring:
  datasource:
    redis:
      database: 0            # Redis数据库索引（默认0）
      host: 127.0.0.1        # Redis服务器地址
      port: 6379             # Redis服务器连接端口
      password:              # Redis服务器连接密码（默认为空）
      jedis:
        pool:
          max-active: 8       # 连接池最大连接数（使用负值表示没有限制）
          max-wait: -1        # 连接池最大阻塞等待时间（使用负值表示没有限制）
          max-idle: 8         # 连接池中的最大空闲连接
          min-idle: 0         # 连接池中的最小空闲连接
      timeout: 0              # 连接超时时间（毫秒）

RedisClient工具类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;

@Component
public class RedisClient {

    @Autowired
    private StringRedisTemplate redisTpl;

    /**
     * 向redis中设值
     * @param key 使在用 a:b:id 的形式，使用 rdm 查看 redis 情况时，看到分层文件夹的展示形式，便于管理
     * @param value
     * @return
     */
    public boolean set(String key, String value) {
        boolean result = false;
        try {
            redisTpl.opsForValue().set(key, value);
            result = true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 向redis中设值，同时设置过期时间
     * @param key
     * @param value
     * @param time
     * @return
     */
    public boolean set(String key, String value, long time) {
        boolean result = false;
        try {
            redisTpl.opsForValue().set(key, value);
            expire(key, time);
            result =  true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 获取redis中的值
     * @param key
     * @return
     */
    public String get(String key) {
        String result = null;
        try {
            result = redisTpl.opsForValue().get(key);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 设置key的过期时间
     * @param key
     * @param time
     * @return
     */
    public boolean expire(String key, long time) {
        boolean result = false;
        try {
            if(time > 0) {
                redisTpl.expire(key, time, TimeUnit.SECONDS);
                result = true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 根据key删除对应value
     * @param key
     * @return
     */
    public boolean remove(String key) {
        boolean result = false;
        try {
            redisTpl.delete(key);
            result = true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }
}

Redis测试类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

@Component
public class RedisTest {

    @Autowired
    private RedisClient redisClient;

    @PostConstruct
    public void test(){

        // 设值
        if(redisClient.set("myKey", "calos")){
            System.out.println("Redis设值成功！ ");
        }
        // 获取值
        System.out.println(redisClient.get("myKey"));
        // 删除值
        if(redisClient.remove("myKey")){
            System.out.println("Redis删除值成功! ");
        }
        // 获取值
        System.out.println(redisClient.get("myKey"));
    }
}

Run