Rumah > Java > javaTutorial > teks badan

Apakah kaedah untuk mengintegrasikan Redis dalam projek SpringBoot java?

王林
Lepaskan: 2023-05-12 13:52:13
ke hadapan
1495 orang telah melayarinya

Redis adalah sumber terbuka sepenuhnya, mematuhi protokol BSD dan merupakan pangkalan data nilai kunci berprestasi tinggi.

Redis mempunyai tiga ciri berikut dengan produk caching nilai kunci yang lain:

  • Redis menyokong kegigihan data ia boleh menyimpan data dalam memori ke cakera dan memuatkannya semula untuk digunakan semasa memulakan semula.

  • Redis bukan sahaja menyokong data jenis nilai kunci mudah, tetapi juga menyediakan storan struktur data seperti senarai, set, zset dan cincang.

  • Redis menyokong sandaran data, iaitu sandaran data dalam mod tuan-hamba.

Kelebihan Redis

  • Prestasi yang sangat tinggi– Redis boleh membaca pada kelajuan 110,000 kali/s dan menulis pada kelajuan 81,000 kali / s

  • Jenis data kaya– Redis menyokong operasi jenis data String, List, Hash, Set dan zset dalam kes binari.

  • Atomik – Semua operasi Redis adalah atom, yang bermaksud sama ada ia dilaksanakan dengan jayanya atau tidak dilaksanakan sama sekali. Operasi individu adalah atom. Berbilang operasi juga menyokong urus niaga, iaitu atomicity, dibalut oleh arahan MULTI dan EXEC.

  • Ciri kaya– Redis juga menyokong penerbitan/langganan, pemberitahuan, tamat tempoh kunci dan ciri lain

  • Redis adalah satu benang, 6.0 Versi ini menyokong membolehkan multi-threading.

Pemasangan Redis

java SpringBoot项目整合Redis的方法是什么

Nyahmampat fail termampat yang dimuat turun Senarai fail yang dinyahmampat adalah seperti berikut:

java SpringBoot项目整合Redis的方法是什么

Gunakan tetingkap cmd untuk membuka Redis

redis-server.exe   redis.windows.conf   #加载配置文件启动
Salin selepas log masuk

java SpringBoot项目整合Redis的方法是什么

注:启动之后,不要关闭窗口,关闭窗口服务停止!

Pasang klien pangkalan data Redis

java SpringBoot项目整合Redis的方法是什么

Arahan berkaitan perpustakaan:

flushdb  清空当前库

flushall  清空所有库

select   1    切换库
Salin selepas log masuk

arahan berkaitan kunci

Arahan Fungsi Sintaks
指令 作用 语法
del 删除一个或多个key del keyname
exists 判断一个或多个key是否存在,多个key时有一个存在则就会返回1 exists keyname
expire 设置key的生存时间 单位 :秒 expire keyname seconds
keys 查询所有匹配模式的key ?匹配一个字符 *匹配0-n个字符 [] 满足其中的一个 key * key h?llo
move 将key移动到指定的库中 move keyname db
pexpire 设置key的生存时间 单位 :毫秒 设置成功返回1 否则返回0 pexpire keyname milliseconds
ttl 以秒为单位返回key的剩余生存时间,返回-1表示永久存储,-2表示key不存在 ttl keyname
randomkey 从当前数据库中随机的返回一个key randomkey
rename 重命名key,成功返回ok,否则返回错误信息。 rename key newkey
type 返回key所存储的值的类型 type keyname
del Padam satu atau lebih kekunci del nama kunci wujud td > Tentukan sama ada satu atau lebih kunci wujud Jika satu daripada berbilang kunci wujud, 1 akan dikembalikan nama kunci wujud tamat tempoh. Tetapkan unit masa kemandirian kunci: saat tamat masa nama kunci saat kuncis Tanya semua kekunci yang sepadan dengan corak? Padankan satu aksara * Padankan 0-n aksara [] Puaskan salah satu daripadanya key * key h?llo move Alihkan kekunci ke pustaka yang ditentukan alihkan nama kunci db pexpire Tetapkan unit masa kelangsungan hidup kunci: milisaat jika tetapan berjaya, kembalikan 1, jika tidak, kembalikan 0 pexpire keyname milisaat ttl Mengembalikan baki masa kemandirian kunci dalam beberapa saat, mengembalikan -1 bermaksud storan kekal, -2 bermakna kunci tidak wujud ttl keyname randomkey Mengembalikan kunci rawak daripada pangkalan data semasa randomkey namakan semula Namakan semula kunci, kembalikan dengan jayanya, jika tidak, kembalikan mesej ralat. namakan semula kunci baru kekunci taip Kembalikan jenis nilai yang disimpan dalam kunci taip keyname

