From 5b3c390e087029b965766628a85ed0196df72a9d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90li?= <15040126243@163.com> Date: Wed, 3 Nov 2021 15:04:10 +0800 Subject: [PATCH] =?UTF-8?q?remove=20=E7=A7=BB=E9=99=A4=20MybatisPlusRedisC?= =?UTF-8?q?ache=20=E4=BA=8C=E7=BA=A7=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cache/MybatisPlusRedisCache.java | 91 ------------------- .../com/ruoyi/demo/mapper/TestDemoMapper.java | 4 - 2 files changed, 95 deletions(-) delete mode 100644 ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/cache/MybatisPlusRedisCache.java diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/cache/MybatisPlusRedisCache.java b/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/cache/MybatisPlusRedisCache.java deleted file mode 100644 index c790c663b..000000000 --- a/ruoyi-common/src/main/java/com/ruoyi/common/core/mybatisplus/cache/MybatisPlusRedisCache.java +++ /dev/null @@ -1,91 +0,0 @@ -package com.ruoyi.common.core.mybatisplus.cache; - -import cn.hutool.extra.spring.SpringUtil; -import com.ruoyi.common.utils.RedisUtils; -import lombok.extern.slf4j.Slf4j; -import org.apache.ibatis.cache.Cache; -import org.springframework.data.redis.connection.RedisServerCommands; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.util.CollectionUtils; - -import java.util.Collection; -import java.util.concurrent.locks.ReadWriteLock; -import java.util.concurrent.locks.ReentrantReadWriteLock; - -/** - * mybatis-redis 二级缓存 - * - * 使用方法 配置文件开启 mybatis-plus 二级缓存 - * 在 XxxMapper.java 类上添加注解 @CacheNamespace(implementation = MybatisPlusRedisCache.class, eviction = MybatisPlusRedisCache.class) - * - * @deprecated 3.4.0删除 推荐使用spirng-cache - * @author Lion Li - */ -@Slf4j -public class MybatisPlusRedisCache implements Cache { - - private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock(true); - - private String id; - - public MybatisPlusRedisCache(final String id) { - if (id == null) { - throw new IllegalArgumentException("Cache instances require an ID"); - } - this.id = id; - } - - @Override - public String getId() { - return this.id; - } - - @Override - public void putObject(Object key, Object value) { - if (value != null) { - RedisUtils.setCacheObject(key.toString(), value); - } - } - - @Override - public Object getObject(Object key) { - try { - if (key != null) { - return RedisUtils.getCacheObject(key.toString()); - } - } catch (Exception e) { - e.printStackTrace(); - log.error("缓存出错"); - } - return null; - } - - @Override - public Object removeObject(Object key) { - if (key != null) { - RedisUtils.deleteObject(key.toString()); - } - return null; - } - - @Override - public void clear() { - log.debug("清空缓存"); - Collection keys = RedisUtils.keys("*:" + this.id + "*"); - if (!CollectionUtils.isEmpty(keys)) { - RedisUtils.deleteObject(keys); - } - } - - @Override - public int getSize() { - RedisTemplate redisTemplate = SpringUtil.getBean("redisTemplate"); - Long size = redisTemplate.execute(RedisServerCommands::dbSize); - return size.intValue(); - } - - @Override - public ReadWriteLock getReadWriteLock() { - return this.readWriteLock; - } -} diff --git a/ruoyi-demo/src/main/java/com/ruoyi/demo/mapper/TestDemoMapper.java b/ruoyi-demo/src/main/java/com/ruoyi/demo/mapper/TestDemoMapper.java index efbbffc44..dccea6154 100644 --- a/ruoyi-demo/src/main/java/com/ruoyi/demo/mapper/TestDemoMapper.java +++ b/ruoyi-demo/src/main/java/com/ruoyi/demo/mapper/TestDemoMapper.java @@ -2,11 +2,9 @@ package com.ruoyi.demo.mapper; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.ruoyi.common.core.mybatisplus.cache.MybatisPlusRedisCache; import com.ruoyi.common.core.mybatisplus.core.BaseMapperPlus; import com.ruoyi.demo.domain.TestDemo; import com.ruoyi.demo.domain.vo.TestDemoVo; -import org.apache.ibatis.annotations.CacheNamespace; import org.apache.ibatis.annotations.Param; /** @@ -15,8 +13,6 @@ import org.apache.ibatis.annotations.Param; * @author Lion Li * @date 2021-07-26 */ -// 如使需切换数据源 请勿使用缓存 会造成数据不一致现象 -@CacheNamespace(implementation = MybatisPlusRedisCache.class, eviction = MybatisPlusRedisCache.class) public interface TestDemoMapper extends BaseMapperPlus { Page customPageList(@Param("page") Page page, @Param("ew") Wrapper wrapper);