springboot使用redis对单个对象进行自动缓存更新删除的实现
Springboot的项目搭建在此省略,pom文件依赖什么的就不说了
创建一个实体类
@Data @EqualsAndHashCode(callSuper = true) @Accessors(chain = true) @ApiModel(value="ERepository对象", description="题库") public class ERepository extends BasicModel<ERepository> implements Serializable { private static final long serialVersionUID = 1L; @TableId(value = "id", type = IdType.AUTO) private Long id; @ApiModelProperty(value = "安全分类id") private Long safeTypeId; @ApiModelProperty(value = "题型") private Integer quesType; @ApiModelProperty(value = "题干") private String quesContent; @ApiModelProperty(value = "选项") private String options; @ApiModelProperty(value = "答案") private String answer; @ApiModelProperty(value = "是否审核(0:未审核,1:已审核)") // @TableField("is_check") private Boolean isCheck; @Override protected Serializable pkVal() { return this.id; } }
创建一个控制器
@RequiredArgsConstructor @RestController @Slf4j @Api(tags = "题库模块") @RequestMapping("/api/eRepository") public class ERepositoryController { private final IERepositoryService eRepositoryService; @ApiOperation("查询所有题目") @GetMapping(value = "/all") @ResponseBody public Result<List<ERepository>> getRespository(ERepositoryQueryCriteria criteria){ return Result.success(eRepositoryService.getRepositoryAll(criteria)); } @ApiOperation(value = "多条件查询题目",notes = "根据各种条件查询,可分页 \n author:LiFang 2021/7/25") @GetMapping @ResponseBody public Result<IPage<ERepositoryDTO>> getRespository(PageVO pageVO,ERepositoryQueryCriteria criteria){ return Result.success(eRepositoryService.getRepository(pageVO.buildPage(),criteria)); } @ApiOperation(value = "按安全分类id查询") @GetMapping(value = "/getBySafeTypeId") public Result<List<ERepository>> getRespositoryBySafeTypeId(Long id){ Long start = System.currentTimeMillis(); List<ERepository> list = eRepositoryService.getBySafeTypeId(id); Long end = System.currentTimeMillis(); System.out.println("耗时:"+(end-start)); return Result.success(list); } @ApiOperation("新增题目") @PostMapping public Result<Void> add(@RequestBody ERepository eRepository){ eRepository.setDeleted(false); eRepositoryService.addRepository(eRepository); return Result.success(); } @ApiOperation("修改题目") @PutMapping public Result<Object> update(@RequestBody ERepository eRepository){ eRepository.setDeleted(false); log.info(StrUtil.format("【修改题目 /api/eRepository】操作人id:{},被修改题目id:{}", SecurityUtils.getCurrentUserId(), eRepository.getId())); return Result.success(eRepositoryService.updateRepository(eRepository)); } @ApiOperation("删除题目") @DeleteMapping public Result<Void> delete(@RequestBody Set<Long> ids){ eRepositoryService.deleteById(ids); return Result.success(); } }
建个service
public interface IERepositoryService extends IBasicService<ERepository> { List<ERepository> getRepositoryAll(ERepositoryQueryCriteria criteria); IPage<ERepositoryDTO> getRepository(IPage<ERepository> page,ERepositoryQueryCriteria criteria); List<ERepository> addRepository(ERepository eRepository); List<ERepository> updateRepository(ERepository eRepository); void deleteById(Set<Long> id); List<ERepository> getBySafeTypeId(Long id); }
新建service实现类
使用注解进行自动缓存、更新、删除主要是在service的实现类里写
@Slf4j @Service @EnableCaching @RequiredArgsConstructor @CacheConfig(cacheNames = "repository") public class ERepositoryServiceImpl extends BasicServiceImpl<ERepositoryMapper, ERepository> implements IERepositoryService { private final ERepositoryMapper eRepositoryMapper; private final ERepositoryStruct eRepositoryStruct; // private final ERepositoryServiceImpl eRepositoryService; private final RedisUtils redisUtils; @Override public List<ERepository> getRepositoryAll(ERepositoryQueryCriteria criteria) { List<ERepository> eRepositories = eRepositoryMapper.selectList(buildERepositoryCriteria(criteria)); return eRepositories; } @Override public IPage<ERepositoryDTO> getRepository(IPage<ERepository> page,ERepositoryQueryCriteria criteria) { IPage<ERepository> eRepositoryPage = eRepositoryMapper.selectPage(page,buildERepositoryCriteria(criteria)); List<ERepositoryDTO> eRepositoryDTOList = eRepositoryStruct.toDto(eRepositoryPage.getRecords()); return PageUtil.toMapStructPage(eRepositoryPage,eRepositoryDTOList); } @Cacheable(key = "'safeTypeId:' + #p0") @Override public List<ERepository> getBySafeTypeId(Long id) { List<ERepository> eRepositoryList = eRepositoryMapper.getBySafeTypeId(id); return eRepositoryList; } private LambdaQueryWrapper<ERepository> buildERepositoryCriteria(ERepositoryQueryCriteria criteria){ LambdaQueryWrapper<ERepository> wrapper = new LambdaQueryWrapper<>(); // wrapper.eq(ERepository::getDeleted,false); if (ObjectUtil.isNotNull(criteria.getId())) { wrapper.eq(ERepository::getId,criteria.getId()); } if(StrUtil.isNotBlank(criteria.getQuesContent())){ //默认使用like匹配 wrapper.like(ERepository::getQuesContent, criteria.getQuesContent()); } if (ObjectUtil.isNotNull(criteria.getSafeTypeId())) { wrapper.eq(ERepository::getSafeTypeId, criteria.getSafeTypeId()); } if(ObjectUtil.isNotNull(criteria.getQuesType())){ wrapper.eq(ERepository::getQuesType,criteria.getQuesType()); } if (ObjectUtil.isNotNull(criteria.getStartTime()) && ObjectUtil.isNotNull(criteria.getEndTime())) { wrapper.between(ERepository::getCreateTime , criteria.getStartTime(), criteria.getEndTime()); } return wrapper; } @CachePut(key = "'safeTypeId:' + #p0.safeTypeId") @Override public List<ERepository> addRepository(ERepository eRepository) { eRepositoryMapper.insert(eRepository); List<ERepository> list = eRepositoryMapper.getBySafeTypeId(eRepository.getSafeTypeId()); // list.add(eRepository); return list; } @CachePut(key = "'safeTypeId:' + #p0.safeTypeId") @Override public List<ERepository> updateRepository(ERepository resources) { ERepository eRepository = getById(resources.getId()); if(ObjectUtil.isEmpty(eRepository)){ log.error(StrUtil.format("【修改题目失败】操作人id:{},修改目标ERepository为空,目标id:{}", SecurityUtils.getCurrentUserId(), resources.getId())); throw new BadRequestException("修改失败,当前数据id不存在"); } eRepositoryMapper.updateById(resources); log.info(StrUtil.format("【修改题目成功】操作人id:{},修改目标题目:{}", SecurityUtils.getCurrentUserId(), resources)); List<ERepository> list = eRepositoryMapper.getBySafeTypeId(resources.getSafeTypeId()); // list.removeIf(item -> resources.geMId().equals(item.getId())); // list.add(resources); //清理缓存 delCaches(resources.getId()); return list; } @Override public void deleteById(Set<Long> ids) { for (Long id : ids){ eRepositoryMapper.deleteById(id); //清理缓存 delCaches(id); } log.info(StrUtil.format("【删除题目成功】操作人id:{},删除目标repositories:{}", SecurityUtils.getCurrentUserId(), ids.toString())); } /** * 清理缓存 * * @param id / */ private void delCaches(Long id) { Long safeTypeId = eRepositoryMapper.getSafeTypeIdById(id); //删除属于该安全分类的题库缓存 redisUtils.del(CacheKey.REPOSITORY_SAFETYPEID + safeTypeId); } }
新建mapper接口
@Component public interface ERepositoryMapper extends BasicMapper<ERepository> { @Select("SELECT * FROM e_repository WHERE safe_type_id = #{safeTypeId} AND is_deleted=0") List<ERepository> getBySafeTypeId(Long safeTypeId); @Select("SELECT safe_type_id FROM e_repository WHERE id= #{id} AND is_deleted=0") Long getSafeTypeIdById(Long id); }
6.启动项目
使用swagger测试根据安全分类id查询题目接口,该分类题目的查询结果成功响应,这时打开redis管理工具,可以看到题目按分类已经被缓存到redis中了。
再次用swagger测试查询该分类id的所有题目,可以看到IDEA控制台并没有sql语句打印,仍然有查询结果成功响应。
@CacheConfig(cacheNames = “repository”)
放在service实现类上,用来配置缓存名称。
@Cacheable(key = “‘safeTypeId:' + #p0”)
放在查询方法上,‘safeTypeId:' + #p0作为键,p0是该方法的第一个参数。
作用:使用这两个注解,会使查询方法首先会根据key从缓存中查询,如果缓存中没有该键,则从使用sql语句到数据库中差查询,查询后,响应结果,并自动将方法的返回结果放入redis缓存中,下一次,如果再查询就直接从redis缓存中查询。
好处:极大提升查询效率,并减轻服务器压力。
@CachePut(key = “‘safeTypeId:' + #p0.safeTypeId”)
通常加到添加和更新方法上
- 当访问新增题目接口时,数据库新增题目成功,方法返回结果会存入redis中,这次再访问查询属于该分类的题目接口,会发现该分类的题目已经添加成功。
- 当访问更新题目接口时,数据库更新题目成功,方法返回结果会根据key存入redis中,当再根据该key查询题目时,会发现控制台并没有打印sql语句,直接从redis中查询出结果。
@CacheEvict(key = “#p0”)
用在删除方法上,走该删除方法,会删除数据库中的该条记录,而且会删除key为方法的第一个参数(通常为id)的redis记录。再次查询该条记录,发现查询不到了。
注意:上面的方法不能用来存储集合。
到此这篇关于springboot使用redis对单个对象进行自动缓存更新删除的实现的文章就介绍到这了,更多相关springboot redis自动缓存更新删除内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题
这篇文章主要介绍了解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-04-28- 这篇文章主要介绍了c#自带缓存使用方法,包括获取数据缓存、设置数据缓存、移除指定数据缓存等方法,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了Redis连接池配置及初始化实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-29
- 这篇文章主要介绍了详解如何清理redis集群的所有数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-18
详解redis desktop manager安装及连接方式
这篇文章主要介绍了redis desktop manager安装及连接方式,本文图文并茂给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2021-01-15- 这篇文章主要为大家详细介绍了SpringBoot实现excel文件生成和下载,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-02-09
- 这篇文章主要介绍了MyBatis-Plus自动填充功能失效导致的原因及解决,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-04
- 这篇文章主要介绍了IDEA中的clean,清除项目缓存图文教程,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-09-25
- 这篇文章主要介绍了浅谈redis key值内存消耗以及性能影响,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-07
- 这篇文章主要介绍了详解springBoot启动时找不到或无法加载主类解决办法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-16
- 最近在工作中遇到了一个问题,通过查找相关资料才得知原因是因为返回结果的问题,下面这篇文章主要给大家介绍了关于lua读取redis数据的null判断的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下...2020-06-30
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
redis setIfAbsent和setnx的区别与使用说明
这篇文章主要介绍了redis setIfAbsent和setnx的区别与使用,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-08-04- 这篇文章主要介绍了解决Springboot get请求是参数过长的情况,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-09-17
- 这篇文章主要介绍了Redis的Expire与Setex区别说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-15
Spring Boot项目@RestController使用重定向redirect方式
这篇文章主要介绍了Spring Boot项目@RestController使用重定向redirect方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-02- 这篇文章主要介绍了Springboot+TCP监听服务器搭建过程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-10-28
- 这篇文章主要介绍了springBoot 项目排除数据库启动方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-10
- 这篇文章主要介绍了C#实现延时并自动关闭MessageBox的方法,非常实用的功能,需要的朋友可以参考下...2020-06-25
springboot中使用@Transactional注解事物不生效的坑
这篇文章主要介绍了springboot中使用@Transactional注解事物不生效的原因,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-01-26