Spring Cache 缓存

缓存不生效的原因核心原因queryUserInfo通过this.queryByUserName(userName)调用属于内部调用绕过了 Spring AOP 代理因此Cacheable不会生效。 原理说明Spring Cache 基于AOP 代理实现外部调用userService.queryByUserName(...)→ 经过代理 → 缓存拦截器生效 ✅内部调用this.queryByUserName(...)→ 直接调用原始方法 → 缓存拦截器不生效 ❌你的调用链javaqueryUserInfo() { // ❌ this.queryByUserName() 是内部调用缓存不生效 UserDTO user queryByUserName(userName); }✅ 解决方案方案一将queryByUserName方法注入自身推荐javaService public class UserServiceImpl implements UserService { Autowired private UserService self; // 注入自身代理对象 Override public String queryUserInfo(String userName) { // ✅ 通过代理对象调用缓存生效 UserDTO user self.queryByUserName(userName); // ... } Override Cacheable(value UserConstants.CACHE_USER, key #userName) public UserDTO queryByUserName(String userName) { System.out.println(###############################################); return userMapper.selectByUserName(userName); } }方案二将缓存方法移到单独的 Service更解耦javaService public class UserCacheService { Cacheable(value UserConstants.CACHE_USER, key #userName) public UserDTO queryByUserName(String userName) { return userMapper.selectByUserName(userName); } } Service public class UserServiceImpl implements UserService { Autowired private UserCacheService userCacheService; public String queryUserInfo(String userName) { UserDTO user userCacheService.queryByUserName(userName); // ... } }方案三使用AopContext.currentProxy()不推荐javaUserService proxy (UserService) AopContext.currentProxy(); UserDTO user proxy.queryByUserName(userName);需在启动类上添加EnableAspectJAutoProxy(exposeProxy true)。 验证方法第一次调用queryUserInfo会打印###############################################第二次调用同一userName如果缓存生效不应打印该行。若每次都打印说明仍是内部调用问题。 其他排查点已确认的EnableCaching是否存在→ 检查启动类UserConstants.CACHE_USER是否有效→ 需为字符串如users返回值是否可序列化→UserDTO需实现SerializableuserName参数是否变化→ 相同值才能命中缓存✅ 推荐方案方案一最简洁改动小立即生效。package com.weiyu.modules.system.service.impl; import com.alibaba.fastjson.JSON; import com.weiyu.framework.exception.BusinessException; import com.weiyu.framework.util.AesUtils; import com.weiyu.modules.system.constant.UserConstants; import com.weiyu.modules.system.context.UserContext; import com.weiyu.modules.system.converter.UserConverter; import com.weiyu.modules.system.dto.UserDTO; import com.weiyu.modules.system.dto.request.UserCreateRequest; import com.weiyu.modules.system.dto.request.UserUpdateRequest; import com.weiyu.modules.system.entity.Account; import com.weiyu.modules.system.enums.UserDataCommand; import com.weiyu.modules.system.mapper.UserMapper; import com.weiyu.modules.system.service.AccountService; import com.weiyu.modules.system.service.UserService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.util.ArrayList; import java.util.List; import java.util.Objects; /** * 用户 */ Service RequiredArgsConstructor Slf4j public class UserServiceImpl implements UserService { private final UserMapper userMapper; // 注入用户自身服务解决 queryByUserName 缓存不生效的问题 // queryUserInfo 通过 this.queryByUserName(userName) 调用属于 内部调用绕过了 Spring AOP 代理因此 Cacheable 不会生效。 private final UserService userService; private final AccountService accountService; private final UserConverter userConverter; /** * 根据用户名/账号查询用户信息 * * param userName 用户名/账号 * return 用户对象 */ Override Cacheable(value UserConstants.CACHE_USER, key #userName) public UserDTO queryByUserName(String userName) { System.out.println(###############################################); return userMapper.selectByUserName(userName); } /** * 新增用户 * * param createRequest 用户创建请求对象 */ Override public void add(UserCreateRequest createRequest) { // 业务实现预留 } /** * 修改用户信息 * * param userUpdateRequest 用户更新请求对象 */ Override public void update(UserUpdateRequest userUpdateRequest) { // 业务实现预留 } /** * 根据数据指令查询用户列表 * * param userName 用户名/账号 * param dataCommand 数据指令 * param id 业务 ID * return 用户列表 */ Override public ListUserDTO queryUsers(String userName, UserDataCommand dataCommand, Integer id) { // 初始化空集合避免返回null ListUserDTO userDTOs new ArrayList(8); switch (dataCommand) { case ALL: userDTOs userMapper.selectAllUsers(); break; case VALID: userDTOs userMapper.selectValidUsers(); break; case ASSAY_TASK_ASSAYER: userDTOs userMapper.selectAssayTaskAssayers(id); break; case TEST_REPORT_VERIFIER: userDTOs userMapper.selectTestReportVerifiers(userName); break; case TEST_REPORT_ISSUER: userDTOs userMapper.selectTestReportIssuers(userName); break; case WSPJ_REPORT_VERIFIER: userDTOs userMapper.selectWspjReportVerifiers(userName); break; case WSPJ_REPORT_ISSUER: userDTOs userMapper.selectWspjReportIssuers(userName); break; default: log.warn(不支持的用户列表查询指令:{}, dataCommand); } // 空集合防护 return CollectionUtils.isEmpty(userDTOs) ? new ArrayList() : userDTOs; } /** * 查询用户签名图片 * * param userName 用户名/账号 * return 签名图片字节数组 */ Override public byte[] queryUserSignatureImage(String userName) { Listbyte[] images userMapper.selectUserSignatureImages(userName); // 双重非空判断 if (!CollectionUtils.isEmpty(images)) { return images.get(0); } return new byte[0]; } /** * 获取用户上下文信息 * * param userName 用户名/账号 * return 用户上下文 */ Override public UserContext getUserContext(String userName) { UserDTO userDTO queryByUserName(userName); return Objects.isNull(userDTO) ? null : userConverter.toContext(userDTO); } /** * 获取用户信息普通用户 超级用户兼容 * * param userName 用户名/账号 * return 加密的用户信息 */ Override public String queryUserInfo(String userName) { try { // 1. 查询普通用户信息 // 通过内部调用 queryByUserName 或 this.queryByUserName 绕过 Spring AOP 代理Cacheable 缓存不生效。 // UserDTO user this.queryByUserName(userName); // 通过外部调用 userService.queryByUserName 经过 Spring AOP 代理Cacheable 缓存生效。 UserDTO user userService.queryByUserName(userName); // 2. 处理超级用户逻辑 if (user null) { Account account accountService.queryAccount(userName); // 空指针防护 if (account ! null UserConstants.SUPER_ACCOUNT_TYPE.equals(account.getType().ordinal())) { user new UserDTO(); user.setUserName(account.getAccount()); user.setRealName(account.getAccount()); user.setDeptName(UserConstants.SUPER_USER_DEPT_NAME); } } // 3. 对象序列化 String userJsonStr JSON.toJSONString(user); // 4. 返回加密的用户信息 return AesUtils.encrypt(userJsonStr); } catch (Exception e) { log.error(获取用户加密信息异常, e); throw new BusinessException(查询用户信息失败); } } /** * 查询用户角色 * * param userName 用户名/账号 * return 用户角色 */ Override public String queryUserRole(String userName) { return userMapper.selectUserRoleByUserName(userName); } }