当前位置：首页 > news >正文

Spring Cache 缓存

news 2026/8/16 12:50:01

🔍 缓存不生效的原因

核心原因：queryUserInfo通过this.queryByUserName(userName)调用，属于内部调用，绕过了 Spring AOP 代理，因此@Cacheable不会生效。

📌 原理说明

Spring Cache 基于AOP 代理实现：

外部调用userService.queryByUserName(...)→ 经过代理 → 缓存拦截器生效 ✅
内部调用this.queryByUserName(...)→ 直接调用原始方法 → 缓存拦截器不生效 ❌

你的调用链：

java

queryUserInfo() { // ❌ this.queryByUserName() 是内部调用，缓存不生效 UserDTO user = queryByUserName(userName); }

✅ 解决方案

方案一：将`queryByUserName`方法注入自身（推荐）

java

@Service 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（更解耦）

java

@Service 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()`（不推荐）

java

UserService proxy = (UserService) AopContext.currentProxy(); UserDTO user = proxy.queryByUserName(userName);

需在启动类上添加@EnableAspectJAutoProxy(exposeProxy = true)。

🎯 验证方法

第一次调用queryUserInfo会打印###############################################
第二次调用同一userName，如果缓存生效，不应打印该行。
若每次都打印，说明仍是内部调用问题。

📌 其他排查点（已确认的）

@EnableCaching是否存在？→ 检查启动类
UserConstants.CACHE_USER是否有效？→ 需为字符串，如"users"
返回值是否可序列化？→UserDTO需实现Serializable
userName参数是否变化？→ 相同值才能命中缓存

✅ 推荐方案

方案一最简洁，改动小，立即生效。🎯

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 List<UserDTO> queryUsers(String userName, UserDataCommand dataCommand, Integer id) { // 初始化空集合，避免返回null List<UserDTO> 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) { List<byte[]> 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); } }

查看全文

http://www.jsqmd.com/news/1374368/