Jenis data Redis

1. Rentetan (rentetan)

  • rentetan ialah jenis redis yang paling asas Anda boleh memahaminya dengan jenis yang sama seperti Memcached , kunci sepadan dengan nilai.

  • Jenis rentetan adalah selamat binari. Ini bermakna rentetan redis boleh mengandungi sebarang data. Contohnya, imej jpg atau objek bersiri.

  • Jenis rentetan ialah jenis data paling asas bagi Redis. Nilai jenis rentetan boleh menyimpan sehingga 512MB.

Arahan operasi:

命令 描述
SET 设置指定 key 的值
GET 获取指定 key 的值。
GETRANGE 返回 key 中字符串值的子字符
GETSET 将给定 key 的值设为 value ,并返回 key 的旧值(old value)。
SETEX 将值 value 关联到 key ,并将 key 的过期时间设为 seconds (以秒为单位)。
SETNX 只有在 key 不存在时设置 key 的值
STRLEN 返回 key 所储存的字符串值的长度。
MSET 同时设置一个或多个 key-value 对。
MSETNX 同时设置一个或多个 key-value 对,当且仅当所有给定 key 都不存在
INCR 将 key 中储存的数字值增一
INCRBY 将 key 所储存的值加上给定的增量值(increment)
INCRBYFLOAT 将 key 所储存的值加上给定的浮点增量值(increment)
DECR 将 key 中储存的数字值减一。
DECRBY key 所储存的值减去给定的减量值(decrement)
APPEND 如果 key 已经存在并且是一个字符串, APPEND 命令将指定的 value 追加到该 key 原来值(value)的末尾

2.Hash (Hash)

  • Hash Redis ialah nilai utama ( kunci =>nilai) koleksi pasangan.

  • Redis hash ialah jadual pemetaan medan dan nilai jenis rentetan amat sesuai untuk menyimpan objek.

Arahan operasi:

命令 描述
hset 设置一个key/value对
hget 获取key对应的value
hgetall 获取所有的key/value对
hdel 删除某个key/value对
hexists 判断一个key是否存在
hkeys 获取所有的key
hvals 获取所有的value
hmset 设置多个key/value
hmget 获取多个key的value
hsetnx 设置一个不存在的key的值
hincrby 为value的值进行加法运算
hincrbyfloat 为value的值进行加浮点类型值运算

3.Senarai (Senarai)

  • Senarai redis ialah senarai ringkas rentetan, diisih mengikut susunan sisipan. Anda boleh menambah elemen pada kepala (kiri) atau ekor (kanan) senarai.

Arahan operasi

命令 描述
LINDEX 通过索引获取列表中的元素 lindex lists 0
LINSERT key BEFORE|AFTER 在列表的元素前或者后插入元素
LLEN 获取列表长度
LPOP 移出并获取列表的第一个元素
LPUSH 将一个或多个值插入到列表头部
LPUSHX 将一个值插入到已存在的列表头部
LRANGE 获取列表指定范围内的元素 (0 -1)
LREM 移除列表重复元素
LSET 通过索引设置列表元素的值 ,但是索引必须存在,实质是根据索引修改值
LTRIM 对一个列表进行修剪(trim),就是说,让列表只保留指定区间内的元素,不在指定区间之内的元素都将被删除
RPOP 移除列表的最后一个元素,返回值为移除的元素
RPOPLPUSH 移除列表的最后一个元素,并将该元素添加到另一个列表并返回
RPUSH 在列表中添加一个或多个值
RPUSHX 为已存在的列表添加值

4.Set (set)

  • Redis’ Set ialah himpunan jenis rentetan tidak tertib .

  • Pengumpulan dilaksanakan melalui jadual cincang, jadi kerumitan menambah, memadam dan mencari ialah O(1).

Arahan operasi:

