1. 程式人生 > >spring+redis的整合,使用spring-data-redis來整合

spring+redis的整合,使用spring-data-redis來整合

1、參考:https://www.cnblogs.com/qlqwjy/p/8562703.html 

2、首先建立一個maven專案。然後加入依賴的jar包就行了。我加入的jar包很多,反正加入了也沒啥壞的影響。

  1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd
"> 3 <modelVersion>4.0.0</modelVersion> 4 <groupId>com.charts</groupId> 5 <artifactId>com.fline.aic.charts</artifactId> 6 <packaging>war</packaging> 7 <version>0.0.1-SNAPSHOT</version> 8 <name>com.fline.aic.charts Maven Webapp</name> 9
<url>http://maven.apache.org</url> 10 11 <dependencies> 12 <dependency> 13 <groupId>junit</groupId> 14 <artifactId>junit</artifactId> 15 <version>3.8.1</version> 16 <scope>test</scope> 17
</dependency> 18 <!-- https://mvnrepository.com/artifact/log4j/log4j --> 19 <dependency> 20 <groupId>log4j</groupId> 21 <artifactId>log4j</artifactId> 22 <version>1.2.17</version> 23 </dependency> 24 <!-- https://mvnrepository.com/artifact/com.github.kstyrc/embedded-redis --> 25 <dependency> 26 <groupId>com.github.kstyrc</groupId> 27 <artifactId>embedded-redis</artifactId> 28 <version>0.6</version> 29 <scope>test</scope> 30 </dependency> 31 <!-- https://mvnrepository.com/artifact/redis.clients/jedis --> 32 <dependency> 33 <groupId>redis.clients</groupId> 34 <artifactId>jedis</artifactId> 35 <version>2.9.0</version> 36 </dependency> 37 <!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-redis --> 38 <dependency> 39 <groupId>org.springframework.data</groupId> 40 <artifactId>spring-data-redis</artifactId> 41 <version>1.7.2.RELEASE</version> 42 </dependency> 43 <!-- https://mvnrepository.com/artifact/commons-pool/commons-pool --> 44 <dependency> 45 <groupId>commons-pool</groupId> 46 <artifactId>commons-pool</artifactId> 47 <version>1.5.4</version> 48 </dependency> 49 <dependency> 50 <groupId>com.fasterxml.jackson.core</groupId> 51 <artifactId>jackson-core</artifactId> 52 <version>2.1.0</version> 53 </dependency> 54 <dependency> 55 <groupId>com.fasterxml.jackson.core</groupId> 56 <artifactId>jackson-databind</artifactId> 57 <version>2.1.0</version> 58 </dependency> 59 <dependency> 60 <groupId>com.fasterxml.jackson.core</groupId> 61 <artifactId>jackson-annotations</artifactId> 62 <version>2.1.0</version> 63 </dependency> 64 65 <!-- https://mvnrepository.com/artifact/org.springframework/spring-core --> 66 <dependency> 67 <groupId>org.springframework</groupId> 68 <artifactId>spring-core</artifactId> 69 <version>4.3.18.RELEASE</version> 70 </dependency> 71 <!-- https://mvnrepository.com/artifact/org.springframework/spring-context --> 72 <dependency> 73 <groupId>org.springframework</groupId> 74 <artifactId>spring-context</artifactId> 75 <version>4.3.18.RELEASE</version> 76 </dependency> 77 <!-- https://mvnrepository.com/artifact/org.springframework/spring-web --> 78 <dependency> 79 <groupId>org.springframework</groupId> 80 <artifactId>spring-web</artifactId> 81 <version>4.3.18.RELEASE</version> 82 </dependency> 83 <!-- https://mvnrepository.com/artifact/org.springframework/spring-aop --> 84 <dependency> 85 <groupId>org.springframework</groupId> 86 <artifactId>spring-aop</artifactId> 87 <version>4.3.18.RELEASE</version> 88 </dependency> 89 <!-- https://mvnrepository.com/artifact/org.springframework/spring-webmvc --> 90 <dependency> 91 <groupId>org.springframework</groupId> 92 <artifactId>spring-webmvc</artifactId> 93 <version>4.3.18.RELEASE</version> 94 </dependency> 95 <!-- https://mvnrepository.com/artifact/org.springframework/spring-beans --> 96 <dependency> 97 <groupId>org.springframework</groupId> 98 <artifactId>spring-beans</artifactId> 99 <version>4.3.18.RELEASE</version> 100 </dependency> 101 <!-- https://mvnrepository.com/artifact/org.springframework/spring-jdbc --> 102 <dependency> 103 <groupId>org.springframework</groupId> 104 <artifactId>spring-jdbc</artifactId> 105 <version>4.3.18.RELEASE</version> 106 </dependency> 107 <!-- https://mvnrepository.com/artifact/org.springframework/spring-webmvc --> 108 <dependency> 109 <groupId>org.springframework</groupId> 110 <artifactId>spring-webmvc</artifactId> 111 <version>4.3.18.RELEASE</version> 112 </dependency> 113 <!-- https://mvnrepository.com/artifact/org.springframework/spring-test --> 114 <dependency> 115 <groupId>org.springframework</groupId> 116 <artifactId>spring-test</artifactId> 117 <version>4.3.18.RELEASE</version> 118 <scope>test</scope> 119 </dependency> 120 <dependency> 121 <groupId>org.aspectj</groupId> 122 <artifactId>aspectjweaver</artifactId> 123 <version>1.8.13</version> 124 </dependency> 125 126 </dependencies> 127 <build> 128 <finalName>com.fline.aic.charts</finalName> 129 </build> 130 131 132 133 </project>

 3、然後在web.xml裡面配置一下Spring框架listener配置。

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://xmlns.jcp.org/xml/ns/javaee" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" id="WebApp_ID" version="3.1">
 3   <display-name>Spring_Struts2_20170313</display-name>
 4   <welcome-file-list>
 5     <welcome-file>index.html</welcome-file>
 6     <welcome-file>index.htm</welcome-file>
 7     <welcome-file>index.jsp</welcome-file>
 8     <welcome-file>default.html</welcome-file>
 9     <welcome-file>default.htm</welcome-file>
