在SpringBoot中添加Redis及配置方法

在实际的开发中，会有这样的场景。有一个微服务需要提供一个查询的服务，但是需要查询的数据库表的数据量十分庞大，查询所需要的时间很长。此时就可以考虑在项目中加入缓存。

引入依赖

在maven项目中引入如下依赖。并且需要在本地安装redis。

				?

									<dependency>

									  <groupid>org.springframework.boot</groupid>

									  <artifactid>spring-boot-starter-data-redis</artifactid>

									  <version>2.0.5.release</version>

									</dependency>

配置redis

在springboot的配置文件中添加如下代码。

				?

									redis:

									  host: 127.0.0.1

									  port: 6379

									  timeout: 5000

									  database: 0

									  jedis:

									   pool:

									    max-idle: 8

									    max-wait:

									    min-idle: 0

添加redis配置文件

新建名为redisconfig的配置类。

				?

									import com.fasterxml.jackson.annotation.jsonautodetect;

									import com.fasterxml.jackson.annotation.propertyaccessor;

									import com.fasterxml.jackson.databind.objectmapper;

									import org.springframework.cache.cachemanager;

									import org.springframework.cache.annotation.cachingconfigurersupport;

									import org.springframework.cache.annotation.enablecaching;

									import org.springframework.cache.interceptor.keygenerator;

									import org.springframework.context.annotation.bean;

									import org.springframework.context.annotation.configuration;

									import org.springframework.data.redis.cache.rediscacheconfiguration;

									import org.springframework.data.redis.cache.rediscachemanager;

									import org.springframework.data.redis.cache.rediscachewriter;

									import org.springframework.data.redis.connection.redisconnectionfactory;

									import org.springframework.data.redis.core.redistemplate;

									import org.springframework.data.redis.core.stringredistemplate;

									import org.springframework.data.redis.serializer.jackson2jsonredisserializer;

									import java.time.duration;

									/**

									 * redisconfig

									 *

									 * @author detectivehlh

									 * @date 2018-10-11 14:39

									 **/

									@configuration

									@enablecaching

									public class redisconfig extends cachingconfigurersupport {

									  @bean

									  @override

									  public keygenerator keygenerator() {

									    return (target, method, params) -> {

									      stringbuilder sb = new stringbuilder();

									      sb.append(target.getclass().getname());

									      sb.append(method.getname());

									      for (object obj : params) {

									        sb.append(obj.tostring());

									      }

									      return sb.tostring();

									    };

									  }

									  @bean

									  public redistemplate<string, string> redistemplate(redisconnectionfactory factory) {

									    objectmapper om = new objectmapper();

									    om.setvisibility(propertyaccessor.all, jsonautodetect.visibility.any);

									    om.enabledefaulttyping(objectmapper.defaulttyping.non_final);

									    //redis序列化

									    jackson2jsonredisserializer jackson2jsonredisserializer = new jackson2jsonredisserializer(object.class);

									    jackson2jsonredisserializer.setobjectmapper(om);

									    stringredistemplate template = new stringredistemplate(factory);

									    template.setvalueserializer(jackson2jsonredisserializer);

									    template.afterpropertiesset();

									    return template;

									  }

									  /**

									   * 自定义cachemanager

									   */

									  @bean

									  public cachemanager cachemanager(redistemplate redistemplate) {

									    //全局redis缓存过期时间

									    rediscacheconfiguration rediscacheconfiguration = rediscacheconfiguration.defaultcacheconfig().entryttl(duration.ofdays(1));

									    rediscachewriter rediscachewriter = rediscachewriter.nonlockingrediscachewriter(redistemplate.getconnectionfactory());

									    return new rediscachemanager(rediscachewriter, rediscacheconfiguration);

									  }

									}

添加缓存配置

在项目的service层中的实现类中，添加@cacheable注解。

				?

									import java.util.hashmap;

									/**

									 * userloginserviceimpl

									 *

									 * @author detectivehlh

									 * @date 2018-10-10 17:20

									 **/

									@service

									public class userloginserviceimpl implements userloginservice {

									  @autowired

									  private userloginmapper userloginmapper;

									  @override

									  @cacheable(value = "usercache")

									  public hashmap getbyusername(string username) {

									    system.out.println("此时没有走缓存");

									    return userloginmapper.getbyusername(username);

									  }

									}