SpringBoot(六)：SpringBoot整合Redis

迷南。 2022-04-23 23:16 195阅读 0赞

From: [https://blog.csdn.net/plei\_yue/article/details/79362372][https_blog.csdn.net_plei_yue_article_details_79362372]

前言

在本篇文章中将SpringBoot整合Redis，使用的是RedisTemplate，分别实现了SpringBoot与redis的单机版、集群版、哨兵模式的整合。  
Maven依赖

<dependency>  
<groupId>org.springframework.boot</groupId>  
<artifactId>spring-boot-starter-data-redis</artifactId>  
</dependency>

1  
2  
3  
4  
5

项目下载及目录结构

1.\[SpringBoot整合Redis实例\]  
(http://download.csdn.net/download/plei\_yue/10257285)  
这里写图片描述  
2.Redis安装和相关配置参考  
修改配置文件

创建一个redis.properties配置文件。

\#Matser的ip地址  
redis.hostName=192.168.177.128  
\#端口号  
redis.port=6382  
\#如果有密码  
redis.password=  
\#客户端超时时间单位是毫秒 默认是2000  
redis.timeout=10000

\#最大空闲数  
redis.maxIdle=300  
\#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal  
\#redis.maxActive=600  
\#控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性  
redis.maxTotal=1000  
\#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。  
redis.maxWaitMillis=1000  
\#连接的最小空闲时间 默认1800000毫秒(30分钟)  
redis.minEvictableIdleTimeMillis=300000  
\#每次释放连接的最大数目,默认3  
redis.numTestsPerEvictionRun=1024  
\#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1  
redis.timeBetweenEvictionRunsMillis=30000  
\#是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个  
redis.testOnBorrow=true  
\#在空闲时检查有效性, 默认false  
redis.testWhileIdle=true

\#redis集群配置  
spring.redis.cluster.nodes=192.168.177.128:7001,192.168.177.128:7002,192.168.177.128:7003,192.168.177.128:7004,192.168.177.128:7005,192.168.177.128:7006  
spring.redis.cluster.max-redirects=3

\#哨兵模式  
\#redis.sentinel.host1=192.168.177.128  
\#redis.sentinel.port1=26379

\#redis.sentinel.host2=172.20.1.231  
\#redis.sentinel.port2=26379

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

封装RedisTemplate的RedisUtil类

import java.util.List;  
import java.util.Map;  
import java.util.Set;  
import java.util.concurrent.TimeUnit;

import org.springframework.data.redis.core.RedisTemplate;  
import org.springframework.util.CollectionUtils;

public class RedisUtil \{

private RedisTemplate<String, Object> redisTemplate;

public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) \{  
this.redisTemplate = redisTemplate;  
\}  
//=============================common============================  
/\*\*  
\* 指定缓存失效时间  
\* @param key 键  
\* @param time 时间(秒)  
\* @return  
\*/  
public boolean expire(String key,long time)\{  
try \{  
if(time>0)\{  
redisTemplate.expire(key, time, TimeUnit.SECONDS);  
\}  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 根据key 获取过期时间  
\* @param key 键 不能为null  
\* @return 时间(秒) 返回0代表为永久有效  
\*/  
public long getExpire(String key)\{  
return redisTemplate.getExpire(key,TimeUnit.SECONDS);  
\}

/\*\*  
\* 判断key是否存在  
\* @param key 键  
\* @return true 存在 false不存在  
\*/  
public boolean hasKey(String key)\{  
try \{  
return redisTemplate.hasKey(key);  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 删除缓存  
\* @param key 可以传一个值 或多个  
\*/  
@SuppressWarnings("unchecked")  
public void del(String ... key)\{  
if(key!=null&&key.length>0)\{  
if(key.length==1)\{  
redisTemplate.delete(key\[0\]);  
\}else\{  
redisTemplate.delete(CollectionUtils.arrayToList(key));  
\}  
\}  
\}

//============================String=============================  
/\*\*  
\* 普通缓存获取  
\* @param key 键  
\* @return 值  
\*/  
public Object get(String key)\{  
return key==null?null:redisTemplate.opsForValue().get(key);  
\}

/\*\*  
\* 普通缓存放入  
\* @param key 键  
\* @param value 值  
\* @return true成功 false失败  
\*/  
public boolean set(String key,Object value) \{  
try \{  
redisTemplate.opsForValue().set(key, value);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}

/\*\*  
\* 普通缓存放入并设置时间  
\* @param key 键  
\* @param value 值  
\* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期  
\* @return true成功 false 失败  
\*/  
public boolean set(String key,Object value,long time)\{  
try \{  
if(time>0)\{  
redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);  
\}else\{  
set(key, value);  
\}  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 递增  
\* @param key 键  
\* @param by 要增加几(大于0)  
\* @return  
\*/  
public long incr(String key, long delta)\{  
if(delta<0)\{  
throw new RuntimeException("递增因子必须大于0");  
\}  
return redisTemplate.opsForValue().increment(key, delta);  
\}

/\*\*  
\* 递减  
\* @param key 键  
\* @param by 要减少几(小于0)  
\* @return  
\*/  
public long decr(String key, long delta)\{  
if(delta<0)\{  
throw new RuntimeException("递减因子必须大于0");  
\}  
return redisTemplate.opsForValue().increment(key, -delta);  
\}

//================================Map=================================  
/\*\*  
\* HashGet  
\* @param key 键 不能为null  
\* @param item 项 不能为null  
\* @return 值  
\*/  
public Object hget(String key,String item)\{  
return redisTemplate.opsForHash().get(key, item);  
\}

/\*\*  
\* 获取hashKey对应的所有键值  
\* @param key 键  
\* @return 对应的多个键值  
\*/  
public Map<Object,Object> hmget(String key)\{  
return redisTemplate.opsForHash().entries(key);  
\}

/\*\*  
\* HashSet  
\* @param key 键  
\* @param map 对应多个键值  
\* @return true 成功 false 失败  
\*/  
public boolean hmset(String key, Map<String,Object> map)\{  
try \{  
redisTemplate.opsForHash().putAll(key, map);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* HashSet 并设置时间  
\* @param key 键  
\* @param map 对应多个键值  
\* @param time 时间(秒)  
\* @return true成功 false失败  
\*/  
public boolean hmset(String key, Map<String,Object> map, long time)\{  
try \{  
redisTemplate.opsForHash().putAll(key, map);  
if(time>0)\{  
expire(key, time);  
\}  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 向一张hash表中放入数据,如果不存在将创建  
\* @param key 键  
\* @param item 项  
\* @param value 值  
\* @return true 成功 false失败  
\*/  
public boolean hset(String key,String item,Object value) \{  
try \{  
redisTemplate.opsForHash().put(key, item, value);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 向一张hash表中放入数据,如果不存在将创建  
\* @param key 键  
\* @param item 项  
\* @param value 值  
\* @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间  
\* @return true 成功 false失败  
\*/  
public boolean hset(String key,String item,Object value,long time) \{  
try \{  
redisTemplate.opsForHash().put(key, item, value);  
if(time>0)\{  
expire(key, time);  
\}  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 删除hash表中的值  
\* @param key 键 不能为null  
\* @param item 项 可以使多个 不能为null  
\*/  
public void hdel(String key, Object... item)\{  
redisTemplate.opsForHash().delete(key,item);  
\}

/\*\*  
\* 判断hash表中是否有该项的值  
\* @param key 键 不能为null  
\* @param item 项 不能为null  
\* @return true 存在 false不存在  
\*/  
public boolean hHasKey(String key, String item)\{  
return redisTemplate.opsForHash().hasKey(key, item);  
\}

/\*\*  
\* hash递增 如果不存在,就会创建一个 并把新增后的值返回  
\* @param key 键  
\* @param item 项  
\* @param by 要增加几(大于0)  
\* @return  
\*/  
public double hincr(String key, String item,double by)\{  
return redisTemplate.opsForHash().increment(key, item, by);  
\}

/\*\*  
\* hash递减  
\* @param key 键  
\* @param item 项  
\* @param by 要减少记(小于0)  
\* @return  
\*/  
public double hdecr(String key, String item,double by)\{  
return redisTemplate.opsForHash().increment(key, item,-by);  
\}

//============================set=============================  
/\*\*  
\* 根据key获取Set中的所有值  
\* @param key 键  
\* @return  
\*/  
public Set<Object> sGet(String key)\{  
try \{  
return redisTemplate.opsForSet().members(key);  
\} catch (Exception e) \{  
e.printStackTrace();  
return null;  
\}  
\}

/\*\*  
\* 根据value从一个set中查询,是否存在  
\* @param key 键  
\* @param value 值  
\* @return true 存在 false不存在  
\*/  
public boolean sHasKey(String key,Object value)\{  
try \{  
return redisTemplate.opsForSet().isMember(key, value);  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 将数据放入set缓存  
\* @param key 键  
\* @param values 值 可以是多个  
\* @return 成功个数  
\*/  
public long sSet(String key, Object...values) \{  
try \{  
return redisTemplate.opsForSet().add(key, values);  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}

/\*\*  
\* 将set数据放入缓存  
\* @param key 键  
\* @param time 时间(秒)  
\* @param values 值 可以是多个  
\* @return 成功个数  
\*/  
public long sSetAndTime(String key,long time,Object...values) \{  
try \{  
Long count = redisTemplate.opsForSet().add(key, values);  
if(time>0) expire(key, time);  
return count;  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}

/\*\*  
\* 获取set缓存的长度  
\* @param key 键  
\* @return  
\*/  
public long sGetSetSize(String key)\{  
try \{  
return redisTemplate.opsForSet().size(key);  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}

/\*\*  
\* 移除值为value的  
\* @param key 键  
\* @param values 值 可以是多个  
\* @return 移除的个数  
\*/  
public long setRemove(String key, Object ...values) \{  
try \{  
Long count = redisTemplate.opsForSet().remove(key, values);  
return count;  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}  
//===============================list=================================

/\*\*  
\* 获取list缓存的内容  
\* @param key 键  
\* @param start 开始  
\* @param end 结束 0 到 -1代表所有值  
\* @return  
\*/  
public List<Object> lGet(String key,long start, long end)\{  
try \{  
return redisTemplate.opsForList().range(key, start, end);  
\} catch (Exception e) \{  
e.printStackTrace();  
return null;  
\}  
\}

/\*\*  
\* 获取list缓存的长度  
\* @param key 键  
\* @return  
\*/  
public long lGetListSize(String key)\{  
try \{  
return redisTemplate.opsForList().size(key);  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}

/\*\*  
\* 通过索引 获取list中的值  
\* @param key 键  
\* @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推  
\* @return  
\*/  
public Object lGetIndex(String key,long index)\{  
try \{  
return redisTemplate.opsForList().index(key, index);  
\} catch (Exception e) \{  
e.printStackTrace();  
return null;  
\}  
\}

/\*\*  
\* 将list放入缓存  
\* @param key 键  
\* @param value 值  
\* @param time 时间(秒)  
\* @return  
\*/  
public boolean lSet(String key, Object value) \{  
try \{  
redisTemplate.opsForList().rightPush(key, value);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 将list放入缓存  
\* @param key 键  
\* @param value 值  
\* @param time 时间(秒)  
\* @return  
\*/  
public boolean lSet(String key, Object value, long time) \{  
try \{  
redisTemplate.opsForList().rightPush(key, value);  
if (time > 0) expire(key, time);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 将list放入缓存  
\* @param key 键  
\* @param value 值  
\* @param time 时间(秒)  
\* @return  
\*/  
public boolean lSet(String key, List<Object> value) \{  
try \{  
redisTemplate.opsForList().rightPushAll(key, value);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 将list放入缓存  
\* @param key 键  
\* @param value 值  
\* @param time 时间(秒)  
\* @return  
\*/  
public boolean lSet(String key, List<Object> value, long time) \{  
try \{  
redisTemplate.opsForList().rightPushAll(key, value);  
if (time > 0) expire(key, time);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 根据索引修改list中的某条数据  
\* @param key 键  
\* @param index 索引  
\* @param value 值  
\* @return  
\*/  
public boolean lUpdateIndex(String key, long index,Object value) \{  
try \{  
redisTemplate.opsForList().set(key, index, value);  
return true;  
\} catch (Exception e) \{  
e.printStackTrace();  
return false;  
\}  
\}

/\*\*  
\* 移除N个值为value  
\* @param key 键  
\* @param count 移除多少个  
\* @param value 值  
\* @return 移除的个数  
\*/  
public long lRemove(String key,long count,Object value) \{  
try \{  
Long remove = redisTemplate.opsForList().remove(key, count, value);  
return remove;  
\} catch (Exception e) \{  
e.printStackTrace();  
return 0;  
\}  
\}  
\}

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  
221  
222  
223  
224  
225  
226  
227  
228  
229  
230  
231  
232  
233  
234  
235  
236  
237  
238  
239  
240  
241  
242  
243  
244  
245  
246  
247  
248  
249  
250  
251  
252  
253  
254  
255  
256  
257  
258  
259  
260  
261  
262  
263  
264  
265  
266  
267  
268  
269  
270  
271  
272  
273  
274  
275  
276  
277  
278  
279  
280  
281  
282  
283  
284  
285  
286  
287  
288  
289  
290  
291  
292  
293  
294  
295  
296  
297  
298  
299  
300  
301  
302  
303  
304  
305  
306  
307  
308  
309  
310  
311  
312  
313  
314  
315  
316  
317  
318  
319  
320  
321  
322  
323  
324  
325  
326  
327  
328  
329  
330  
331  
332  
333  
334  
335  
336  
337  
338  
339  
340  
341  
342  
343  
344  
345  
346  
347  
348  
349  
350  
351  
352  
353  
354  
355  
356  
357  
358  
359  
360  
361  
362  
363  
364  
365  
366  
367  
368  
369  
370  
371  
372  
373  
374  
375  
376  
377  
378  
379  
380  
381  
382  
383  
384  
385  
386  
387  
388  
389  
390  
391  
392  
393  
394  
395  
396  
397  
398  
399  
400  
401  
402  
403  
404  
405  
406  
407  
408  
409  
410  
411  
412  
413  
414  
415  
416  
417  
418  
419  
420  
421  
422  
423  
424  
425  
426  
427  
428  
429  
430  
431  
432  
433  
434  
435  
436  
437  
438  
439  
440  
441  
442  
443  
444  
445  
446  
447  
448  
449  
450  
451  
452  
453  
454  
455  
456  
457  
458  
459  
460  
461  
462  
463  
464  
465  
466  
467  
468  
469  
470  
471  
472  
473  
474  
475  
476  
477  
478  
479  
480  
481  
482  
483  
484  
485  
486  
487  
488  
489  
490  
491  
492  
493  
494  
495  
496  
497  
498  
499  
500  
501  
502  
503  
504  
505  
506  
507  
508  
509  
510  
511  
512  
513  
514  
515  
516  
517  
518  
519  
520  
521  
522  
523  
524

SpringBoot整合单机版redis

如果我们只需要整合redis的单机版，只要在redis.conf中进行如下配置

@Configuration  
@PropertySource("classpath:config/redis.properties")  
public class RedisConfig \{

@Value("$\{redis.maxIdle\}")  
private Integer maxIdle;

@Value("$\{redis.maxTotal\}")  
private Integer maxTotal;

@Value("$\{redis.maxWaitMillis\}")  
private Integer maxWaitMillis;

@Value("$\{redis.minEvictableIdleTimeMillis\}")  
private Integer minEvictableIdleTimeMillis;

@Value("$\{redis.numTestsPerEvictionRun\}")  
private Integer numTestsPerEvictionRun;

@Value("$\{redis.timeBetweenEvictionRunsMillis\}")  
private long timeBetweenEvictionRunsMillis;

@Value("$\{redis.testOnBorrow\}")  
private boolean testOnBorrow;

@Value("$\{redis.testWhileIdle\}")  
private boolean testWhileIdle;

@Value("$\{spring.redis.cluster.nodes\}")  
private String clusterNodes;

@Value("$\{spring.redis.cluster.max-redirects\}")  
private Integer mmaxRedirectsac;

/\*\*  
\* 实例化 RedisTemplate 对象  
\*  
\* @return  
\*/  
@Bean  
public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) \{  
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();  
initDomainRedisTemplate(redisTemplate, redisConnectionFactory);  
return redisTemplate;  
\}  
/\*\*  
\* 设置数据存入 redis 的序列化方式,并开启事务  
\*  
\* @param redisTemplate  
\* @param factory  
\*/  
private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) \{  
//如果不配置Serializer，那么存储的时候缺省使用String，如果用User类型存储，那么会提示错误User can't cast to String！  
redisTemplate.setKeySerializer(new StringRedisSerializer());  
redisTemplate.setHashKeySerializer(new StringRedisSerializer());  
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());  
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());  
// 开启事务  
redisTemplate.setEnableTransactionSupport(true);  
redisTemplate.setConnectionFactory(factory);  
\}  
/\*\*  
\* 注入封装RedisTemplate  
\* @Title: redisUtil  
\* @return RedisUtil  
\* @autor lpl  
\* @date 2017年12月21日  
\* @throws  
\*/  
@Bean(name = "redisUtil")  
public RedisUtil redisUtil(RedisTemplate<String, Object> redisTemplate) \{  
RedisUtil redisUtil = new RedisUtil();  
redisUtil.setRedisTemplate(redisTemplate);  
return redisUtil;  
\}

SpringBoot整合Redis-Cluster集群