10     <welcome-file>default.jsp</welcome-file>
11   </welcome-file-list>
12 
13   
14   <!-- 1:spring配置 ,在spring-framework-3.2.5.RELEASE\docs\spring-framework-reference\htmlsingle
15                              搜尋context-param找到下面這段話即可。記得就該param-value的值,如下所示;
16          2:param-value的值最好使用bean,這樣方便引用如/WEB-INF/classes/bean-*.xml   
17   -->
18   <context-param>
19     <param-name>contextConfigLocation</param-name>
20     <!-- <param-value>classpath:applicationContext.xml</param-value> -->
21     <param-value>/WEB-INF/applicationContext.xml</param-value>
22   </context-param>
23   <listener>
24     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
25   </listener>
26   
27   
28 </web-app>

4、然後配置一下Spring的配置檔案。

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:p="http://www.springframework.org/schema/p"
 5     xmlns:context="http://www.springframework.org/schema/context"
 6     xsi:schemaLocation="
 7         http://www.springframework.org/schema/beans
 8         http://www.springframework.org/schema/beans/spring-beans.xsd
 9         http://www.springframework.org/schema/context
10         http://www.springframework.org/schema/context/spring-context.xsd">
11      
12     <!-- 開啟註解掃描 -->
13     <context:annotation-config/>   
14     <context:component-scan base-package="com.fline.*"></context:component-scan> 
15     
16     <!-- <import resource="classpath:applicationContext-redis.xml" />  -->
17     
18 </beans>

5、然後配置一下Redis的配置檔案redis.properties和applicationContext-redis.xml。

1 redis.host=127.0.0.1 
2 redis.port=6379
3 redis.password=123456
4 
5 redis.maxIdle=300
6 redis.maxActive=600
7 redis.maxWait=1000
8 redis.testOnBorrow=true
 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"
 4     xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
 5     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ">
 6 
 7     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig" >    
 8         <!--最大空閒數-->    
 9         <property name="maxIdle" value="10" />    