命令 描述
sadd 为集合添加元素
smembers 显示集合中所有元素 (无序)
scard 返回集合中元素的个数
spop 随机返回一个元素,并将这个元素删除
smove 从一个集合向令一个集合中转移元素
srem 从集合中删除一个元素
sismember 判断集合中是否包含这个元素
srandmember 随机返回一个元素
sinter 求交集
sunion 求和集

5.ZSet (set diisih: set tersusun)

  • Redis ZSet dan Set juga merupakan koleksi elemen jenis String dan ahli pendua tidak dibenarkan.

  • Perbezaannya ialah setiap elemen dikaitkan dengan skor jenis berganda. Redis menggunakan markah untuk mengisih ahli set daripada kecil kepada besar. Ahli

  • ZSet adalah unik, tetapi markah boleh diulang.

Arahan operasi:

命令 描述
zadd 添加一个有序集合元素
zcard 返回集合中元素的个数
zrange升序 zrevrange降序 返回一个范围内的元素
zrangebyscore 按照分数查找一个范围内的元素
zrank 返回排名
zrevrank 倒叙排名
zscore 显示某个元素的分数
zrem 移除某个元素
zincrby 给某个特定元素加分

SpringBoot 操作 Redis

  spring boot data redis中提供了RedisTemplate和StringRedisTemplate,其中StringRedisTemplate是Redistemplate的子类,两个方法基本一致,不同之处主要体现在操作的数据类型不同,RedisTemplate中的两个泛型都是Object,意味着存储的key和value都可以是一个对象,而StringRedisTemplate的两个泛型都是String,意味着StringRedisTemplate的key和value都只能是字符串。

引入依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
Salin selepas log masuk

SpringBoot 配置 Redis

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

RedisTemplate 及其相关方法

1.RedisTemplate 介绍

  Spring封装了RedisTemplate对象来进行对Redis的各种操作,它支持所有的Redis原生的api。RedisTemplate位于spring-data-redis包下。RedisTemplate提供了redis各种操作、异常处理及序列化,支持发布订阅。

2.Redis 5种数据结构操作

  • redisTemplate.opsForValue(); //操作字符串

  • redisTemplate.opsForHash(); //操作hash

  • redisTemplate.opsForList(); //操作list

  • redisTemplate.opsForSet(); //操作set

  • redisTemplate.opsForZSet(); //操作有序set

或者:

  • redistempalate.boundValueOps

  • redistempalate.boundSetOps

  • redistempalate.boundListOps

  • redistempalate.boundHashOps

  • redistempalate.boundZSetOps

opsForXXX和boundXXXOps的区别:XXX为value的类型,前者获取一个operator,但是没有指定操作的对象(key),可以在一个连接(事务)内操作多个key以及对应的value;后者获取了一个指定操作对象(key)的operator,在一个连接(事务)内只能操作这个key对应的value。

SpringBootTest 实现Redis数据库增删改查

/**
 * 使用RedisTemplate 操作Redis数据的不同数据类型
 */
@SpringBootTest
public class Springbootday03ApplicationTests {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    /**
     * String 类型数据操作
     */
    @Test
    public void operateString() {

        //添加值
        redisTemplate.opsForValue().set("str", "strValue1");

        //添加值  判定是否存在 存在则不添加
        Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent("str", "strAbsent");
        System.out.println("str设置成功:" + aBoolean);

        //获取值
        String str = redisTemplate.opsForValue().get("str");
        System.out.println("str = " + str);

        //更新值
        redisTemplate.opsForValue().set("str", "strValue2");
        str = redisTemplate.opsForValue().get("str");
        System.out.println("newStr = " + str);

        //删除值
        Boolean b = redisTemplate.delete("str");
        System.out.println("str删除成功:" + b);

    }

    /**
     * 操作string类型数据  设置过期时间
     */
    @Test
    public void operateString2() {
        redisTemplate.opsForValue().set("str", "strTimeout", 10, TimeUnit.SECONDS);
        //判定值是否存在 不存在则设置值 同时设置过期时间
        Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent("str2", "strTimeoutAbsent", 20, TimeUnit.SECONDS);
        System.out.println("setIfAbsent:" + aBoolean);
    }

    /**
     * 操作hash类型数据
     */
    @Test
    public void operateHash() {
        //添加hash类型数据  key - value
        redisTemplate.opsForHash().put("hash", "username", "admin");
        //修改hash类型数据
        redisTemplate.opsForHash().put("hash", "username", "tom");
        redisTemplate.opsForHash().put("hash", "password", "123456");

        //添加hash类型数据  key - map
        HashMap<String, String> map = new HashMap<>();
        map.put("driverName", "com.mysql.jdbc.Driver");
        map.put("url", "jdbc:mysql://localhost:3306/mybatis?serverTimezone=UTC");
        redisTemplate.opsForHash().putAll("hash", map);

        //获取hash类型数据  entries
        Map<Object, Object> hash = redisTemplate.opsForHash().entries("hash");
        hash.forEach((key, value) -> {
            System.out.println(key + "::" + value);
        });

        //获取所有的key
        Set<Object> keys = redisTemplate.opsForHash().keys("hash");
        for (Object key : keys) {
            System.out.println("key:" + key);
        }
        //获取所有value
        List<Object> values = redisTemplate.opsForHash().values("hash");
        values.forEach(value -> System.out.println("value:" + value));

        //删除hash类型数据  删除一个  返回删除的个数
        Long delete = redisTemplate.opsForHash().delete("hash", "username");
        System.out.println("delete = " + delete);

        //删除hash类型数据  删除多个  返回删除的个数
        delete = redisTemplate.opsForHash().delete("hash", "username", "password", "driverName");
        System.out.println("delete = " + delete);

        //删除hash类型数据  删除所有
        Boolean delHash = redisTemplate.delete("hash");
        System.out.println("delHah:" + delHash);

    }

    /**
     * 操作List类型  有序 可重复
     */
    @Test
    public void operateList() {

        //左压栈
        // redisTemplate.opsForList().leftPush("list", "listValue1");
        // redisTemplate.opsForList().leftPush("list", "listValue1");
        // redisTemplate.opsForList().leftPush("list", "listValue2");
        // redisTemplate.opsForList().leftPush("list", "listValue3");

        //右压栈
        redisTemplate.opsForList().rightPush("list", "listValue0");
        redisTemplate.opsForList().rightPush("list", "listValue2");
        redisTemplate.opsForList().rightPush("list", "listValue0");

        //左出栈
        String list1 = redisTemplate.opsForList().leftPop("list");
        System.out.println("leftPop list1 = " + list1);
        //右出栈
        String list2 = redisTemplate.opsForList().rightPop("list");
        System.out.println("rightPop list2 = " + list2);

        //获取所有数据
        List<String> lists = redisTemplate.opsForList().range("list", 0, 		        redisTemplate.opsForList().size("list") - 1);
        lists.forEach(list -> System.out.println(list));


        //设置指定位置的数据
        redisTemplate.opsForList().set("list", 0, "listValue0");
        /**
         * 从存储在键中的列表中删除等于值的元素的第一个计数事件。
         * count> 0:删除等于从左到右移动的值的第一个元素;
         * count< 0:删除等于从右到左移动的值的第一个元素;
         * count = 0:删除等于value的所有元素。
         */
        Long remove = redisTemplate.opsForList().remove("list", -1, "listValue0");
        System.out.println("remove:" + remove);

        //删除指定key的list数据
        Boolean list = redisTemplate.delete("list");
        System.out.println("list集合删除成功:" + list);
    }

    /**
     * 操作Set类型  无序 不可重复
     */
    @Test
    public void operateSet() {

        //设置set值
        redisTemplate.opsForSet().add("set", "setValue0");
        redisTemplate.opsForSet().add("set", "setValue0");
        redisTemplate.opsForSet().add("set", "setValue1");

        //判定是否包含
        Boolean member = redisTemplate.opsForSet().isMember("set", "setValue0");
        System.out.println("isMember:" + member);

        //删除set中的值
        Long remove = redisTemplate.opsForSet().remove("set", "setValue0");
        System.out.println("remove = " + remove);

        //获取set类型值
        Set<String> set = redisTemplate.opsForSet().members("set");
        set.forEach(str -> {
            System.out.println("str = " + str);
        });
    }

