springboot使用redisRepository和redistemplate操作redis的過(guò)程解析

更新時(shí)間：2022年05月30日 09:51:22 作者：march?of?Time

本文給大家介紹springboot整合redis/分別用redisRepository和redistemplate操作redis，本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友參考下吧

導(dǎo)入依賴

菜單大部分情況下不會(huì)出現(xiàn)變化，我們可以將其放入Redis 加快加載速度

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- commons-pool2 對(duì)象池依賴 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

基本配置

redis:
 timeout: 10000ms # 連接超時(shí)時(shí)間
 host: 192.168.10.100 # Redis服務(wù)器地址
 port: 6379 # Redis服務(wù)器端口
 database: 0 # 選擇哪個(gè)庫(kù)，默認(rèn)0庫(kù)
 lettuce:
  pool:
  max-active: 1024 # 最大連接數(shù)，默認(rèn) 8
  max-wait: 10000ms # 最大連接阻塞等待時(shí)間，單位毫秒，默認(rèn) -1
  max-idle: 200 # 最大空閑連接，默認(rèn) 8
  min-idle: 5 # 最小空閑連接，默認(rèn) 0

使用RedisTemplate訪問(wèn)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設(shè)置序列器
redisTemplate.setKeySerializer(new StringRedisSerializer());
//為string類型value設(shè)置序列器
redisTemplate.setValueSerializer(new
GenericJackson2JsonRedisSerializer());
//為hash類型key設(shè)置序列器
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
//為hash類型value設(shè)置序列器
redisTemplate.setHashValueSerializer(new
GenericJackson2JsonRedisSerializer());
redisTemplate.setConnectionFactory(redisConnectionFactory);
return redisTemplate;
}
}

修改菜單方法：
MenuServiceImpl.java

/**
* 通過(guò)用戶id獲取菜單列表
*
* @return
*/
@Override
public List<Menu> getMenusByAdminId() {
Integer adminId = ((Admin)
SecurityContextHolder.getContext().getAuthentication().getPrincipal()).getId();
ValueOperations<String, Object> valueOperations =
redisTemplate.opsForValue();
//查詢緩存中是否有數(shù)據(jù)
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訪問(wèn)redis

需要聲明一配置項(xiàng)用于啟用Repository以及模板

public class RedisConfig {
    @Bean
    public LettuceConnectionFactory redisConnectionFactory() {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration("127.0.0.1", 6567);
        redisStandaloneConfiguration.setPassword("password");//如果有密碼需要通過(guò)這個(gè)函數(shù)設(shè)置密碼
        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;
    
}
}

實(shí)例：

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注解用于聲明該實(shí)體將被存儲(chǔ)與RedisHash中，如果需要使用repository的數(shù)據(jù)訪問(wèn)形式，這個(gè)注解是必須用到的 timetoLive為實(shí)體對(duì)象在數(shù)據(jù)庫(kù)的有效期
    //@Indexed用于標(biāo)注需要作為查詢條件的屬性
}

寫(xiě)接口
repository:

@Repository
public interface StuRepository extends CrudRepository<stu,String> {
stu findByName(String name);
//自定義查詢方法，使用了@Indexed的name屬性查詢
}

調(diào)用：

@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);//根據(jù)id更新或者新增記錄
    }
    @Test
    void testFindBy(){
        //使用主鍵查詢
        assert stuRepository.findById("0002").isPresent();
        //根據(jù)自定義方法查詢
        assert stuRepository.findByName("xiaoming") !=null;
    }
}

到此這篇關(guān)于springboot使用redisRepository和redistemplate操作redis的過(guò)程解析的文章就介紹到這了,更多相關(guān)springboot整合redis內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: