你的位置:首页 > Java教程

[Java教程]spring + redis 实现数据的缓存


1、实现目标

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

2、所需jar包

  

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

3、redis简介

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

4、编码实现

1)、配置的文件(properties)

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

  redis.properties

redis.hostName=127.0.0.1redis.port=6379redis.timeout=15000redis.usePool=trueredis.maxIdle=6redis.minEvictableIdleTimeMillis=300000redis.numTestsPerEvictionRun=3redis.timeBetweenEvictionRunsMillis=60000

2)、spring-redis.

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

<beans ="http://www.springframework.org/schema/beans"  ="http://www.w3.org/2001/ 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> 

3)、applicationContext.

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

<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. />

4)、web。

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

  <context-param>    <param-name>contextConfigLocation</param-name>    <param-value>classpath*:/META-INF/applicationContext.</param-value><!-- -->  </context-param>

5)、redis缓存工具类

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

HashOperations  Map的缓存

import 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.ClassPathimport 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(key);  }    /**   * 缓存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(i));      }    }        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(key);        for(int i = 0 ; i < size ; i ++)    {      dataList.add((T) listOperation.leftPop(key));    }        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(key);      /*T[] t = (T[]) dataSet.toArray();       setOperation.add(t);*/            Iterator<T> it = dataSet.iterator();    while(it.hasNext())    {      setOperation.add(it.next());    }        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(key);          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(key);    /*Map<String, T> map = hashOperation.entries(key);*/    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(key);    /*Map<String, T> map = hashOperation.entries(key);*/    return map;  }}  

6)、测试

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

6.1  项目启动时缓存数据

import 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);    @Autowired  private RedisCacheUtil<Object> redisCache;    @Autowired  private BrandStoreService brandStoreService;    @Override  public 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(i).getCity_id(), cityList.get(i));      }            for(int i = 0 ; i < countryListSize ; i ++ )      {        countryMap.put(countryList.get(i).getCountry_id(), countryList.get(i));      }            redisCache.setCacheIntegerMap("cityMap", cityMap);      redisCache.setCacheIntegerMap("countryMap", countryMap);    }  }  }

6.2  获取缓存数据

  @Autowired  private RedisCacheUtil<User> redisCache;  @RequestMapping("testGetCache")  public void testGetCache()  {    /*Map<String,Country> countryMap = redisCacheUtil1.getCacheMap("country");    Map<String,City> cityMap = redisCacheUtil.getCacheMap("city");*/    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(key));    }        System.out.println("------------city");    for(int key : cityMap.keySet())    {      System.out.println("key = " + key + ",value=" + cityMap.get(key));    }  }   

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

 

  致谢:感谢您的阅读!

 




丽江旅游报价价格丽江旅游团购优惠深圳去丽江旅游报价跟团去丽江旅游多少钱几月去丽江旅游最好在野外露营遇到意外怎么办? 暑假出门注意事项有哪些? 暑假学生票什么时候开始可以买? 寒暑假购买学生票要符合什么条件? 桂林两江四湖三月三门票多少钱?两江四湖三月三门票价格? 两江四湖三月三有演出吗?桂林两江四湖三月三演出时间? 三月三两江四湖夜游时间?夜游桂林两江四湖几点开始? 两江四湖三月三有什么好玩的?桂林两江四湖三月三活动安排? 三亚鹿回头公园好玩吗?国庆去鹿回头公园怎么样? 桂林各个市县好玩的地方推荐 2015厦门中秋节有什么活动?2015中国厦门中秋旅游嘉年华 从北京西站到首都机场,坐大巴怎么坐? 长隆欢乐世界冬天有什么优惠?广州长隆欢乐世界2015圣诞活动? 长隆欢乐世界免费吃自助吗?广州长隆欢乐世界自助什么餐? 广州长隆野生动物园有专车吗?香江野生动物园在哪里上车? 香江野生动物园官网?广州香江野生动物园怎样预订? IDT71T75702S75PFGI Datasheet IDT71T75702S75PFGI Datasheet IDT71T75702S75PFI Datasheet IDT71T75702S75PFI Datasheet IDT71T75702S75PFI8 Datasheet IDT71T75702S75PFI8 Datasheet 公司年会表演节目 公司年会表演节目 公司年会表演节目 泡温泉泳衣 泡温泉泳衣 泡温泉泳衣 五星漂流 五星漂流 五星漂流