springboot使用redisRepository和redistemplate操作redis的过

< dependency >

< groupId >org.springframework.boot</ groupId >

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

</ dependency >

<!-- commons-pool2 对象池依赖 -->

< dependency >

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

< artifactId >commons-pool2</ artifactId >

</ dependency >

redis:

  timeout: 10000ms # 连接超时时间

  host: 192.168.10.100 # Redis服务器地址

  port: 6379 # Redis服务器端口

  database: 0 # 选择哪个库，默认0库

  lettuce:

   pool:

   max-active: 1024 # 最大连接数，默认 8

   max-wait: 10000ms # 最大连接阻塞等待时间，单位毫秒，默认 -1

   max-idle: 200 # 最大空闲连接，默认 8

   min-idle: 5 # 最小空闲连接，默认 0

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import

org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;

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

import

org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;

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

/**

* Redis配置类

*

* @author zhoubin

* @since 1.0.0

*/

@Configuration

public class RedisConfig {

@Bean

public RedisTemplate<String,Object> redisTemplate(LettuceConnectionFactory

redisConnectionFactory){

RedisTemplate<String,Object> redisTemplate = new RedisTemplate<>();

//为string类型key设置序列器

redisTemplate.setKeySerializer( new StringRedisSerializer());

//为string类型value设置序列器

redisTemplate.setValueSerializer( new

GenericJackson2JsonRedisSerializer());

//为hash类型key设置序列器

redisTemplate.setHashKeySerializer( new StringRedisSerializer());

//为hash类型value设置序列器

redisTemplate.setHashValueSerializer( new

GenericJackson2JsonRedisSerializer());

redisTemplate.setConnectionFactory(redisConnectionFactory);

return redisTemplate;

}

}

/**

* 通过用户id获取菜单列表

*

* @return

*/

@Override

public List<Menu> getMenusByAdminId() {

Integer adminId = ((Admin)

SecurityContextHolder.getContext().getAuthentication().getPrincipal()).getId();

ValueOperations<String, Object> valueOperations =

redisTemplate.opsForValue();

//查询缓存中是否有数据

List<Menu> menus = (List<Menu>) valueOperations.get( "menu_" + adminId);

if (CollectionUtils.isEmpty(menus)){

menus = menuMapper.getMenusByAdminId(adminId);

valueOperations.set( "menu_" +adminId,menus);

}

return menus;

}

public class RedisConfig {

     @Bean

     public LettuceConnectionFactory redisConnectionFactory() {

         RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration( "127.0.0.1" , 6567 );

         redisStandaloneConfiguration.setPassword( "password" ); //如果有密码需要通过这个函数设置密码

         return new LettuceConnectionFactory(redisStandaloneConfiguration);

     }

@Bean

     public JedisConnectionFactory jedisConnectionFactory(){

         //如果使用jedis作为客户端也需要声明该bean 使用与上面的类似

}

@Bean

     public RedisTemplate<?,?> redisTemplate(){

         RedisTemplate<String,Object> template = new RedisTemplate<>();

     RedisSerializer<String> stringSerializer = new StringRedisSerializer();

     JdkSerializationRedisSerializer jdkSerializationRedisSerializer = new JdkSerializationRedisSerializer();

     template.setConnectionFactory(redisConnectionFactory());

     template.setKeySerializer(stringSerializer);

     template.setHashKeySerializer(stringSerializer);

     template.setValueSerializer(stringSerializer);

     template.setHashValueSerializer(jdkSerializationRedisSerializer);

     template.setEnableTransactionSupport( true );

     template.afterPropertiesSet();

     return template;

}

}

import lombok.Data;

import lombok.experimental.Accessors;

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

import org.springframework.data.redis.core.index.Indexed;

@Accessors (chain = true )

@Data

@RedisHash (value= "Student" ,timeToLive = 10 )

public class stu implements Serializable {

     public enum Gender{

         MALE,FEMALE

     }

     private String id;

     @Indexed

     private String name;

     private Gender gender;

     //RedisHash注解用于声明该实体将被存储与RedisHash中，如果需要使用repository的数据访问形式，这个注解是必须用到的 timetoLive为实体对象在数据库的有效期

     //@Indexed用于标注需要作为查询条件的属性

}

@Repository

public interface StuRepository extends CrudRepository<stu,String> {

stu findByName(String name);

//自定义查询方法，使用了@Indexed的name属性查询

}

@SpringBootTest

public class RedisApplicationTests {

     @Autowired

     StuRepository stuRepository;

     @Test

     void testSave(){

         stu student = new stu().setId( "0002" ).setName( "xiaoming" ).setGender(stu.Gender.FEMALE);

         stuRepository.save(student); //根据id更新或者新增记录

     }

     @Test

     void testFindBy(){

         //使用主键查询

         assert stuRepository.findById( "0002" ).isPresent();

         //根据自定义方法查询

         assert stuRepository.findByName( "xiaoming" ) != null ;

     }

}