使用Spring-Data-Redis存儲對象(redisTemplate)

Redis是一種nosql資料庫，在開發中常用做緩存。Jedis是Redis在java中的redis- client.在此之前，希望已經了解redis的基本使用和Maven的使用。建立Maven Project之後，在POM.xml中添加jedis和spring-data-redis的依賴如下：

[html]  view plain copy

1. <dependency>  
2.     <groupId>redis.clients</groupId>  
3.     <artifactId>jedis</artifactId>  
4.     <version>2.0.0</version>  
5.     <type>jar</type>  
6.     <scope>compile</scope>  
7. </dependency>  
8. <!-- spring-redis -->  
9. <dependency>  
10.     <groupId>org.springframework.data</groupId>  
11.     <artifactId>spring-data-redis</artifactId>  
12.     <version>1.0.0.RELEASE</version>  
13. </dependency>  

Redis連接配接資料庫參數如下：applicationContext-redis.properties

[plain]  view plain copy

1. #redis config  
2. redis.pool.maxActive=100  
3. redis.pool.maxIdle=20  
4. redis.pool.maxWait=1000  
5. redis.pool.testOnBorrow=true  
6. redis.hostname=localhost  
7. redis.port=6379  
8. redis.password=  

在上下文配置中使用key-value讀取方式讀取properties中的值：

[html]  view plain copy

1. <!-- Jedis 連接配接池配置-->  
2. <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
3.     <property name="maxActive" value="${redis.pool.maxActive}" />  
4.     <property name="maxIdle" value="${redis.pool.maxIdle}" />  
5.     <property name="maxWait" value="${redis.pool.maxWait}" />  
6.     <property name="testOnBorrow" value="${redis.pool.testOnBorrow}" />  
7. </bean>  
8. <!-- Jedis ConnectionFactory 資料庫連接配接配置-->  
9. <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">  
10.     <property name="hostName" value="${redis.hostname}" />  
11.     <property name="port" value="${redis.port}" />  
12.     <property name="password" value="${redis.password}" />  
13.     <property name="poolConfig" ref="jedisPoolConfig" />  
14. </bean>  
15. <!—- redisTemplate配置，redisTemplate是對Jedis的對redis操作的擴充，有更多的操作，封裝使操作更便捷 -->   
16. <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"                                   p:connection-factory-ref="jedisConnectionFactory" />  

上面redisTemplate已經基本配置完成。

接下來建立User類，必須實作或者間接實作Serializable接口：

Redis存儲對象是使用序列化，spring-data-redis已經将序列化的功能内置，不需要我們去管，我們隻需要調用api就可以使用。SerialVersionUID字段對序列化擴充有用，為了以後擴充或者縮減字段時不會造成反序列化出錯。

[java]  view plain copy

1. public class User implements Serializable {  
2.     private static final long serialVersionUID = -7898194272883238670L;  
3.     public static final String OBJECT_KEY = "USER";  
4.     public User() {  
5.     }  
6.     public User(String id) {  
7.     }  
8.     public User(String id, String name) {  
9.         this.id = id;  
10.         this.name = name;  
11.     }  
12.     private String id;  
13.     private String name;  
14.     public String getId() {  
15.         return id;  
16.     }  
17.     public void setId(String id) {  
18.         this.id = id;  
19.     }  
20.     public String getName() {  
21.         return name;  
22.     }  
23.     public void setName(String name) {  
24.         this.name = name;  
25.     }  
26.     public String toString() {  
27.         return "User [id=" + id + ", name=" + name + "]";  
28.     }  
29.     public String getKey() {  
30.         return getId();  
31.     }  
32.     public String getObjectKey() {  
33.         return OBJECT_KEY;  
34.     }  
35. }  

建立userService類來操作redis增删查改緩存對象。

[java]  view plain copy

1. public class UserService {  
2.     RedisTemplate<String, User> redisTemplate;  
3.     public RedisTemplate<String, User> getRedisTemplate() {  
4.         return redisTemplate;  
5.     }  
6.     public void setRedisTemplate(RedisTemplate<String, User> redisTemplate) {  
7.         this.redisTemplate = redisTemplate;  
8.     }  
9.     public void put(User user) {  
10.         redisTemplate.opsForHash().put(user.getObjectKey(), user.getKey(), user);  
11.     }  
12.     public void delete(User key) {  
13.         redisTemplate.opsForHash().delete(key.getObjectKey(), key.getKey());  
14.     }  
15.     public User get(User key) {  
16.         return (User) redisTemplate.opsForHash().get(key.getObjectKey(), key.getKey());  
17.     }  
18. }  

在上下文中配置redisTemplate注入，在使用bean方式來注入時，redisTemplate必須有setter/getter方法：

[html]  view plain copy

1. <bean id="userService" class="Service.UserService">  
2.     <property name="redisTemplate">  
3.         <ref bean="redisTemplate" />  
4.     </property>  
5. </bean>  

======如果使用注解方式自動注入，則可以注釋掉上面的bean配置方式======

在UserService注解@Service(“userService”),也可以在Service裡寫名字，預設是第一字母小寫。

[java]  view plain copy

1. @Service("userService")  
2. public class UserService {  
3.     @Autowired  
4.     RedisTemplate<String, User> redisTemplate;  
5.     ……  
6.         ……  
7. }  

在上下文配置檔案中，添加自動掃描包的context節點，Base-package的路徑要覆寫包含注解的類檔案： [html]  view plain copy

1. <context:component-scan base-package="*" />  

在main中來簡單操作一下：

[java]  view plain copy

1. public class Main {  
2.     public static void main( String[] args )  
3.     {  
4.         ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath*:/conf/applicationContext.xml"        );  
5.         UserService userService =  (UserService) applicationContext.getBean("userService");  
6.         User user1 = new User("user1ID", "User 1");  
7.         User user2 = new User("user2ID", "User 2");  
8.         System.out.println("==== getting objects from redis ====");  
9.         System.out.println("User is not in redis yet: " + userService.get(user1));  
10.         System.out.println("User is not in redis yet: " + userService.get(user2));  
11.         System.out.println("==== putting objects into redis ====");  
12.         userService.put(user1);  
13.         userService.put(user2);  
14.         System.out.println("==== getting objects from redis ====");  
15.         System.out.println("User should be in redis yet: " + userService.get(user1));  
16.         System.out.println("User should be in redis yet: " + userService.get(user2));  
17.         System.out.println("==== deleting objects from redis ====");  
18.         userService.delete(user1);  
19.         userService.delete(user2);  
20.         System.out.println("==== getting objects from redis ====");  
21.         System.out.println("User is not in redis yet: " + userService.get(user1));  
22.         System.out.println("User is not in redis yet: " + userService.get(user2));  
23.     }  
24. }  

確定redis伺服器是開啟狀态之後就可以運作程式。運作結果如下：