10         <!--連線池的最大資料庫連線數  -->  
11         <property name="maxTotal" value="50" />  
12         <!--最大建立連線等待時間-->    
13         <property name="maxWaitMillis" value="1500" />    
14         <!--逐出連線的最小空閒時間 預設1800000毫秒(30分鐘)-->  
15         <property name="minEvictableIdleTimeMillis" value="1800000" />   
16         <!--每次逐出檢查時 逐出的最大數目 如果為負數就是 : 1/abs(n), 預設3-->  
17         <property name="numTestsPerEvictionRun" value="1024" />   
18         <!--逐出掃描的時間間隔(毫秒) 如果為負數,則不執行逐出執行緒, 預設-1-->  
19         <property name="timeBetweenEvictionRunsMillis" value="30000" />   
20         <!--是否在從池中取出連線前進行檢驗,如果檢驗失敗,則從池中去除連線並嘗試取出另一個-->    
21         <property name="testOnBorrow" value="true" />    
22         <!--在空閒時檢查有效性, 預設false  -->  
23         <property name="testWhileIdle" value="true" />    
24     </bean >    
25       
26     <!--redis連線工廠 -->  
27     <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" destroy-method="destroy">   
28         <property name="poolConfig" ref="jedisPoolConfig"></property>   
29         <!--IP地址 -->  
30         <property name="hostName" value="127.0.0.1"></property>   
31         <!--埠號  -->  
32         <property name="port" value="6379"></property>   
33         <!--如果Redis設定有密碼  -->  
34         <property name="password" value="123456" />  
35         <!--客戶端超時時間單位是毫秒  -->  
36         <property name="timeout" value="1000"></property>   
37     </bean>    
38       
39     <!--redis操作模版,使用該物件可以操作redis  -->  
40     <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" >    
41         <property name="connectionFactory" ref="jedisConnectionFactory" />    
42         <!--如果不配置Serializer,那麼儲存的時候預設使用String,如果用User型別儲存,那麼會提示錯誤User can't cast to String!!  -->    
43         <property name="keySerializer" >    
44             <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />    
45         </property>    
46         <property name="valueSerializer" >    
47             <bean class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer" />    
48         </property>    
49         <property name="hashKeySerializer">    
50             <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>    
51         </property>    
52         <property name="hashValueSerializer">    
53             <bean class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"/>    
54         </property>    
55         <!--開啟事務  -->  
56         <property name="enableTransactionSupport" value="true"></property>  
57     </bean > 
58 
59     <bean id="redisUtil" class="com.fline.aic.utils.RedisUtil">
60         <property name="redisTemplate" ref="redisTemplate" />
61     </bean>
62 
63 </beans>

