springboot使用redisRepository和redistemplate操作redis的过程解析_Java教程

导入依赖

菜单大部分情况下不会出现变化，我们可以将其放入Redis 加快加载速度

				?

									<dependency>

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

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

									</dependency>

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

									<dependency>

									<groupId>org.apache.commons</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

使用RedisTemplate访问redis

RedisConfig.java

				?

									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;

									}

									}

修改菜单方法：
MenuServiceImpl.java

				?

									/**

									* 通过用户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;

									}

使用Redisrepository访问redis

需要声明一配置项用于启用Repository以及模板

				?

									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;

									}

									}

实例：

entity

				?

									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:

				?

									@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;

									    }

									}