首页 > 资讯 > 后端开发 > Python >springBoot整合redis使用案例详解

220

分享到

springBoot整合redis使用案例详解

2024-04-02 19:04:59 220人浏览薄情痞子

Python 官方文档：入门教程 => 点击学习

摘要

一、创建SpringBoot项目（采用骨架方式）创建完成；我们分析下pom文件中内容：所使用到的关键依赖： <!--springBoot集成Redis-

一、创建SpringBoot项目（采用骨架方式）

在这里插入图片描述

创建完成；
我们分析下pom文件中内容：
所使用到的关键依赖：


 <!--springBoot集成Redis-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>2.5.4</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-WEB</artifactId>
            <version>2.5.4</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.20</version>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.5.4</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
            <version>2.5.4</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastJSON</artifactId>
            <version>1.2.75</version>
        </dependency>

二、配置文件


server.port=8088
spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=6379
#Redis服务器连接密码（默认为空）
spring.redis.passWord=123456
#连接池最大连接数（使用负值表示没有限制）
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=30000

三、使用redis


package com.example.redis.cache;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.util.Collection;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;


@Slf4j
@Component
public class CacheService {
    @Autowired
    private StringRedisTemplate redisTemplate;

    private final String DEFAULT_KEY_PREFIX = "";
    private final int EXPIRE_TIME = 1;
    private final TimeUnit EXPIRE_TIME_TYPE = TimeUnit.DAYS;


    
    public <K, V> void add(K key, V value) {
        try {
            if (value != null) {
                redisTemplate
                        .opsForValue()
                        .set(DEFAULT_KEY_PREFIX + key, JSON.toJSONString(value));
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            throw new RuntimeException("数据缓存至redis失败");
        }
    }

    
    public <K, V> void add(K key, V value, long timeout, TimeUnit unit) {
        try {
            if (value != null) {
                redisTemplate
                        .opsForValue()
                        .set(DEFAULT_KEY_PREFIX + key, JSON.toJSONString(value), timeout, unit);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            throw new RuntimeException("数据缓存至redis失败");
        }
    }

    
    public <K, SK, V> void addHashCache(K key, SK subKey, V value) {
        redisTemplate.opsForHash().put(DEFAULT_KEY_PREFIX + key, subKey, value);
    }

    
    public <K, SK, V> void addHashCache(K key, SK subKey, V value, long timeout, TimeUnit unit) {
        redisTemplate.opsForHash().put(DEFAULT_KEY_PREFIX + key, subKey, value);
        redisTemplate.expire(DEFAULT_KEY_PREFIX + key, timeout, unit);
    }

    
    public <K, SK> Object getHashCache(K key, SK subKey) {
        return  redisTemplate.opsForHash().get(DEFAULT_KEY_PREFIX + key, subKey);
    }


    
    public <K, V> V getObject(K key, Class<V> clazz) {
        String value = this.get(key);
        V result = null;
        if (!StringUtils.isEmpty(value)) {
            result = JSONObject.parseObject(value, clazz);
        }
        return result;
    }

    
    public <K, V> List<V> getList(K key, Class<V> clazz) {
        String value = this.get(key);
        List<V> result = Collections.emptyList();
        if (!StringUtils.isEmpty(value)) {
            result = JSONArray.parseArray(value, clazz);
        }
        return result;
    }

    
    public <K> String get(K key) {
        String value;
        try {
            value = redisTemplate.opsForValue().get(DEFAULT_KEY_PREFIX + key);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            throw new RuntimeException("从redis缓存中获取缓存数据失败");
        }
        return value;
    }

    
    public void delete(String key) {
        redisTemplate.delete(key);
    }

    
    public void delete(Collection<String> keys) {
        redisTemplate.delete(keys);
    }

    
    public byte[] dump(String key) {
        return redisTemplate.dump(key);
    }

    
    public Boolean hasKey(String key) {
        return redisTemplate.hasKey(key);
    }

    
    public Boolean expire(String key, long timeout, TimeUnit unit) {
        return redisTemplate.expire(key, timeout, unit);
    }

    
    public Boolean expireAt(String key, Date date) {
        return redisTemplate.expireAt(key, date);
    }


    
    public Boolean persist(String key) {
        return redisTemplate.persist(key);
    }

    
    public Long getExpire(String key, TimeUnit unit) {
        return redisTemplate.getExpire(key, unit);
    }

    
    public Long getExpire(String key) {
        return redisTemplate.getExpire(key);
    }
}

1、添加字符串到redis


 
    @Test
    void add() {
        cacheService.add("test", 1234);
    }

结果：

在这里插入图片描述

2、将对象转换成jsonString并存入redis


 
    @Test
    void addObject() {
        User user = User.builder()
                .id(ID)
                .name("小萌")
                .age(AGE)
                .build();
        cacheService.add(user.getId(), user);
    }

结果：

在这里插入图片描述

3、将对象集合转换成jsonString，并设置过期时间存入至redis


 
    @Test
    void addObjects() {
        ArrayList<User> users = new ArrayList<>();
        User user = User.builder()
                .id(ID)
                .name("小萌")
                .age(AGE)
                .build();
        users.add(user);
        cacheService.add("key", users, 1, TimeUnit.HOURS);
    }

结果：

在这里插入图片描述

4、获取对象



    @Test
    void getObject() {
        User object = cacheService.getObject(ID, User.class);
        System.out.println("object = " + object);
    }

结果：

object = User(id=123, name=小萌, age=12)

5、获取对象集合


 
    @Test
    void getObjects() {
        List<User> users = cacheService.getList("key", User.class);
        System.out.println("users = " + users);
    }

结果：

users = [User(id=123, name=小萌, age=12)]

6、添加 hash-set



    @Test
    void addHashCache() {
        cacheService.addHashCache("hashKey", "key", "value");
    }

结果：

在这里插入图片描述

7、获取 hash-setvalue



    public <K, SK> Object getHashCache(K key, SK subKey) {
        return  redisTemplate.opsForHash().get(DEFAULT_KEY_PREFIX + key, subKey);
    }

结果：

hashCache = value

到此这篇关于springBoot整合redis使用案例详解的文章就介绍到这了,更多相关springBoot整合redis使用内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: springBoot整合redis使用案例详解

本文链接: https://www.lsjlt.com/news/154324.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

python分析数据的方法是什么

2024-03-01

如何使用Python实现抽奖小程序

2024-03-01

python copy函数的作用是什么

2024-03-01

python进程池创建队列的方法是什么

2024-02-29

python字符串处理与应用的方法有哪些

2024-02-29

python全局变量如何定义

2024-02-29

python如何读取文件夹下所有文件

2024-02-29

python keyerror错误怎么解决

2024-02-29

python如何提取字符串的数字

2024-02-29

python中怎么将回车作为输入内容

2024-02-29

热门问答

回答

如何调试操作系统的错误？
操作系统

2023-11-15发布

回答

操作系统中的I/O系统是如何实现的？
操作系统

2023-11-15发布

回答

如何实现操作系统的内存管理？
操作系统

2023-11-15发布

回答

什么是虚拟内存，它对操作系统有什么影响？
操作系统

2023-11-15发布

回答

ASP中的MVC架构和WebForms架构有什么区别和使用场景？
ASP.NET

2023-11-15发布

回答

ASP中的数据验证和数据校验有什么不同？
ASP.NET

2023-11-15发布

回答

ASP中的ADO对象和DAO对象有什么区别和使用方法？
ASP.NET

2023-11-15发布

回答

Node.js中的包管理器NPM是什么？如何使用它进行依赖管理？
node.js

2023-11-15发布

回答

Vue.js中的动态组件是什么？如何使用它来动态渲染组件？
VUE

2023-11-15发布

回答

如何使用Vue.js实现懒加载和预加载？
VUE

2023-11-15发布

springBoot整合redis使用案例详解

一、创建SpringBoot项目（采用骨架方式）

二、配置文件

三、使用redis

本篇文章演示代码以及资料文档资料下载

springBoot整合redis使用案例详解

SpringBoot整合Redis案例分析

SpringBoot整合Druid、Redis的示例详解

SpringBoot示例代码整合Redis详解

springboot详解整合swagger方案

基于Redis结合SpringBoot的秒杀案例详解

如何用SpringBoot整合Redis（详细讲解~）

springboot整合quartz项目使用案例

SpringBoot详解整合Redis缓存方法

SpringBoot项目整合Redis教程详解

使用SpringBoot中整合Redis

详解SpringBoot开发案例之整合定时任务(Scheduled)

java、spring、springboot中整合Redis的详细讲解

SpringBoot整合Security实现权限控制框架(案例详解)

SpringBoot整合Redis使用@Cacheable和RedisTemplate

SpringBoot整合Redis使用RedisTemplate和StringRedisTemplate

Springboot详解如何整合使用Thymeleaf

SpringBoot详解如何整合Redis缓存验证码

Java Springboot websocket使用案例详解

Maven的porfile与SpringBoot的profile结合使用案例详解

python分析数据的方法是什么

如何使用Python实现抽奖小程序

python copy函数的作用是什么

python进程池创建队列的方法是什么

python字符串处理与应用的方法有哪些

python全局变量如何定义

python如何读取文件夹下所有文件

python keyerror错误怎么解决

python如何提取字符串的数字

python中怎么将回车作为输入内容