當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

spring整合redis缓存

發布時間：2025/4/16 编程问答 15 豆豆

生活随笔收集整理的這篇文章主要介紹了 spring整合redis缓存小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

如果對spring cache不了解,這邊有一篇文章詳細的介紹了
http://jinnianshilongnian.iteye.com/blog/2001040
改項目基于maven構建
相關依賴

Xml代碼

   <dependency>??   ????<groupId>org.springframework.data</groupId>??   ????<artifactId>spring-data-redis</artifactId>??   ????<version>1.3.4.RELEASE</version>??   </dependency>??   ???  <dependency>??   ????<groupId>redis.clients</groupId>??   ????<artifactId>jedis</artifactId>??   ????<version>2.5.2</version>??   </dependency>??   ???  <dependency>??   ????<groupId>org.springframework</groupId>??   ????<artifactId>spring-jdbc</artifactId>??   ????<version>3.2.13.RELEASE</version>??   </dependency>??   ???  <!--?日志記錄依賴包，很多都依賴此包，像log4j,json-lib等等?-->??  <dependency>??   ????<groupId>commons-logging</groupId>??   ????<artifactId>commons-logging-api</artifactId>??   ????<version>1.1</version>??   </dependency>??   ???  <!--?junit?測試包?-->??  <dependency>??   ????<groupId>junit</groupId>??   ????<artifactId>junit</artifactId>??   ????<version>4.11</version>??   ????<scope>test</scope>??   </dependency>??   ???  <dependency>??   ????<groupId>org.springframework</groupId>??   ????<artifactId>spring-test</artifactId>??   ????<version>3.2.13.RELEASE</version>??   ????<scope>test</scope>??   </dependency>   

Spring相關配置
Xml代碼 ?

   <?xml?version="1.0"?encoding="UTF-8"?>??   <beans?xmlns="http://www.springframework.org/schema/beans"??  ????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"?xmlns:context="http://www.springframework.org/schema/context"??  ????xmlns:cache="http://www.springframework.org/schema/cache"?xmlns:p="http://www.springframework.org/schema/p"??  ????xmlns:c="http://www.springframework.org/schema/c"??  ????xsi:schemaLocation="??   ????????http://www.springframework.org/schema/beans?http://www.springframework.org/schema/beans/spring-beans-3.2.xsd??   ????????http://www.springframework.org/schema/context?http://www.springframework.org/schema/context/spring-context-3.2.xsd??   ????????http://www.springframework.org/schema/jee?http://www.springframework.org/schema/jee/spring-jee-3.2.xsd??   ????????http://www.springframework.org/schema/cache???   ????????http://www.springframework.org/schema/cache/spring-cache-3.2.xsd"??   ????default-lazy-init="true">??   ???  ????<context:property-placeholder?location="classpath:redis.properties"?/>??   ???????  ????<!--?自動掃描包?-->??  ????<context:component-scan?base-package="com.layou"?/>??   ???  ???  ????<!--?啟用緩存注解功能，這個是必須的，否則注解不會生效，另外，該注解一定要聲明在spring主配置文件中才會生效?-->??  ????<cache:annotation-driven?cache-manager="cacheManager"?/>??   ???  ????<!--?spring自己的換管理器，這里定義了兩個緩存位置名稱?，既注解中的value?-->??  ????<bean?id="cacheManager"?class="org.springframework.cache.support.SimpleCacheManager">??   ????????<property?name="caches">??   ????????????<set>??   ????????????????<bean?class="com.layou.RedisCache">??   ????????????????????<property?name="redisTemplate"?ref="redisTemplate"?/>??   ????????????????????<property?name="name"?value="default"?/>??   ????????????????</bean>??   ????????????</set>??   ????????</property>??   ????</bean>??   ???  ????<!--?redis?相關配置?-->??  ????<bean?id="poolConfig"?class="redis.clients.jedis.JedisPoolConfig">??   ????????<property?name="maxIdle"?value="${redis.pool.maxIdle}"?/>??   ????????<property?name="maxTotal"?value="${redis.pool.maxActive}"?/>??   ????????<property?name="maxWaitMillis"?value="${redis.pool.maxWait}"?/>??   ????????<property?name="testOnBorrow"?value="${redis.pool.testOnBorrow}"?/>??   ????</bean>??   ???  ????<bean?id="connectionFactory"??  ????????class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">??   ????????<property?name="hostName"?value="${redis.host}"?/>??   ????????<property?name="port"?value="${redis.port}"?/>??   ????????<property?name="password"?value="${redis.password}"?/>??   ????????<property?name="timeout"?value="${redis.timeout}"?/>??   ????????<property?name="usePool"?value="true"?/>??   ????????<property?name="poolConfig"?ref="poolConfig"?/>??   ????</bean>??   ???  ????<bean?id="redisTemplate"?class="org.springframework.data.redis.core.RedisTemplate">??   ????????<property?name="connectionFactory"?ref="connectionFactory"?/>??   ????</bean>??   </beans>   

