快捷導(dǎo)航

SpringDataRedis入門和序列化方式解決內(nèi)存占用問題小結(jié)

更新時(shí)間：2022年12月10日 10:21:21 作者：是一個(gè)Bug

spring-data-redis是spring-data模塊的一部分,專門用來(lái)支持在spring管理項(xiàng)目對(duì)redis的操作，這篇文章主要介紹了SpringDataRedis入門和序列化方式解決內(nèi)存占用問題,需要的朋友可以參考下

spring-data-redis簡(jiǎn)介

spring-data-redis是spring-data模塊的一部分,專門用來(lái)支持在spring管理項(xiàng)目對(duì)redis的操作,使用java操作redis最常用的是使用jedis,但并不是只有jedis可以使用,像jdbc-redis jredis也都屬于redis的java客戶端,他們之間是無(wú)法兼容的,如果你在一個(gè)項(xiàng)目中使用了jedis,然后后來(lái)決定棄用掉改用jdbc-redis就比較麻煩了,spring-data-redis提供了redis的java客戶端的抽象,在開發(fā)中可以忽略掉切換具體的客戶端所帶來(lái)的影響,而且他本身就屬于spring的一部分,比起單純的使用jedis,更加穩(wěn)定.管理起來(lái)更加自動(dòng)化.(當(dāng)然jedis的缺點(diǎn)不止以上).

spring-data-redis的特性

自動(dòng)管理連接池,提供了一個(gè)高度封裝的RedisTemplate類
針對(duì)jedis客戶端的大量api進(jìn)行了歸類封裝,把同一類型的操作封裝成了operation接口.支持redis中的五種數(shù)據(jù)類型的操作.
針對(duì)數(shù)據(jù)的"序列化與反序列化"]提供了多種可以選擇的策略(RedisSerializer)
JdkSerializationRedisserializer:當(dāng)需要存儲(chǔ)java對(duì)象時(shí)使用．
stringRedisSerializer:當(dāng)需要存儲(chǔ)string類型的字符串時(shí)使用.
JacksonJsonRedisSerializer:將對(duì)象序列化成json的格式存儲(chǔ)在redis中,需要jackson-json工具的支持(目前我還沒使用過,不了解)

SpringCloud章節(jié)復(fù)習(xí)已經(jīng)過去，新的章節(jié)Redis開始了，這個(gè)章節(jié)中將會(huì)回顧Redis
主要依照以下幾個(gè)原則

基礎(chǔ)+實(shí)戰(zhàn)的Demo和Coding上傳到我的代碼倉(cāng)庫(kù)在原有基礎(chǔ)上加入一些設(shè)計(jì)模式，stream+lamdba等新的糖通過DeBug調(diào)試，進(jìn)入組件源碼去分析底層運(yùn)行的規(guī)則和設(shè)計(jì)模式

代碼會(huì)同步在我的gitee中去，覺得不錯(cuò)的同學(xué)記得一鍵三連求關(guān)注，感謝：
自定義RedisTemplate序列化-鏈接: DefineRedistemplate
StringRedisTemplate解決內(nèi)存占用-鏈接: StringRedisTemplate

可以進(jìn)入去看，覺得不錯(cuò)的博主記得一鍵三連支持下

基本介紹

1、什么是 SpringDataRedis?

2.常用API

實(shí)例Demo

自定義RedisTemplate序列化

引入依賴

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

        <!--JackSon依賴：為了手動(dòng)序列化使用-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

配置yaml文件，配置連接池屬性

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password:
    lettuce:
       pool:
         max-active: 8 #最大連接
         max-idle: 8  #最大空閑連接
         min-idle: 0  # 最小
         max-wait: 100ms # 連接等待時(shí)間

配置自定義的RedisTemplate

@Configuration
public class RedisConfig {


    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        
        //設(shè)置連接工廠
        template.setConnectionFactory(redisConnectionFactory);
        //key和hashkey使用String序列化
        template.setKeySerializer(RedisSerializer.string());
        template.setHashKeySerializer(RedisSerializer.string());
        //設(shè)置序列化工具
        GenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer();
        //value和hashValue采用JSON序列化方式
        template.setValueSerializer(serializer);
        template.setHashValueSerializer(serializer);
        return template;
    }
}

通過注入屬性拿 @Autowired private RedisTemplate<String, Object> redisTemplate;

@SpringBootTest
public class RedisTest {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @BeforeEach
    void testBefore(){
        System.out.println("開始測(cè)試");
    }

    @AfterEach
    void testAfter(){
        System.out.println("結(jié)束測(cè)試");
    }

    @Test
    void testString(){
        redisTemplate.opsForValue().set("name4", "li");
        Object name = redisTemplate.opsForValue().get("name1");
        System.out.println(name);
    }


    @Test
    void testUser(){
        User user = new User(1, "張大樹");
        redisTemplate.opsForValue().set("user1", user);
        User user1 = (User) redisTemplate.opsForValue().get("user1");
        System.out.println(user1);
    }

自定義的RestTemplate的內(nèi)存占用問題

這種方式會(huì)自帶類型數(shù)據(jù)，存放一萬(wàn)個(gè)數(shù)據(jù)，就會(huì)花費(fèi)一萬(wàn)個(gè)類型數(shù)據(jù)的空間，是非常浪費(fèi)的

    @Test
    void testUser(){
        User user = new User(1, "張大樹");
        redisTemplate.opsForValue().set("user1", user);
        User user1 = (User) redisTemplate.opsForValue().get("user1");
        System.out.println(user1);
    }

StringRedisTemplate解決內(nèi)存占用問題

        <!--JackSon依賴-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

@SpringBootTest
public class RedisTest1 {

    @Autowired
    private StringRedisTemplate redisTemplate1;

    private static final ObjectMapper mapper = new ObjectMapper();


    @BeforeEach
    void testBefore(){
        System.out.println("開始測(cè)試");
    }

    @AfterEach
    void testAfter(){
        System.out.println("結(jié)束測(cè)試");
    }

    @Test
    void testString(){
        redisTemplate1.opsForValue().set("name4", "li");
        Object name = redisTemplate1.opsForValue().get("name1");
        System.out.println(name);
    }


    @Test
    void testUser(){
        User user = new User(1, "張大樹");
        try {
            String value = mapper.writeValueAsString(user);
            redisTemplate1.opsForValue().set("user:"+ user.getName(), value);

            String user1 = redisTemplate1.opsForValue().get("user:張大樹");
            User readValue = mapper.readValue(user1, User.class);
            System.out.println(readValue);
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }
    }
}