Maven中Spring-Data-Redis存儲對象(redisTemplate)

Redis是一種nosql 數據庫,在開發中經常使用作緩存。Jedis是Redis在java中的redis- client.在此以前,但願已經瞭解redis的基本使用和Maven的使用。創建Maven Project以後,在POM.xml中添加jedis和spring-data-redis的依賴以下:html

[html] view plaincopy在CODE上查看代碼片派生到個人代碼片java

  1. <dependency>  redis

  2.     <groupId>redis.clients</groupId>  spring

  3.     <artifactId>jedis</artifactId>  sql

  4.     <version>2.0.0</version>  數據庫

  5.     <type>jar</type>  api

  6.     <scope>compile</scope>  緩存

  7. </dependency>  服務器

  8. <!-- spring-redis -->  app

  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 plaincopy在CODE上查看代碼片派生到個人代碼片

  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 plaincopy在CODE上查看代碼片派生到個人代碼片

  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 plaincopy在CODE上查看代碼片派生到個人代碼片

  1. public class User implements Serializable {  

  2.   

  3.     private static final long serialVersionUID = -7898194272883238670L;  

  4.   

  5.     public static final String OBJECT_KEY = "USER";  

  6.   

  7.     public User() {  

  8.     }  

  9.   

  10.     public User(String id) {  

  11.     }  

  12.   

  13.     public User(String id, String name) {  

  14.         this.id = id;  

  15.         this.name = name;  

  16.     }  

  17.   

  18.     private String id;  

  19.   

  20.     private String name;  

  21.   

  22.     public String getId() {  

  23.         return id;  

  24.     }  

  25.   

  26.     public void setId(String id) {  

  27.         this.id = id;  

  28.     }  

  29.   

  30.     public String getName() {  

  31.         return name;  

  32.     }  

  33.   

  34.     public void setName(String name) {  

  35.         this.name = name;  

  36.     }  

  37.   

  38.     public String toString() {  

  39.         return "User [id=" + id + ", name=" + name + "]";  

  40.     }  

  41.   

  42.     public String getKey() {  

  43.         return getId();  

  44.     }  

  45.   

  46.     public String getObjectKey() {  

  47.         return OBJECT_KEY;  

  48.     }  

  49. }  

建立userService類來操做redis增刪查改緩存對象。

[java] view plaincopy在CODE上查看代碼片派生到個人代碼片

  1. public class UserService {  

  2.   

  3.     RedisTemplate<String, User> redisTemplate;  

  4.   

  5.     public RedisTemplate<String, User> getRedisTemplate() {  

  6.         return redisTemplate;  

  7.     }  

  8.   

  9.     public void setRedisTemplate(RedisTemplate<String, User> redisTemplate) {  

  10.         this.redisTemplate = redisTemplate;  

  11.     }  

  12.       

  13.     public void put(User user) {  

  14.         redisTemplate.opsForHash().put(user.getObjectKey(), user.getKey(), user);  

  15.     }  

  16.   

  17.     public void delete(User key) {  

  18.         redisTemplate.opsForHash().delete(key.getObjectKey(), key.getKey());  

  19.     }  

  20.   

  21.     public User get(User key) {  

  22.         return (User) redisTemplate.opsForHash().get(key.getObjectKey(), key.getKey());  

  23.     }  

  24. }  

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

[html] view plaincopy在CODE上查看代碼片派生到個人代碼片

  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 plaincopy在CODE上查看代碼片派生到個人代碼片

  1. @Service ("userService")  

  2. public class UserService {  

  3.   

  4.     @Autowired  

  5.     RedisTemplate<String, User> redisTemplate;  

  6.     ……  

  7.         ……  

  8. }  

在上下文配置文件中,添加自動掃描包的context節點,Base-package的路徑要覆蓋包含註解的類文件

[html] view plaincopy在CODE上查看代碼片派生到個人代碼片

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

在main中來簡單操做一下:

[java] view plaincopy在CODE上查看代碼片派生到個人代碼片

  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.               

  7.         User user1 = new User("user1ID""User 1");  

  8.         User user2 = new User("user2ID""User 2");  

  9.           

  10.         System.out.println("==== getting objects from redis ====");  

  11.         System.out.println("User is not in redis yet: " + userService.get(user1));  

  12.         System.out.println("User is not in redis yet: " + userService.get(user2));  

  13.           

  14.         System.out.println("==== putting objects into redis ====");  

  15.         userService.put(user1);  

  16.         userService.put(user2);  

  17.           

  18.         System.out.println("==== getting objects from redis ====");  

  19.         System.out.println("User should be in redis yet: " + userService.get(user1));  

  20.         System.out.println("User should be in redis yet: " + userService.get(user2));  

  21.           

  22.         System.out.println("==== deleting objects from redis ====");  

  23.         userService.delete(user1);  

  24.         userService.delete(user2);  

  25.           

  26.         System.out.println("==== getting objects from redis ====");  

  27.         System.out.println("User is not in redis yet: " + userService.get(user1));  

  28.         System.out.println("User is not in redis yet: " + userService.get(user2));  

  29.   

  30.     }  

  31. }  

確保redis服務器是開啓狀態以後就能夠運行程序。運行結果以下:

相關文章
相關標籤/搜索