基于 Redis+Caffeine+ 腾讯云的图片库查询上传加载存储优化与分布式 Session 登录

(2) 配置文件

在 application.yml 中添加 Redis 配置：

spring:
  redis:
    database: 0
    host: 127.0.0.1
    port: 6379
    timeout: 5000

(3) 单元测试验证

使用 StringRedisTemplate 测试基础增删改查操作。

@SpringBootTest
public class RedisStringTest {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Test
    public void testRedisStringOperations() {
        ValueOperations<String, String> valueOps = stringRedisTemplate.opsForValue();
        String key = "testKey";
        String value = "testValue";

        // 新增或更新
        valueOps.set(key, value);
        assertEquals(value, valueOps.get(key));

        // 修改
        valueOps.set(key, "updatedValue");
        assertEquals("updatedValue", valueOps.get(key));

        // 删除
        stringRedisTemplate.delete(key);
        assertNull(valueOps.get(key));
    }
}

(4) 实现带缓存的查询接口

注入 StringRedisTemplate，在查库前先查缓存。若命中直接返回，未命中则查库并回填缓存。

@PostMapping("/list/page/vo/cache")
public BaseResponse<Page<PictureVO>> listPictureVOByPageWithCache(
        @RequestBody PictureQueryRequest pictureQueryRequest,
        HttpServletRequest request) {
    long current = pictureQueryRequest.getCurrent();
    long size = pictureQueryRequest.getPageSize();
    ThrowUtils.throwIf(size > 20, ErrorCode.PARAMS_ERROR);

    pictureQueryRequest.setReviewStatus(PictureReviewStatusEnum.PASS.getValue());

    // 构建缓存 Key
    String queryCondition = JSONUtil.toJsonStr(pictureQueryRequest);
    String hashKey = DigestUtils.md5DigestAsHex(queryCondition.getBytes());
    String redisKey = String.format("yupicture:listPictureVOByPage:%s", hashKey);

    ValueOperations<String, String> opsedForValue = stringRedisTemplate.opsForValue();
    String cachedValue = opsedForValue.get(redisKey);

    if (cachedValue != null) {
        Page<PictureVO> cachedPage = JSONUtil.toBean(cachedValue, Page.class);
        return ResultUtils.success(cachedPage);
    }

    // 查询数据库
    Page<Picture> picturePage = pictureService.page(new Page<>(current, size), pictureService.getQueryWrapper(pictureQueryRequest));
    Page<PictureVO> pictureVOPage = pictureService.getPictureVOPage(picturePage, request);

    // 写入缓存，设置随机过期时间防止雪崩
    String cacheValue = JSONUtil.toJsonStr(pictureVOPage);
    int cachedExpireTime = 300 + RandomUtil.randomInt(0, 300);
    opsedForValue.set(redisKey, cacheValue, cachedExpireTime, TimeUnit.SECONDS);

    return ResultUtils.success(pictureVOPage);
}

测试表明，引入缓存后平均响应时间显著下降。注意序列化过程中 null 字段可能被过滤，导致前后端数据结构略有差异。

Caffeine 本地缓存

本地缓存将数据存储在 JVM 内存中，速度更快但无法跨节点共享。适用于小型数据集或单机高频访问场景。 Caffeine 是 Java 生态中主流的本地缓存库，支持容量控制、过期策略和异步操作。

后端开发

(1) 引入依赖

<!-- 本地缓存 Caffeine --><dependency><groupId>com.github.ben-manes.caffeine</groupId><artifactId>caffeine</artifactId><version>3.1.8</version></dependency>

(2) 初始化缓存

private final Cache<String, String> LOCAL_CACHE = Caffeine.newBuilder()
    .initialCapacity(1024)
    .maximumSize(10000L)
    .expireAfterWrite(5L, TimeUnit.MINUTES)
    .build();

(3) 替换逻辑

参考分布式缓存逻辑，将 Redis 操作替换为 LOCAL_CACHE.getIfPresent 和 put。

多级缓存

结合本地缓存的高性能和分布式缓存的一致性，构建两级缓存系统。

工作流程：

1. 第一级（Caffeine）：优先读取，命中直接返回。
2. 第二级（Redis）：未命中则查 Redis，命中则回写本地缓存。
3. 数据库：均未命中则查库，结果同时写入 Redis 和本地缓存。

这种架构提升了容错性，即使 Redis 故障，本地缓存仍可提供部分服务。

代码实现

// 1. 查询本地缓存
String cachedValue = LOCAL_CACHE.getIfPresent(cacheKey);
if (cachedValue != null) {
    return ResultUtils.success(JSONUtil.toBean(cachedValue, Page.class));
}

// 2. 查询分布式缓存
cachedValue = valueOps.get(cacheKey);
if (cachedValue != null) {
    LOCAL_CACHE.put(cacheKey, cachedValue);
    return ResultUtils.success(JSONUtil.toBean(cachedValue, Page.class));
}

// 3. 查询数据库并回写
Page<Picture> picturePage = pictureService.page(...);
Page<PictureVO> pictureVOPage = pictureService.getPictureVOPage(picturePage, request);
String cacheValue = JSONUtil.toJsonStr(pictureVOPage);
LOCAL_CACHE.put(cacheKey, cacheValue);
valueOps.set(cacheKey, cacheValue, 5, TimeUnit.MINUTES);
return ResultUtils.success(pictureVOPage);