redis相關配置
Java代碼 ?

  #redis.host=localhost?? redis.host=192.168.71.145?? redis.port=6379?? redis.password=?? #客戶端超時時間單位是毫秒?? redis.timeout=100000??  ??? #最大連接數?? redis.pool.maxActive=500???? #最大能夠保持idel狀態的對象數???? redis.pool.maxIdle=200???? #最大建立連接等待時間???? redis.pool.maxWait=2000???? #當調用borrow?Object方法時，是否進行有效性檢查???? redis.pool.testOnBorrow=true  

首先,通過自己實現Cache接口來實現對redis的相關操作

   package?com.layou;??   ???  import?java.io.ByteArrayInputStream;??   import?java.io.ByteArrayOutputStream;??   import?java.io.IOException;??   import?java.io.ObjectInputStream;??   import?java.io.ObjectOutputStream;??   ???  import?org.springframework.cache.Cache;??   import?org.springframework.cache.support.SimpleValueWrapper;??   import?org.springframework.dao.DataAccessException;??   import?org.springframework.data.redis.connection.RedisConnection;??   import?org.springframework.data.redis.core.RedisCallback;??   import?org.springframework.data.redis.core.RedisTemplate;??   ???  public?class?RedisCache?implements?Cache?{??   ???  ????private?RedisTemplate<String,?Object>?redisTemplate;??   ????private?String?name;??   ???  ????public?RedisTemplate<String,?Object>?getRedisTemplate()?{??   ????????return?redisTemplate;??   ????}??   ???  ????public?void?setRedisTemplate(RedisTemplate<String,?Object>?redisTemplate)?{??   ????????this.redisTemplate?=?redisTemplate;??   ????}??   ???  ????public?void?setName(String?name)?{??   ????????this.name?=?name;??   ????}??   ???  ????@Override??  ????public?String?getName()?{??   ????????return?this.name;??   ????}??   ???  ????@Override??  ????public?Object?getNativeCache()?{??   ????????return?this.redisTemplate;??   ????}??   ???  ????@Override??  ????public?ValueWrapper?get(Object?key)?{??   ????????final?String?keyf?=?(String)?key;??   ????????Object?object?=?null;??   ????????object?=?redisTemplate.execute(new?RedisCallback<Object>()?{??   ????????????public?Object?doInRedis(RedisConnection?connection)?throws?DataAccessException?{??   ???  ????????????????byte[]?key?=?keyf.getBytes();??   ????????????????byte[]?value?=?connection.get(key);??   ????????????????if?(value?==?null)?{??   ????????????????????return?null;??   ????????????????}??   ????????????????return?toObject(value);??   ???  ????????????}??   ????????});??   ????????return?(object?!=?null???new?SimpleValueWrapper(object)?:?null);??   ????}??   ???  ????@Override??  ????public?void?put(Object?key,?Object?value)?{??   ????????final?String?keyf?=?(String)?key;??   ????????final?Object?valuef?=?value;??   ????????final?long?liveTime?=?86400;??   ???  ????????redisTemplate.execute(new?RedisCallback<Long>()?{??   ????????????public?Long?doInRedis(RedisConnection?connection)?throws?DataAccessException?{??   ????????????????byte[]?keyb?=?keyf.getBytes();??   ????????????????byte[]?valueb?=?toByteArray(valuef);??   ????????????????connection.set(keyb,?valueb);??   ????????????????if?(liveTime?>?0)?{??   ????????????????????connection.expire(keyb,?liveTime);??   ????????????????}??   ????????????????return?1L;??   ????????????}??   ????????});??   ????}??   ???  ????@Override??  ????public?void?evict(Object?key)?{??   ????????final?String?keyf?=?(String)?key;??   ????????redisTemplate.execute(new?RedisCallback<Long>()?{??   ????????????public?Long?doInRedis(RedisConnection?connection)?throws?DataAccessException?{??   ????????????????return?connection.del(keyf.getBytes());??   ????????????}??   ????????});??   ????}??   ???  ????@Override??  ????public?void?clear()?{??   ????????redisTemplate.execute(new?RedisCallback<String>()?{??   ????????????public?String?doInRedis(RedisConnection?connection)?throws?DataAccessException?{??   ????????????????connection.flushDb();??   ????????????????return?"ok";??   ????????????}??   ????????});??   ????}??   ???  ????/**?   ?????*?描述?:?<Object轉byte[]>.?<br>?   ?????*?<p>?   ?????*?<使用方法說明>?   ?????*?</p>?   ?????*??   ?????*?@param?obj?   ?????*?@return?   ?????*/??  ????private?byte[]?toByteArray(Object?obj)?{??   ????????byte[]?bytes?=?null;??   ????????ByteArrayOutputStream?bos?=?new?ByteArrayOutputStream();??   ????????try?{??   ????????????ObjectOutputStream?oos?=?new?ObjectOutputStream(bos);??   ????????????oos.writeObject(obj);??   ????????????oos.flush();??   ????????????bytes?=?bos.toByteArray();??   ????????????oos.close();??   ????????????bos.close();??   ????????}?catch?(IOException?ex)?{??   ????????????ex.printStackTrace();??   ????????}??   ????????return?bytes;??   ????}??   ???  ????/**?   ?????*?描述?:?<byte[]轉Object>.?<br>?   ?????*?<p>?   ?????*?<使用方法說明>?   ?????*?</p>?   ?????*??   ?????*?@param?bytes?   ?????*?@return?   ?????*/??  ????private?Object?toObject(byte[]?bytes)?{??   ????????Object?obj?=?null;??   ????????try?{??   ????????????ByteArrayInputStream?bis?=?new?ByteArrayInputStream(bytes);??   ????????????ObjectInputStream?ois?=?new?ObjectInputStream(bis);??   ????????????obj?=?ois.readObject();??   ????????????ois.close();??   ????????????bis.close();??   ????????}?catch?(IOException?ex)?{??   ????????????ex.printStackTrace();??   ????????}?catch?(ClassNotFoundException?ex)?{??   ????????????ex.printStackTrace();??   ????????}??   ????????return?obj;??   ????}??  }  

