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自動緩存更新刪除內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- Redis實現好友關註的示例代碼
- 微服務 Spring Boot 整合 Redis BitMap 實現 簽到與統計功能
- springboot如何使用redis的incr創建分佈式自增id
- Redis實現訂單過期刪除的方法步驟
- springboot vue接口測試前後端樹節點編輯刪除功能