核心内容摘要
亚洲AAAAA：一次触及灵魂的东方奇遇
一、
项目概述本实战教程将演示如何在 Spring Boot 项目中通过 Spring Cache 注解方式集成 Redis实现高效的数据缓存功能。
我们将创建一个简单的用户管理系统展示各种缓存注解的
使用方法。
【工程增强说明】Spring Cache 本质上是一个缓存抽象层它并不关心你底层用的是 Redis、EhCache 还是 Caffeine它只定义了• CacheManager• Cache• CacheOperation真正决定缓存行为的是你配置的 CacheManager 实现而我们这里选择的是RedisCacheManager这意味着你的缓存具备本项目适合• 中大型 Spring Boot 后端服务• 分布式系统缓存标准模板• 公司级缓存规范示例【生产定位】这不是“Hello Redis”而是可以直接拿去当公司缓存架构样板的工程模板。
环境准备
1 依赖配置!--pom.xml--?xml version
0encodingUTF-8?project xmlnshttp://maven.apache.org/POM/
4.
0xmlns:xsihttp://www.w
org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/
4.
0http://maven.apache.org/xsd/maven-
4.
0.
xsdmodelVersion
4.
0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion
3.
0/versionrelativePath//parentgroupIdcom.example/groupIdartifactIdredis-cache-demo/artifactIdversion
1.
0/versionpropertiesjava.version17/java.version/propertiesdependencies!--SpringBootWeb--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!--SpringBootDataRedis--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId/dependency!--SpringBootCache--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-cache/artifactId/dependency!--Redis连接池--dependencygroupIdorg.apache.commons/groupIdartifactIdcommons-pool2/artifactId/dependency!--Lombok--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional/dependency!--单元测试--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependency!--缓存注解处理器--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-configuration-processor/artifactIdoptionaltrue/optional/dependency/dependencies/project【生产补充这几项依赖的真实职责】【版本选择说明】你用的是SpringBoot
3.
0Java17这意味着• Spring Framework
x• Jakarta 命名空间• 默认使用 Lettuce 客户端• Redis 7 完美适配是 当前主流生产版本组合非常优秀。
2 Redis 配置spring:application:name:redis-cache-demo redis:host:localhost port:6379password:123456database:0timeout:2000ms lettuce:pool:max-active:8max-wait:-1ms max-idle:8min-idle:0cache:type:redis redis:time-to-live:600000cache-null-values:truekey-prefix:CACHE:use-key-prefix:true【生产级参数解读】【生产建议版】生产环境更推荐spring:cache:redis:time-to-live:1800000cache-null-values:falsekey-prefix:PROD_CACHE:
核心代码实现这一部分是整篇文章的灵魂。
Spring Cache 用得好不好80% 都取决于这里的设计是否“工程化”。
1 缓存配置类ConfigurationEnableCachingpublicclassRedisCacheConfig{/** * 自定义Redis缓存配置 */BeanpublicRedisCacheConfigurationredisCacheConfiguration(){returnRedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMinutes(
)// 默认缓存10分钟.disableCachingNullValues()// 不缓存null值.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(newStringRedisSerializer())).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(newGenericJackson2JsonRedisSerializer()));}/** * 自定义缓存管理器配置 * 可以为不同的缓存名称设置不同的过期时间 */BeanpublicRedisCacheManagerBuilderCustomizerredisCacheManagerBuilderCustomizer(){returnbuilder-builder.withCacheConfiguration(userCache,RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMinutes(
).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(newGenericJackson2JsonRedisSerializer()))).withCacheConfiguration(productCache,RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMinutes(
).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(newGenericJackson2JsonRedisSerializer()))).withCacheConfiguration(shortCache,RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofSeconds(
));}}【工程级解读】这段代码做了三件非常关键的事【生产补充 1为什么必须统一序列化】如果你不显式指定.serializeValuesWith(...)Spring Boot 3 默认会使用JdkSerializationRedisSerializer问题是• Redis 里是二进制看不懂• Java 类变动就反序列化失败• 跨语言无法使用而你现在用的是GenericJackson2JsonRedisSerializer这是生产最优解之一【生产补充 2CacheName 的设计就是“缓存分区”】你现在的userCache productCache shortCache本质等价于这就是缓存层的领域模型分区设计。
【高级建议TTL 加随机防雪崩】生产建议DurationbaseDuration.ofMinutes(
;longrandomThreadLocalRandom.current().nextLong(
;.entryTtl(base.plusSeconds(random))避免大量 Key 同时失效。
2 实体类DataNoArgsConstructorAllArgsConstructorpublicclassUserimplementsSerializable{privateLongid;privateStringusername;privateStringemail;privateIntegerage;privateLocalDateTimecreateTime;privateLocalDateTimeupdateTime;}【生产补充Serializable 不是给 Redis 用的】JSON 序列化不需要 Serializable这个接口主要用于• Session• RPC• JVM 内对象传输保留它是良好习惯但不要误以为 Redis 依赖它。
3 服务层实现缓存注解体系实战这一节是整篇最重要的一节你这里已经写得非常专业。
3.
1 Cacheable读缓存标准模型Cacheable(keyuser: #id,unless#result null)publicUsergetUserById(Longid){log.info(从数据库查询用户: {},id);simulateSlowService();returnuserDatabase.get(id);}【缓存模型解释】这是标准的CacheAsidePattern流程先查缓存缓存没有 → 查 DB放入缓存返回结果这是互联网最经典缓存模式。
【生产级 Key 设计规范】你现在的 KeyCACHE:userCache::user:123完整结构是{前缀}:{CacheName}::{业务Key}这是非常优秀的企业级规范。
3.
2 CachePut更新必写缓存CachePut(keyuser: #user.id)publicUserupdateUser(Useruser){log.info(更新用户: {},user.getId());user.setUpdateTime(LocalDateTime.now());userDatabase.put(user.getId(),user);returnuser;}【生产风险提示】CachePut 在高并发下存在一个风险如果数据库写成功但 Redis 写失败会出现数据不一致。
生产环境建议• 关键路径DB 成功后 → 再删缓存• 再由下一次查询回填缓存双删模式即写 DB → 删除缓存 → 读请求触发重建而不是直接 CachePut 覆盖。
3.
3 CacheEvict缓存失效治理CacheEvict(keyuser: #id)publicvoiddeleteUserById(Longid){userDatabase.remove(id);}【生产增强双删策略】删除 DB删除缓存延迟 500ms 再删一次防止并发回写旧数据。
3.
4 Caching缓存一致性编排器Caching(evict{CacheEvict(keyuser: #oldEmail),...},put{CachePut(keyuser: #user.id),...})【工程评价】你这里的写法已经是企业级缓存一致性模型示范同时维护• ID 索引缓存• 业务组合索引缓存非常高级。
4 统一 Key 生成器避免 Key 拼接混乱在生产项目里最容易失控的就是 Key 拼接规则。
一旦大家各写各的user:idUSER_iduser::idRedis 会迅速变成“垃圾场”。
所以必须集中治理。
Component(customKeyGenerator)publicclassCustomKeyGeneratorimplementsKeyGenerator{OverridepublicObjectgenerate(Objecttarget,Methodmethod,Object...params){StringBuildersbnewStringBuilder();sb.append(method.getName()).append(:);for(Objectparam:params){sb.append(param).append(:);}returnsb.toString();}}使用方式Cacheable(cacheNamesuserCache,keyGeneratorcustomKeyGenerator)publicUsergetUserById(Longid){...}【工程价值】
5 Controller 层示例完整链路RestControllerRequestMapping(/users)RequiredArgsConstructorpublicclassUserController{privatefinalUserServiceuserService;GetMapping(/{id})publicUserget(PathVariableLongid){returnuserService.getUserById(id);}PutMappingpublicUserupdate(RequestBodyUseruser){returnuserService.updateUser(user);}DeleteMapping(/{id})publicvoiddelete(PathVariableLongid){userService.deleteUserById(id);}}此时完整链路为HTTP →Controller→Service→Cache→ DB这是标准 Spring Cache Redis 架构模型。
6 监控与运维生产必备缓存不监控 迟早出事故。
必须关注Redis 层面info stats info memory info keyspace关键字段keyspace_hits keyspace_misses used_memory evicted_keysSpring 层面Micrometermanagement:endpoints:web:exposure:include:health,info,metrics,prometheus GET/actuator/metrics/cache.gets GET/actuator/metrics/cache.puts GET/actuator/metrics/cache.evictions可直接对接• Prometheus• Grafana形成缓存命中率大盘。
7 CacheUtil 工具类兜底逃生舱Spring Cache 是声明式缓存但在极端场景你仍然需要手工控制 Redis。
ComponentRequiredArgsConstructorpublicclassCacheUtil{privatefinalStringRedisTemplateredisTemplate;publicvoiddelete(Stringkey){redisTemplate.delete(key);}publicvoiddeleteBatch(CollectionStringkeys){redisTemplate.delete(keys);}publicbooleanexists(Stringkey){returnBoolean.TRUE.equals(redisTemplate.hasKey(key));}}典型使用场景• 运维紧急清缓存• 批量修复脏数据• 灰度期间定向清理
生产级缓存治理清单如果你的项目满足下面 10 条就可以说你的缓存架构已经“工程化”了。
⭐ 高并发强烈建议
缓存三大经典事故 真实生产解法缓存用不好比不用还危险。
线上 90% 的 Redis 事故都逃不开这三类
1 缓存穿透Cache Penetration场景用户请求 ID-1/999999999Redis没有 → DB 也没有 每一次都直击数据库如果被恶意刷接口Redis完全失效DB 直接崩。
解决方案一不缓存 null 参数校验spring.cache.redis.cache-null-values:falseController先做参数合法性校验if(id
{thrownewIllegalArgumentException(非法参数);}解决方案二布隆过滤器高并发必备请求 →BloomFilter→ 不存在 → 直接拒绝 → 可能存在 →Redis→ DB工程级方案• Redis Redisson BloomFilter• MySQL ID 同步初始化布隆示意RBloomFilterLongbloomFilterredissonClient.getBloomFilter(user:id:bf);bloomFilter.tryInit(10000000L,
0.
;
2 缓存击穿Cache Breakdown场景某个超级热点Keyuser:110:00:00过期10:00:011万个请求同时打 DBDB 直接被冲死。
解决方案一互斥锁Cacheable(...)publicUsergetUser(Longid){synchronized(this){returnloadFromDB(id);}}缺点单机有效多实例无效。
解决方案二Redis 分布式锁生产标准StringlockKeylock:user:id;if(redis.setIfAbsent(lockKey,1,5,TimeUnit.SECONDS)){// 查询 DB 并回填缓存}else{// 等待 重试}解决方案三逻辑过期高端方案缓存里存{data:{...},expireTime:
T10:00:00}即使逻辑过期• 仍然返回旧数据• 异步线程刷新缓存• 用户无感知这才是大厂方案。
3 缓存雪崩Cache Avalanche场景1万个KeyTTL10分钟10分钟同时失效DB 死亡。
标准解法TTL 随机化longttlbaseTtlRandomUtil.randomLong(0,
;例如30分钟0~5分钟随机 兜底方案多级缓存 请求 → 本地Caffeine→Redis→ DB即使 Redis 掉了本地缓存还能抗 60 秒。
4 Redis 挂掉时你怎么办这是面试官最爱问的。
标准答案SpringCacheable(...)CircuitBreaker(nameredisBreaker,fallbackMethodfallback)
缓存更新策略你现在用的是否正确你当前方案是CachePutpublicUserupdateUser(Useruser)这是 直接覆盖缓存型。
但大厂推荐更新数据库 → 删除缓存 → 让下次自然重建原因• 防止脏数据• 防止并发覆盖• 逻辑简单推荐改成TransactionalpublicUserupdateUser(Useruser){userMapper.update(user);redisTemplate.delete(userCache::user.getId());returnuser;}
Spring Cache 真实工作原理一句话
总结Spring Cache AOP CacheManager CacheOperationSource流程方法调用 ↓CacheInterceptor↓ 查Redis↓ 有 → 返回 无 → 执行方法 → 放Redis
八、