6、redis的工具類,可以直接拿到專案中使用的。

  1 package com.fline.aic.utils;
  2 
  3 import java.util.List;
  4 import java.util.Map;
  5 import java.util.Set;
  6 import java.util.concurrent.TimeUnit;
  7 
  8 import org.springframework.beans.factory.annotation.Autowired;
  9 import org.springframework.data.redis.core.RedisTemplate;
 10 import org.springframework.stereotype.Component;
 11 import org.springframework.util.CollectionUtils;
 12 
 13 /**
 14  * 
 15  * @author QLQ 基於spring和redis的redisTemplate工具類 針對所有的hash 都是以h開頭的方法 針對所有的Set
 16  *         都是以s開頭的方法 不含通用方法 針對所有的List 都是以l開頭的方法
 17  */
 18 @Component // 交給Spring管理(在需要快取的地方自動注入即可使用)
 19 public class RedisUtil {
 20 
 21     @Autowired // (自動注入redisTemplet)
 22     private RedisTemplate<String, Object> redisTemplate;
 23 
 24     public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
 25         this.redisTemplate = redisTemplate;
 26     }
 27     // =============================common============================
 28 
 29     /**
 30      * 指定快取失效時間
 31      * 
 32      * @param key
 33      *            鍵
 34      * @param time
 35      *            時間(秒)
 36      * @return
 37      */
 38     public boolean expire(String key, long time) {
 39         try {
 40             if (time > 0) {
 41                 redisTemplate.expire(key, time, TimeUnit.SECONDS);
 42             }
 43             return true;
 44         } catch (Exception e) {
 45             e.printStackTrace();
 46             return false;
 47         }
 48     }
 49 
 50     /**
 51      * 根據key 獲取過期時間
 52      * 
 53      * @param key
 54      *            鍵 不能為null
 55      * @return 時間(秒) 返回0代表為永久有效
 56      */
 57     public long getExpire(String key) {
 58         return redisTemplate.getExpire(key, TimeUnit.SECONDS);
 59     }
 60 
 61     /**
 62      * 判斷key是否存在
 63      * 
 64      * @param key
 65      *            鍵
 66      * @return true 存在 false不存在
 67      */
 68     public boolean hasKey(String key) {
 69         try {
 70             return redisTemplate.hasKey(key);
 71         } catch (Exception e) {
 72             e.printStackTrace();
 73             return false;
 74         }
 75     }
 76 
 77     /**
 78      * 刪除快取
 79      * 
 80      * @param key
 81      *            可以傳一個值 或多個
 82      */
 83     @SuppressWarnings("unchecked")
 84     public void del(String... key) {
 85         if (key != null && key.length > 0) {
 86             if (key.length == 1) {
 87                 redisTemplate.delete(key[0]);
 88             } else {
 89                 redisTemplate.delete(CollectionUtils.arrayToList(key));
 90             }
 91         }
 92     }
 93 
 94     // ============================String=============================
 95     /**
 96      * 普通快取獲取
 97      * 
 98      * @param key
 99      *            鍵
100      * @return 值
101      */
102     public Object get(String key) {
103         return key == null ? null : redisTemplate.opsForValue().get(key);
104     }
105 
106     /**
107      * 普通快取放入
108      * 
109      * @param key
110      *            鍵
111      * @param value
112      *            值
113      * @return true成功 false失敗
114      */
115     public boolean set(String key, Object value) {
116         try {
117             redisTemplate.opsForValue().set(key, value);
118             return true;
119         } catch (Exception e) {
120             e.printStackTrace();
121             return false;
122         }
123 
124     }
125 
126     /**
127      * 普通快取放入並設定時間
128      * 
129      * @param key
130      *            鍵
131      * @param value
132      *            值
133      * @param time
134      *            時間(秒) time要大於0 如果time小於等於0 將設定無限期
135      * @return true成功 false 失敗
136      */
137     public boolean set(String key, Object value, long time) {
138         try {
139             if (time > 0) {
140                 redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
141             } else {
142                 set(key, value);
143             }
144             return true;
145         } catch (Exception e) {
146             e.printStackTrace();
147             return false;
148         }
149     }
150 
151     /**
152      * 遞增
153      * 
154      * @param key
155      *            鍵
156      * @param by
157      *            要增加幾(大於0)
158      * @return
159      */
160     public long incr(String key, long delta) {
161         if (delta < 0) {
162             throw new RuntimeException("遞增因子必須大於0");
163         }
164         return redisTemplate.opsForValue().increment(key, delta);
165     }
166 
167     /**
168      * 遞減
169      * 
170      * @param key
171      *            鍵
172      * @param by
173      *            要減少幾(小於0)
174      * @return
175      */
176     public long decr(String key, long delta) {
177         if (delta < 0) {
178             throw new RuntimeException("遞減因子必須大於0");
179         }
180         return redisTemplate.opsForValue().increment(key, -delta);
181     }
182 
183     // ================================Map=================================
184     /**
185      * HashGet
186      * 
187      * @param key
188      *            鍵 不能為null
189      * @param item
190      *            項 不能為null
191      * @return 值
192      */
193     public Object hget(String key, String item) {
194         return redisTemplate.opsForHash().get(key, item);
195     }
196 
197     /**
198      * 獲取hashKey對應的所有鍵值
199      * 
200      * @param key
201      *            鍵
202      * @return 對應的多個鍵值
203      */
204     public Map<Object, Object> hmget(String key) {
205         return redisTemplate.opsForHash().entries(key);
206     }
207 
208     /**
209      * HashSet
210      * 
211      * @param key
212      *            鍵
213      * @param map
214      *            對應多個鍵值
215      * @return true 成功 false 失敗
216      */
217     public boolean hmset(String key, Map<String, Object> map) {
218         try {
219             redisTemplate.opsForHash().putAll(key, map);
220             return true;
221         } catch (Exception e) {
222             e.printStackTrace();
223             return false;
224         }
225     }
226 
227     /**
228      * HashSet 並設定時間
229      * 
230      * @param key
231      *            鍵
232      * @param map
233      *            對應多個鍵值
234      * @param time
235      *            時間(秒)
236      * @return true成功 false失敗
237      */
238     public boolean hmset(String key, Map<String, Object> map, long time) {
239         try {
240             redisTemplate.opsForHash().putAll(key, map);
241             if (time > 0) {
242                 expire(key, time);
243             }
244             return true;
245         } catch (Exception e) {
246             e.printStackTrace();
247             return false;
248         }
249     }
250 
251     /**
252      * 向一張hash表中放入資料,如果不存在將建立
253      * 
254      * @param key
255      *            鍵
256      * @param item
257      *            項
258      * @param value
259      *            值
260      * @return true 成功 false失敗
261      */
262     public boolean hset(String key, String item, Object value) {
263         try {
264             redisTemplate.opsForHash().put(key, item, value);
265             return true;
266         } catch (Exception e) {
267             e.printStackTrace();
268             return false;
269         }
270     }
271 
272     /**
273      * 向一張hash表中放入資料,如果不存在將建立
274      * 
275      * @param key
276      *            鍵
277      * @param item
278      *            項
279      * @param value
280      *            值
281      * @param time
282      *            時間(秒) 注意:如果已存在的hash表有時間,這裡將會替換原有的時間
283      * @return true 成功 false失敗
284      */
285     public boolean hset(String key, String item, Object value, long time) {
286         try {
287             redisTemplate.opsForHash().put(key, item, value);
288             if (time > 0) {
289                 expire(key, time);
290             }
291             return true;
292         } catch (Exception e) {
293             e.printStackTrace();
294             return false;
295         }
296     }
297 
298     /**
299      * 刪除hash表中的值
300      * 
301      * @param key
302      *            鍵 不能為null
303      * @param item
304      *            項 可以使多個 不能為null
305      */
306     public void hdel(String key, Object... item) {
307         redisTemplate.opsForHash().delete(key, item);
308     }
309 
310     /**
311      * 判斷hash表中是否有該項的值
312      * 
313      * @param key
314      *            鍵 不能為null
315      * @param item
316      *            項 不能為null
317      * @return true 存在 false不存在
318      */
319     public boolean hHasKey(String key, String item) {
320         return redisTemplate.opsForHash().hasKey(key, item);
321     }
322 
323     /**
324      * hash遞增 如果不存在,就會建立一個 並把新增後的值返回
325      * 
326      * @param key
327      *            鍵
328      * @param item
329      *            項
330      * @param by
331      *            要增加幾(大於0)
332      * @return
333      */
334     public double hincr(String key, String item, double by) {
335         return redisTemplate.opsForHash().increment(key, item, by);
336     }
337 
338     /**
339      * hash遞減
340      * 
341      * @param key
342      *            鍵
343      * @param item
344      *            項
345      * @param by
346      *            要減少記(小於0)
347      * @return
348      */
349     public double hdecr(String key, String item, double by) {
350         return redisTemplate.opsForHash().increment(key, item, -by);
351     }
352 
353     // ============================set=============================
354     /**
355      * 根據key獲取Set中的所有值
356      * 
357      * @param key
358      *            鍵
359      * @return
360      */
361     public Set<Object> sGet(String key) {
362         try {
363             return redisTemplate.opsForSet().members(key);
364         } catch (Exception e) {
365             e.printStackTrace();
366             return null;
367         }
368     }
369 
370     /**
371      * 根據value從一個set中查詢,是否存在
372      * 
373      * @param key
374      *            鍵
375      * @param value
376      *            值
377      * @return true 存在 false不存在
378      */
379     public boolean sHasKey(String key, Object value) {
380         try {
381             return redisTemplate.opsForSet().isMember(key, value);
382         } catch (Exception e) {
383             e.printStackTrace();
384             return false;
385         }
386     }
387 
388     /**
389      * 將資料放入set快取
390      * 
391      * @param key
392      *            鍵
393      * @param values
394      *            值 可以是多個
395      * @return 成功個數
396      */
397     public long sSet(String key, Object... values) {
398         try {
399             return redisTemplate.opsForSet().add(key, values);
400         } catch (Exception e) {
401             e.printStackTrace();
402             return 0;
403         }
404     }
405 
406     /**
407      * 將set資料放入快取
408      * 
409      * @param key
410      *            鍵
411      * @param time
412      *            時間(秒)
413      * @param values
414      *            值 可以是多個
415      * @return 成功個數
416      */
417     public long sSetAndTime(String key, long time, Object... values) {
418         try {
419             Long count = redisTemplate.opsForSet().add(key, values);
420             if (time > 0)
421                 expire(key, time);
422             return count;
423         } catch (Exception e) {
424             e.printStackTrace();
425             return 0;
426         }
427     }
428 
429     /**
430      * 獲取set快取的長度
431      * 
432      * @param key
433      *            鍵
434      * @return
435      */
436     public long sGetSetSize(String key) {
437         try {
438             return redisTemplate.opsForSet().size(key);
439         } catch (Exception e) {
440             e.printStackTrace();
441             return 0;
442         }
443     }
444 
445     /**
446      * 移除值為value的
447      * 
448      * @param key
449      *            鍵
450      * @param values
451      *            值 可以是多個
452      * @return 移除的個數
453      */
454     public long setRemove(String key, Object... values) {
455         try {
456             Long count = redisTemplate.opsForSet().remove(key, values);
457             return count;
458         } catch (Exception e) {
459             e.printStackTrace();
460             return 0;
461         }
462     }
463     // ===============================list=================================
464 
465     /**
466      * 獲取list快取的內容
467      * 
468      * @param key
469      *            鍵
470      * @param start
471      *            開始
472      * @param end
473      *            結束 0 到 -1代表所有值
474      * @return
475      */
476     public List<Object> lGet(String key, long start, long end) {
477         try {
478             return redisTemplate.opsForList().range(key, start, end);
479         } catch (Exception e) {
480             e.printStackTrace();
481             return null;
482         }
483     }
484 
485     /**
486      * 獲取list快取的長度
487      * 
488      * @param key
489      *            鍵
490      * @return
491      */
492     public long lGetListSize(String key) {
493         try {
494             return redisTemplate.opsForList().size(key);
495         } catch (Exception e) {
496             e.printStackTrace();
497             return 0;
498         }
499     }
500 
501     /**
502      * 通過索引 獲取list中的值
503      * 
504      * @param key
505      *            鍵
506      * @param index
507      *            索引 index>=0時, 0 表頭,1 第二個元素,依次類推;index<0時,-1,表尾,-2倒數第二個元素,依次類推
508      * @return
509      */
510     public Object lGetIndex(String key, long index) {
511         try {
512             return redisTemplate.opsForList().index(key, index);
513         } catch (Exception e) {
514             e.printStackTrace();
515             return null;
516         }
517     }
518 
519     /**
520      * 將list放入快取
521      * 
522      * @param key
523      *            鍵
524      * @param value
525      *            值
526      * @param time
527      *            時間(秒)
528      * @return
529      */
530     public boolean lSet(String key, Object value) {
531         try {
532             redisTemplate.opsForList().rightPush(key, value);
533             return true;
534         } catch (Exception e) {
535             e.printStackTrace();
536             return false;
537         }
538     }
539 
540     /**
541      * 將list放入快取
542      * 
543      * @param key
544      *            鍵
545      * @param value
546      *            值
547      * @param time
548      *            時間(秒)
549      * @return
550      */
551     public boolean rSet(String key, Object value) {
552         try {
553             redisTemplate.opsForList().rightPush(key, value);
554             return true;
555         } catch (Exception e) {
556             e.printStackTrace();
557             return false;
558         }
559     }
560 
561     /**
562      * 將list放入快取
563      * 
564      * @param key
565      *            鍵
566      * @param value
567      *            值
568      * @param time
569      *            時間(秒)
570      * @return
571      */
572     public boolean lSet(String key, Object value, long time) {
573         try {
574             redisTemplate.opsForList().rightPush(key, value);
575             if (time > 0)
576                 expire(key, time);
577             return true;
578         } catch (Exception e) {
579             e.printStackTrace();
580             return false;
581         }
582     }
583 
584     /**
585      * 將list放入快取
586      * 
587      * @param key
588      *            鍵
589      * @param value
590      *            值
591      * @param time
592      *            時間(秒)
593      * @return
594      */
595     public boolean lSet(String key, List<Object> value) {
596         try {
597             redisTemplate.opsForList().rightPushAll(key, value);
598             return true;
599         } catch (Exception e) {
600             e.printStackTrace();
601             return false;
602         }
603     }
604 
605     /**
606      * 將list放入快取
607      * 
608      * @param key
609      *            鍵
610      * @param value
611      *            值
612      * @param time
613      *            時間(秒)
614      * @return
615      */
616     public boolean lSet(String key, List<Object> value, long time) {
617         try {
618             redisTemplate.opsForList().rightPushAll(key, value);
619             if (time > 0)
620                 expire(key, time);
621             return true;
622         } catch (Exception e) {
623             e.printStackTrace();
624             return false;
625         }
626     }
627 
628     /**
629      * 根據索引修改list中的某條資料
630      * 
631      * @param key
632      *            鍵
633      * @param index
634      *            索引
635      * @param value
636      *            值
637      * @return
638      */
639     public boolean lUpdateIndex(String key, long index, Object value) {
640         try {
641             redisTemplate.opsForList().set(key, index, value);
642             return true;
643         } catch (Exception e) {
644             e.printStackTrace();
645             return false;
646         }
647     }
648 
649     /**
650      * 移除N個值為value
651      * 
652      * @param key
653      *            鍵
654      * @param count
655      *            移除多少個
656      * @param value
657      *            值
658      * @return 移除的個數
659      */
660     public long lRemove(String key, long count, Object value) {
661         try {
662             Long remove = redisTemplate.opsForList().remove(key, count, value);
663             return remove;
664         } catch (Exception e) {
665             e.printStackTrace();
666             return 0;
667         }
668     }
669 
670 }

7、最後是Redis的測試類,方便自己進行測試使用。

 1 package com.fline.aic.utils;
 2 
 3 import java.util.List;
 4 import java.util.Map;
 5 import java.util.Map.Entry;
 6 import java.util.Set;
 7 
 8 import org.junit.Before;
 9 import org.junit.Test;
10 import org.springframework.context.ApplicationContext;
11 import org.springframework.context.support.ClassPathXmlApplicationContext;
12 
13 /**
14  * 
15  * @Description TODO
16  * @author biehl
17  * @Date 2018年12月7日 下午8:25:34
18  *
19  *       參考:https://www.cnblogs.com/qlqwjy/p/8562703.html
20  */
21 public class RedisTest {
22 
23     private RedisUtil redisUtils = null;
24 
25     @Before
26     public void before() {
27         ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext-redis.xml");
28         redisUtils = (RedisUtil) context.getBean("redisUtil");
29     }
30 
31     // redis存放String型