    /**
     * 操作 ZSet  有序 不可重复
     */
    @Test
    public void operateZSet() {
        //存储值
        Boolean add = redisTemplate.opsForZSet().add("zset", "zsetValue0", 10);
        System.out.println("add = " + add);
        System.out.println("add = " + add);
        add = redisTemplate.opsForZSet().add("zset", "zsetValue2", 2);
        System.out.println("add = " + add);
        //获取值
        // Boolean zset = redisTemplate.delete("zset");
        // System.out.println("delete zset = " + zset);
    }
}
Salin selepas log masuk

Redis工具类的封装

/**
 * Redis 工具类
 * @author mosin
 * date 2021/11/30
 * @version 1.0
 */
@Component
public final class RedisUtil {

    private RedisUtil(){};
    @Autowired
    private RedisTemplate<String,String> redisTemplate;

    //设置值
    public void  setValue(String key,String value){
        redisTemplate.opsForValue().set(key, value);
    }
    // 设置值 同时设置有效时间
    public void setValue(String key, String value, Long timeOut, TimeUnit timeUnit){
        redisTemplate.opsForValue().setIfAbsent(key, value, timeOut, timeUnit);
    }

    //设置值 没有则设置 有则不设置
    public void  setNx(String key,String value){
        redisTemplate.opsForValue().setIfAbsent(key, value);
    }

    //设置值 没有则设置 同时设置有效时间 有则不设置
    public void  setNx(String key,String value,long timeOut,TimeUnit timeUnit){
        redisTemplate.opsForValue().setIfAbsent(key, value,timeOut,timeUnit);
    }

    //删除值
    public boolean del(String key){
        return redisTemplate.delete(key);
    }
    
     //获取值
    public String getValue(String key){
        return  redisTemplate.opsForValue().get(key);
    }
}
Salin selepas log masuk

Redis 业务实践

redis 存储 token,实现非法请求拦截

1.编写拦截器

@Component
public class AdminInterceptor implements HandlerInterceptor {
    @Autowired
    private RedisUtil redisUtil;
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        System.out.println("拦截器以拦截请求");
        //从请求头中获取token  验证用户是否登录
        String token = request.getHeader("token");
        System.out.println(token);
        String tokenValue = redisUtil.getValue(token);
        System.out.println("tokenValue = " + tokenValue);
        if(tokenValue!=null){ //用户已登录 放行请求
            return  true;
        }else{//重定向到登录页面
            response.sendRedirect(request.getContextPath()+"/login.jsp");
            return false;
        }
    }
}
Salin selepas log masuk

2.配置拦截器

@Configuration
public class LoginConfig implements WebMvcConfigurer {
    @Autowired
    private AdminInterceptor adminInterceptor;
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        InterceptorRegistration registration = registry.addInterceptor(adminInterceptor);
        registration.addPathPatterns("/**");
        registration.excludePathPatterns("/user/login","/user/register","/login.jsp");
    }
}
Salin selepas log masuk

3.编写统一返回数据格式类

@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class JsonResult<T> {
    private Integer code;
    private String msg;
    private Long count;
    private T data;
}
Salin selepas log masuk

4.编写控制器

@Controller
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;
    @Autowired
    private RedisUtil redisUtil;
    @ResponseBody
    @RequestMapping("/login")
    public Object login(User user) throws JsonProcessingException {
        User usr = User.builder().id(1).name("admin").password("123456").build();
        //获取token  放入redis
        String token = UUID.randomUUID().toString().replace("-", "");
        //将user 转为json格式放入 redis
        ObjectMapper objectMapper = new ObjectMapper();
        String s1 = objectMapper.writeValueAsString(usr);
        //将 token 和用户信息存入 redis
        redisUtil.setValue(token, s1, 2L, TimeUnit.MINUTES);
        //将token 存入map集合返回
        HashMap<String, String> map = new HashMap<>();
        map.put("token", token);
        return map;
    }

    @ResponseBody
    @RequestMapping("/register")
    public Object register(User user){
        HashMap<String, String> map = new HashMap<>();
        map.put("msg", "ok");
        return map;
    }

    @ResponseBody
    @RequestMapping("/add")
    public Object add(User user){
        HashMap<String, String> map = new HashMap<>();
        map.put("msg", "ok");
        return map;
    }
}
Salin selepas log masuk

5.编写业务类和Mapper接口

6.使用postman接口测试工具测试接口

Atas ialah kandungan terperinci Apakah kaedah untuk mengintegrasikan Redis dalam projek SpringBoot java?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:yisu.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan