spring-data-redis 2.0 的使用示例代码

<!-- redis -->

<dependency>

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

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

</dependency>

<!--spring2. 0 集成redis所需common-pool2-->

<dependency>

   <groupid>org.apache测试数据mons</groupid>

   <artifactid>commons-pool2</artifactid>

   <version> 2.4 . 2 </version>

</dependency>

redis:

  #  reids的连接ip

  host: 127.0 . 0.1

  port: 6379

  password: helloworld

  # redis默认情况下有 16 个分片，这里配置具体使用的分片，默认是 0

  database: 0

  # 连接超时时间（毫秒)

  timeout: 10000ms

  # redis client配置，使用lettuce

  lettuce:

   pool:

    # 连接池中的最小空闲连接 默认 0

    min-idle: 0

    # 连接池最大阻塞等待时间（使用负值表示没有限制） 默认 - 1

    max-wait: 1000ms

    # 连接池最大连接数（使用负值表示没有限制） 默认 8

    max-active: 8

    # 连接池中的最大空闲连接 默认 8

    max-idle: 8

@enableswagger2      // 使用swagger api 功能

@enablecaching       // 使用缓存

@springbootapplication

public class starter {

   public static void main(string[] args) {

     springapplication.run(starter. class , args);

   }

}

/**

  * 基于id 获取用户信息

  */

@cacheable (value= "user" , key= "#id" , unless= "#result == null" )

public userdto getuserbyid( int id) {

   user userentity = usermapper.getuserbyid(id);

   if (userentity == null ){

     return null ;

   }

   /* entity 转 dto */

   userdto userdto = new userdto();

   userdto.setage(userentity.getage());

   userdto.setid(id);

   userdto.setname(userentity.getname());

   userdto.setcreatetime(unixtime2string(userentity.getcreatetime()));

   userdto.setphone(userentity.getphone());

   userdto.setemail(userentity.getemail());

   return userdto;

}

@cacheput (value = "user" , key= "#p0.id" )

public userdto updateuser(inputuserinfodto inputuserinfodto){

   usermapper.updateuser(inputuserinfodto.getid(), inputuserinfodto.getname(), inputuserinfodto.getage());

   user userentity = usermapper.getuserbyid(inputuserinfodto.getid()); /* entity 转 dto */

   if ( null == userentity){

     return null ;

   }

   userdto userdto = new userdto();

   userdto.setage(userentity.getage());

   userdto.setid(userentity.getid());

   userdto.setname(userentity.getname());

   userdto.setcreatetime(unixtime2string(userentity.getcreatetime()));

   userdto.setphone(userentity.getphone());

   userdto.setemail(userentity.getemail());

   return userdto;

}

@cacheevict (value = "user" , key= "#id" )

public void deleteuser( int id){

   usermapper.deleteuser(id);

}

@data

public class userdto implements serializable {

//public class userdto implements serializable {

   private int id;

   private string name;

   private int age;

   private string createtime;

   private string phone;

   private string email;

}

@configuration

@conditionalonclass (redisoperations. class )

@enableconfigurationproperties (redisproperties. class )

public class redisconfig extends cachingconfigurersupport{

   @bean

   public cachemanager cachemanager(redisconnectionfactory factory) {

     redisserializer<string> redisserializer = new stringredisserializer();

     jackson2jsonredisserializer jackson2jsonredisserializer = new jackson2jsonredisserializer(object. class );

     //解决查询缓存转换异常的问题

     objectmapper om = new objectmapper();

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

     om.enabledefaulttyping(objectmapper.defaulttyping.non_final);

     jackson2jsonredisserializer.setobjectmapper(om);

     // 配置序列化（解决乱码的问题）

     rediscacheconfiguration config = rediscacheconfiguration.defaultcacheconfig()

                       .entryttl(duration.zero)

                       .serializekeyswith(redisserializationcontext.serializationpair.fromserializer(redisserializer))

                       .serializevalueswith(redisserializationcontext.serializationpair.fromserializer(jackson2jsonredisserializer))

                       .disablecachingnullvalues();

     rediscachemanager cachemanager = rediscachemanager.builder(factory).cachedefaults(config).build();

     return cachemanager;

   }

}