分段存储Redis键值对的方法详解

public interface CacheService {

    /**
     * 添加一个字符串键值对
     * @param key 键
     * @param value 值
     */
    void setString(String key, String value);
}

import com.hezy.service.CacheService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class RedisServiceImpl implements CacheService {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;


    @Override
    public void setString(String key, String value) {
        redisTemplate.opsForValue().set(key, value);
    }
}

import com.hezy.service.impl.RedisServiceImpl;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class RedisServiceImplTest {

    @Autowired
    private RedisServiceImpl redisService;

    @Test
    public void test1() {
        String key = "content";
        String value = "这是一段分非常大非常大的字符串…………………………非常大";
        redisService.setString(key, value);
    }
}

    /**
     * 分段存储
     * @param key 键
     * @param value 值
     * @param chunkSize 每个分段大小
     */
    void setStrSub(String key, String value, int chunkSize);

    @Override
    public void setStrSub(String key, String value, int chunkSize) {
        // 将value，按照length，分成多个部分
        int totalChunks = (int) Math.ceil((double) value.length() / chunkSize);
        // 定义一个分段数据key集合
        List<String> subKeys = new ArrayList<>(totalChunks);
        // 将字符串分成多段
        for (int i = 0; i < totalChunks; i++) {
            // 计算分段起止位置
            int startIndex = i * chunkSize;
            int endIndex = Math.min(startIndex + chunkSize, value.length());
            // 获取对应分段数据
            String chunkValue = value.substring(startIndex, endIndex);
            // 拼接分段key
            String subKey = key + "_" + i;
            // 存储分段数据
            setString(subKey, chunkValue);
            // 将分段key添加到集合
            subKeys.add(subKey);
        }
        // 分段key添加到集合
        setList(key, subKeys);
    }

    @Override
    public void setList(String key, List value) {
        redisTemplate.opsForList().rightPushAll(key, value);
    }

    @Test
    public void test2() {
        String key = "content";
        String value = "这是一段分非常大非常大的字符串…………………………非常大";
        redisService.setStrSub(key, value, 5);
    }

    /**
     * 获取字符串（分段）
     * @param key
     * @return
     */
    String getStrSub(String key);

    @Override
    public String getStrSub(String key) {
        // 先把分段key获取出来
        List<String> list = getList(key);
        // 字符串拼接，用StringBuilder，线程安全
        StringBuilder stringBuilder = new StringBuilder();
        for (String subKey : list) {
            String subValue = getString(subKey);
            // 这里要跳过null，不然最后输出会把null转为字符串
            if (subValue == null) {
                continue;
            }
            stringBuilder.append(subValue);
        }
        // 如果没有数据，返回null
        return "".contentEquals(stringBuilder) ? null : stringBuilder.toString();
    }

    @Override
    public List getList(String key) {
        return redisTemplate.opsForList().range(key, 0, -1);
    }

    @Test
    public void test3() {
        String content = redisService.getStrSub("content");
        System.out.println(content);
    }