使用junit進行測試

package?com.layou;??

import?org.junit.Before;??

import?org.junit.Test;??

import?org.springframework.beans.factory.annotation.Autowired;??

import?org.springframework.cache.CacheManager;??

import?org.springframework.test.context.ContextConfiguration;??

import?org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;??

@ContextConfiguration(locations?=?{"classpath:applicationContext-cache-redis.xml"})??

public?class?RedisTest?extends?AbstractJUnit4SpringContextTests?{??

????private?RedisCache?cache;??

????@Autowired??

????private?CacheManager?manager;??

??????

????@Before??

????public?void?before()?{??

????????cache?=?(RedisCache)?manager.getCache("default");??

????}??

??????

????@Test??

????public?void?testAdd()?throws?Exception?{??

????????cache.put("test",?1);??

????}??

??????

????@Test??

????public?void?testGet()?throws?Exception?{??

????????System.out.println(cache.get("test").get());??

????}??

??????

????@Test??

????public?void?testEvict()?throws?Exception?{??

????????cache.evict("test");??

????}??

??????

????@Test??

????public?void?testClear()?throws?Exception?{??

????????cache.clear();??

????}??

}

在實際項目中,多是通過Spring的注解完成相關操作

   package?com.layou;??   ???  import?org.springframework.cache.annotation.CacheEvict;??   import?org.springframework.cache.annotation.Cacheable;??   import?org.springframework.stereotype.Service;??   ???  @Service??  public?class?RedisAnnotation?{??   ???????  ????/**?   ?????*?第一次查詢會到數據庫中差尋,第二次就會從緩存中取?   ?????*?#id代表使用參數id?   ?????*?一定要放在spring容器中管理，不然攔截不到?   ?????*?@param?id?   ?????*?@return?   ?????*/??  ????@Cacheable(key="'name'?+?#id",?value="default")??   ????public?String?getNameById(int?id)?{??   ????????//TODO?進行數據庫查詢并返回查詢數據庫內容??   ????????System.out.println("查詢數據庫");??   ????????return?""?+?id;??   ????}??   ???????  ????/**?   ?????*?從緩存中刪除?   ?????*?@param?id?   ?????*/??  ????@CacheEvict(key="'name'?+?#id",?value="default")??   ????public?void?deleteById(int?id)?{??   ????????System.out.println("數據庫刪除");??   ????}??  }  

使用junit進行相關測試

   package?com.layou;??   ???  import?org.junit.Test;??   import?org.springframework.beans.factory.annotation.Autowired;??   import?org.springframework.test.context.ContextConfiguration;??   import?org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;??   ???  @ContextConfiguration(locations?=?{"classpath:applicationContext-cache-redis.xml"})??   public?class?RedisAnnotationTest?extends?AbstractJUnit4SpringContextTests?{??   ????@Autowired??  ????private?RedisAnnotation?redis;??   ???????  ????@Test??  ????public?void?testQuery()?{??   ????????//第二次查詢的時候就會從緩存中取??   ????????System.out.println(redis.getNameById(1));??   ????}??   ???????  ????@Test??  ????public?void?testDelete()?{??   ????????redis.deleteById(1);??   ????}??  } ?? 
  

本文轉自yunlielai51CTO博客，原文鏈接：http://blog.51cto.com/4925054/1741066，如需轉載請自行聯系原作者

總結

以上是生活随笔為你收集整理的spring整合redis缓存的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： linux 运维shell习题
下一篇： [HDU 1427]速度计算24点(DF