spring + redis 实现数据的缓存

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162import java.util.HashMap;import java.util.List;import java.util.Map;import org.apache.log4j.Logger;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.ApplicationListener;import org.springframework.context.event.ContextRefreshedEvent;import org.springframework.stereotype.Service;import com.test.model.City;import com.test.model.Country;import com.zcr.test.User;/** 监听器,用于项目启动的时候初始化信息*/@Servicepublic class StartAddCacheListener implements ApplicationListener<ContextRefreshedEvent>{//日志private final Logger log= Logger.getLogger(StartAddCacheListener.class);@Autowiredprivate RedisCacheUtil<Object> redisCache;@Autowiredprivate BrandStoreService brandStoreService;@Overridepublic void onApplicationEvent(ContextRefreshedEvent event) {//spring 启动的时候缓存城市和国家等信息if(event.getApplicationContext().getDisplayName().equals("Root WebApplicationContext")){System.out.println("\n\n\n_________\n\n缓存数据 \n\n ________\n\n\n\n");List<City> cityList = brandStoreService.selectAllCityMessage();List<Country> countryList = brandStoreService.selectAllCountryMessage();Map<Integer,City> cityMap = new HashMap<Integer,City>();Map<Integer,Country> countryMap = new HashMap<Integer, Country>();int cityListSize = cityList.size();int countryListSize = countryList.size();for(int i = 0 ; i < cityListSize ; i ++ ){cityMap.put(cityList.get.getCity_id(), cityList.get;}for(int i = 0 ; i < countryListSize ; i ++ ){countryMap.put(countryList.get.getCountry_id(), countryList.get;}redisCache.setCacheIntegerMap("cityMap", cityMap);redisCache.setCacheIntegerMap("countryMap", countryMap);}}}

redis.properties

3)、applicationContext.xml

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207import java.io.Serializable;import java.util.ArrayList;import java.util.HashMap;import java.util.HashSet;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Set;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.data.redis.core.BoundSetOperations;import org.springframework.data.redis.core.HashOperations;import org.springframework.data.redis.core.ListOperations;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.SetOperations;import org.springframework.data.redis.core.ValueOperations;import org.springframework.stereotype.Service;@Servicepublic class RedisCacheUtil<T>{@Autowired @Qualifier("jedisTemplate")public RedisTemplate redisTemplate;/*** 缓存基本的对象,Integer、String、实体类等* @param key 缓存的键值* @param value 缓存的值* @return 缓存的对象*/public <T> ValueOperations<String,T> setCacheObject(String key,T value){ValueOperations<String,T> operation = redisTemplate.opsForValue(); operation.set(key,value);return operation;}/*** 获得缓存的基本对象。* @param key 缓存键值* @param operation* @return 缓存键值对应的数据*/public <T> T getCacheObject(String key/*,ValueOperations<String,T> operation*/){ValueOperations<String,T> operation = redisTemplate.opsForValue(); return operation.get;}/*** 缓存List数据* @param key 缓存的键值* @param dataList 待缓存的List数据* @return 缓存的对象*/public <T> ListOperations<String, T> setCacheList(String key,List<T> dataList){ListOperations listOperation = redisTemplate.opsForList();if(null != dataList){int size = dataList.size();for(int i = 0; i < size ; i ++){listOperation.rightPush(key,dataList.get;}}return listOperation;}/*** 获得缓存的list对象* @param key 缓存的键值* @return 缓存键值对应的数据*/public <T> List<T> getCacheList(String key){List<T> dataList = new ArrayList<T>();ListOperations<String,T> listOperation = redisTemplate.opsForList();Long size = listOperation.size;for(int i = 0 ; i < size ; i ++){dataList.add listOperation.leftPop;}return dataList;}/*** 缓存Set* @param key 缓存键值* @param dataSet 缓存的数据* @return 缓存数据的对象*/public <T> BoundSetOperations<String,T> setCacheSet(String key,Set<T> dataSet){BoundSetOperations<String,T> setOperation = redisTemplate.boundSetOps; /*T[] t = dataSet.toArray();setOperation.add;*/Iterator<T> it = dataSet.iterator();while(it.hasNext{setOperation.add);}return setOperation;}/*** 获得缓存的set* @param key* @param operation* @return*/public Set<T> getCacheSet(String key/*,BoundSetOperations<String,T> operation*/){Set<T> dataSet = new HashSet<T>();BoundSetOperations<String,T> operation = redisTemplate.boundSetOps; Long size = operation.size();for(int i = 0 ; i < size ; i++){dataSet.add(operation.pop;}return dataSet;}/*** 缓存Map* @param key* @param dataMap* @return*/public <T> HashOperations<String,String,T> setCacheMap(String key,Map<String,T> dataMap){HashOperations hashOperations = redisTemplate.opsForHash();if(null != dataMap){for (Map.Entry<String, T> entry : dataMap.entrySet { /*System.out.println("Key = " + entry.getKey() + ", Value = " + entry.getValue; */hashOperations.put(key,entry.getKey(),entry.getValue;} }return hashOperations;}/*** 获得缓存的Map* @param key* @param hashOperation* @return*/public <T> Map<String,T> getCacheMap(String key/*,HashOperations<String,String,T> hashOperation*/){Map<String, T> map = redisTemplate.opsForHash().entries;/*Map<String, T> map = hashOperation.entries;*/return map;}/*** 缓存Map* @param key* @param dataMap* @return*/public <T> HashOperations<String,Integer,T> setCacheIntegerMap(String key,Map<Integer,T> dataMap){HashOperations hashOperations = redisTemplate.opsForHash();if(null != dataMap){for (Map.Entry<Integer, T> entry : dataMap.entrySet { /*System.out.println("Key = " + entry.getKey() + ", Value = " + entry.getValue; */hashOperations.put(key,entry.getKey(),entry.getValue;} }return hashOperations;}/*** 获得缓存的Map* @param key* @param hashOperation* @return*/public <T> Map<Integer,T> getCacheIntegerMap(String key/*,HashOperations<String,String,T> hashOperation*/){Map<Integer, T> map = redisTemplate.opsForHash().entries;/*Map<String, T> map = hashOperation.entries;*/return map;}}

4、编码实现

spring的总配置文件,在里面假如一下的代码

通过redis缓存数据。(目的不是加快查询的速度,而是减少数据库的负担)

redis的相关参数配置设置。参数的值来自上面的properties文件

6.2 获取缓存数据

将那些经常要变化的参数配置成独立的propertis,方便以后的修改

由于Spring在配置文件中配置的bean默认是单例的,所以只需要通过Autowired注入,即可得到原先的缓存类。

123456789101112<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" /><property name="ignoreResourceNotFound" value="true" /><property name="locations"><list><value>classpath*:/META-INF/config/redis.properties</value></list></property></bean><import resource="spring-redis.xml" />

图片 1

这里测试我是在项目启动的时候到数据库中查找出国家和城市的数据,进行缓存,之后将数据去出

12345678910111213141516171819202122232425262728293031<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd" default-autowire="byName"> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <!-- <property name="maxIdle" value="6"></property> <property name="minEvictableIdleTimeMillis" value="300000"></property> <property name="numTestsPerEvictionRun" value="3"></property> <property name="timeBetweenEvictionRunsMillis" value="60000"></property> --><property name="maxIdle" value="${redis.maxIdle}"></property> <property name="minEvictableIdleTimeMillis" value="${redis.minEvictableIdleTimeMillis}"></property> <property name="numTestsPerEvictionRun" value="${redis.numTestsPerEvictionRun}"></property> <property name="timeBetweenEvictionRunsMillis" value="${redis.timeBetweenEvictionRunsMillis}"></property></bean> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" destroy-method="destroy"> <property name="poolConfig" ref="jedisPoolConfig"></property> <property name="hostName" value="${redis.hostName}"></property> <property name="port" value="${redis.port}"></property> <property name="timeout" value="${redis.timeout}"></property> <property name="usePool" value="${redis.usePool}"></property> </bean> <bean id="jedisTemplate" class="org.springframework.data.redis.core.RedisTemplate"> <property name="connectionFactory" ref="jedisConnectionFactory"></property> <property name="keySerializer"> <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/> </property> <property name="valueSerializer"> <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/> </property> </bean> </beans>
123456789redis.hostName=127.0.0.1redis.port=6379redis.timeout=15000redis.usePool=trueredis.maxIdle=6redis.minEvictableIdleTimeMillis=300000redis.numTestsPerEvictionRun=3redis.timeBetweenEvictionRunsMillis=60000

2)、spring-redis.xml

HashOperations  Map的缓存

转自:

4)、web。xml

设置spring的总配置文件在项目启动时加载

5)、redis缓存工具类

6)、测试

style=” color: white; font-size: 17px; font-weight: bold;”3、redis简介

redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string、list、set、zset(sorted
set
–有序集合)和hash。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave

6.1 项目启动时缓存数据

1234<context-param><param-name>contextConfigLocation</param-name><param-value>classpath*:/META-INF/applicationContext.xml</param-value><!-- --></context-param>
12345678910111213141516171819202122@Autowiredprivate RedisCacheUtil<User> redisCache;@RequestMapping("testGetCache")public void testGetCache(){/*Map<String,Country> countryMap = redisCacheUtil1.getCacheMap("country");Map<String,City> cityMap = redisCacheUtil.getCacheMap;*/Map<Integer,Country> countryMap = redisCacheUtil1.getCacheIntegerMap("countryMap");Map<Integer,City> cityMap = redisCacheUtil.getCacheIntegerMap("cityMap");for(int key : countryMap.keySet{System.out.println("key = " + key + ",value=" + countryMap.get;}System.out.println("------------city");for(int key : cityMap.keySet{System.out.println("key = " + key + ",value=" + cityMap.get;}}

1)、配置的文件(properties)

2、所需jar包

1、实现目标

注意:jdies和commons-pool两个jar的版本是有对应关系的,注意引入jar包是要配对使用,否则将会报错。因为commons-pooljar的目录根据版本的变化,目录结构会变。前面的版本是org.apache.pool,而后面的版本是org.apache.pool2…

ValueOperations  ——基本数据类型和实体类的缓存
ListOperations   ——list的缓存
SetOperations   ——set的缓存

相关文章

Comment ()
评论是一种美德,说点什么吧,否则我会恨你的。。。