个人中心
gpt4 book ai didi

springBoot整合redis使用案例详解

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 35 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章springBoot整合redis使用案例详解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

1、创建springboot项目（采用骨架方式）

springBoot整合redis使用案例详解
springBoot整合redis使用案例详解
springBoot整合redis使用案例详解
springBoot整合redis使用案例详解
springBoot整合redis使用案例详解
springBoot整合redis使用案例详解

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
<!--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>

2、配置文件

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
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

3、使用redis

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
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;
 
/**
  * @author wxl
  * @date 2021-08-15 18:44
  */
@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;
 
 
     /**
      * 数据缓存至redis
      *
      * @param key
      * @param value
      * @return
      */
     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失败" );
         }
     }
 
     /**
      * 数据缓存至redis并设置过期时间
      *
      * @param key
      * @param value
      * @return
      */
     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失败" );
         }
     }
 
     /**
      * 写入 hash-set,已经是key-value的键值，不能再写入为hash-set
      *
      * @param key    must not be {@literal null}.
      * @param subKey must not be {@literal null}.
      * @param value  写入的值
      */
     public <K, SK, V> void addHashCache(K key, SK subKey, V value) {
         redisTemplate.opsForHash().put(DEFAULT_KEY_PREFIX + key, subKey, value);
     }
 
     /**
      * 写入 hash-set,并设置过期时间
      *
      * @param key    must not be {@literal null}.
      * @param subKey must not be {@literal null}.
      * @param 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);
     }
 
     /**
      * 获取 hash-setvalue
      *
      * @param key    must not be {@literal null}.
      * @param subKey must not be {@literal null}.
      */
     public <K, SK> Object getHashCache(K key, SK subKey) {
         return  redisTemplate.opsForHash().get(DEFAULT_KEY_PREFIX + key, subKey);
     }
 
 
     /**
      * 从redis中获取缓存数据，转成对象
      *
      * @param key   must not be {@literal null}.
      * @param clazz 对象类型
      * @return
      */
     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;
     }
 
     /**
      * 从redis中获取缓存数据，转成list
      *
      * @param key   must not be {@literal null}.
      * @param clazz 对象类型
      * @return
      */
     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;
     }
 
     /**
      * 功能描述：Get the value of {@code key}.
      *
      * @param key must not be {@literal null}.
      * @return java.lang.String
      * @date 2021/9/19
      **/
     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;
     }
 
     /**
      * 删除key
      */
     public void delete(String key) {
         redisTemplate.delete(key);
     }
 
     /**
      * 批量删除key
      */
     public void delete(Collection<String> keys) {
         redisTemplate.delete(keys);
     }
 
     /**
      * 序列化key
      */
     public byte [] dump(String key) {
         return redisTemplate.dump(key);
     }
 
     /**
      * 是否存在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);
     }
 
 
     /**
      * 移除 key 的过期时间，key 将持久保持
      */
     public Boolean persist(String key) {
         return redisTemplate.persist(key);
     }
 
     /**
      * 返回 key 的剩余的过期时间
      */
     public Long getExpire(String key, TimeUnit unit) {
         return redisTemplate.getExpire(key, unit);
     }
 
     /**
      * 返回 key 的剩余的过期时间
      */
     public Long getExpire(String key) {
         return redisTemplate.getExpire(key);
     }
}

1、添加字符串到redis 。

?
1
2
3
4
5
6
7
/**
     * 功能描述：添加字符串到redis
     */
    @Test
    void add() {
        cacheService.add( "test" , 1234 );
    }

结果:

springBoot整合redis使用案例详解

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

?
1
2
3
4
5
6
7
8
9
10
11
12
/**
     * 功能描述：添加对象至redis
     */
    @Test
    void addObject() {
        User user = User.builder()
                .id(ID)
                .name( "小萌" )
                .age(AGE)
                .build();
        cacheService.add(user.getId(), user);
    }

结果:

springBoot整合redis使用案例详解

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
/**
     * 功能描述：添加对象集合至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);
    }

结果:

springBoot整合redis使用案例详解

4、获取对象 。

?
1
2
3
4
5
6
7
8
/**
      * 功能描述：获取对象
      */
     @Test
     void getObject() {
         User object = cacheService.getObject(ID, User. class );
         System.out.println( "object = " + object);
     }

结果:

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

5、获取对象集合 。

?
1
2
3
4
5
6
7
8
/**
     * 功能描述：获取对象集合
     */
    @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 。

?
1
2
3
4
5
6
7
/**
      * 功能描述：添加 hash-set
      */
     @Test
     void addHashCache() {
         cacheService.addHashCache( "hashKey" , "key" , "value" );
     }

结果:

springBoot整合redis使用案例详解

7、获取 hash-setvalue 。

?
1
2
3
4
5
6
7
8
9
/**
      * 获取 hash-setvalue
      *
      * @param key    must not be {@literal null}.
      * @param subKey must not be {@literal null}.
      */
     public <K, SK> Object getHashCache(K key, SK subKey) {
         return  redisTemplate.opsForHash().get(DEFAULT_KEY_PREFIX + key, subKey);
     }

结果:

hashCache = value 。

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

原文链接：https://blog.csdn.net/weixin_43811057/article/details/120382906 。

最后此篇关于springBoot整合redis使用案例详解的文章就讲到这里了,如果你想了解更多关于springBoot整合redis使用案例详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

35 4 0
文章推荐： Java基础之不简单的数组
文章推荐： MySQL多版本并发控制MVCC底层原理解析
文章推荐： MySQL之高可用架构详解
文章推荐： SpringBootTest--踩坑错误的解决
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com