常见问题与扩展

• 缓存击穿：热点数据过期时大量请求打库。解决方案：互斥锁或超长过期时间。
• 缓存穿透：查询不存在的数据。解决方案：布隆过滤器或缓存空值。
• 缓存雪崩：大量缓存同时过期。解决方案：随机过期时间或多级缓存。

二、图片上传优化

图片压缩

压缩能显著减少文件体积，降低带宽成本。推荐转换为 WebP 格式，相比 JPEG/PNG 体积更小且支持透明通道。

方案选择

利用腾讯云 COS 对象存储的数据万象服务，可在上传时自动处理图片规则，无需额外开发。

后端开发

(1) 修改 CosManager

在上传请求中增加图片处理规则，将后缀转为 .webp。

PutObjectRequest putObjectRequest = new PutObjectRequest(bucket, key, file);
PicOperations picOperations = new PicOperations();
picOperations.setIsPicInfo(1);

List<PicOperations.Rule> rules = new ArrayList<>();
PicOperations.Rule compressRule = new PicOperations.Rule();
compressRule.setFileId(webpKey);
compressRule.setRule("imageMogr2/format/webp");
compressRule.setBucket(bucket);
rules.add(compressRule);

picOperations.setRules(rules);
putObjectRequest.setPicOperations(picOperations);

(2) 解析处理结果

从上传结果中提取压缩后的图片信息，包括宽高、大小、格式等。

ProcessResults processResults = putObjectResult.getCiUploadResult().getProcessResults();
List<CIObject> objectList = processResults.getObjectList();
if (CollUtil.isNotEmpty(objectList)) {
    CIObject compressCiObject = objectList.get(0);
    return buildResult(originalFilename, compressCiObject);
}

(3) 封装返回结果

根据压缩对象构建 UploadPictureResult，确保前端获取到的是 WebP 地址。

测试显示，压缩效果显著，且原图与压缩图同名便于管理。

文件秒传

基于文件指纹（MD5）校验，避免重复上传。虽然本项目因 COS 限制未完全实现，但原理通用：

1. 客户端计算文件 MD5。
2. 服务端查询是否存在该 MD5。
3. 存在则直接返回路径，不存在则上传。

分片上传与断点续传

大文件传输建议使用 SDK 提供的分片功能，记录进度中断后可恢复，无需自行开发底层逻辑。

三、图片加载优化

缩略图

首页直接加载原图会导致加载慢、流量浪费。解决方案是在上传时生成缩略图，列表页仅加载缩略图。

实现步骤

1. 数据库变更：picture 表新增 thumbnailUrl 字段。
2. MyBatis 映射：XML 中增加字段映射。
3. 实体类同步：Picture, PictureVO 等类增加对应属性。
4. 处理逻辑：在上传规则中增加缩放参数 /thumbnail/128x128>。

注意：小图片生成缩略图可能反而变大，建议仅对大于 20KB 的图片生成缩略图。若无缩略图，则复用压缩图 URL。

CDN 加速

CDN（内容分发网络）将资源分发至全球节点，用户就近访问，大幅降低源站压力。

核心流程：

• 源站（COS）上传资源至 CDN。
• 用户请求命中 CDN 节点缓存，未命中则回源。

注意事项：

• 缓存策略：静态资源设置长期缓存。
• HTTPS：启用 SSL 证书保障安全。
• 防盗链：配置 Referer 白名单。
• 监控告警：设置流量阈值，防止费用超额。

浏览器缓存

通过 HTTP 头信息（如 Cache-Control）让浏览器缓存资源。配合 CDN 配置，可实现本地瞬间加载。

四、图片存储优化

数据沉降与清理

随着时间推移，数据热度降低。可通过生命周期规则将冷数据迁移至低频存储，降低成本。

清理策略：

• 立即清理：删除记录时同步删除文件。
• 定期清理：定时任务扫描过期数据。
• 手动清理：管理员触发特定范围清理。

后端开发

利用 Spring 的 @Async 异步删除文件，避免阻塞主线程。

@Async
public void clearPictureFile(Picture oldPicture) {
    String pictureUrl = oldPicture.getUrl();
    Long count = this.lambdaQuery().eq(Picture::getUrl, pictureUrl).count();
    if (count <= 1) {
        cosManager.deleteObject(pictureUrl);
        if (StrUtil.isNotBlank(oldPicture.getThumbnailUrl())) {
            cosManager.deleteObject(oldPicture.getThumbnailUrl());
        }
    }
}

启动类需开启异步支持 @EnableAsync。

五、登录态自动保持

重启服务器后重新登录体验不佳，可利用 Redis 管理 Session 实现分布式登录态保持。

(1) 引入依赖

<!-- Spring Session + Redis --><dependency><groupId>org.springframework.session</groupId><artifactId>spring-session-data-redis</artifactId></dependency>

(2) 配置 Session

spring:
  session:
    store-type: redis
    timeout: 2592000 # 30 天
server:
  servlet:
    session:
      cookie:
        max-age: 2592000

配置完成后，重启服务无需重新登录，Session 信息持久化在 Redis 中。