商城首页欢迎来到中国正版软件门户

您的位置: 首页 > 文章列表 > 编程开发 > 基于Redis的MybatisPlus二级缓存解决方案

基于Redis的MybatisPlus二级缓存解决方案

  发布于2026-07-10 阅读(0)

扫一扫,手机访问

在 MyBatis-Plus 中接入 Redis 作为二级缓存,关键其实就两个点:一是把 RedisTemplate 的序列化方式配对,二是搞定 MyBatis 的 Cache 接口实现。这里有个小坑要注意——MyBatis 的 Cache 实现类不受 Spring 容器直接管理,所以得想个办法让它可以拿到 RedisTemplate

基于Redis的MybatisPlus二级缓存解决方案

下面直接上配置和代码,一步步说清楚。

1. 引入依赖

先把 MyBatis-Plus 和 Spring Data Redis 的依赖加进来:


    com.baomidou
    mybatis-plus-boot-starter
    3.5.3.1 


    org.springframework.boot
    spring-boot-starter-data-redis



    cn.hutool
    hutool-all
    5.8.22

2. 配置 RedisTemplate (关键步骤)

MyBatis 缓存的对象必须可序列化,这里推荐用 JSON 序列化,比如 Jackson。相比 JDK 默认序列化,JSON 更节省空间,可读性也更好。

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactory);
        // 使用 String 序列化 Key
        StringRedisSerializer stringSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringSerializer);
        template.setHashKeySerializer(stringSerializer);
        // 使用 Jackson 序列化 Value
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 解决 java.util.Date 等类型序列化问题,并启用默认类型信息以支持多态
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
}

3. 实现 MyBatis Cache 接口

接下来写一个自定义类,实现 org.apache.ibatis.cache.Cache 接口。注意,这个类是由 MyBatis 创建的,不是 Spring,所以不能直接用 @Autowired,得通过 ApplicationContext 拿到 RedisTemplate

方案 A:使用 Hutool 的 SpringUtil(推荐,代码更简洁)

import cn.hutool.extra.spring.SpringUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.cache.Cache;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
@Slf4j
public class MybatisRedisCache implements Cache {
    private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    private final String id;
    private RedisTemplate redisTemplate;
    // 缓存过期时间(分钟),可根据业务调整
    private static final long EXPIRE_TIME_IN_MINUTES = 30;
    public MybatisRedisCache(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) {
        getRedisTemplate().opsForHash().put(getId(), key.toString(), value);
        log.debug("Put query result to redis: key={}", key);
    }
    @Override
    public Object getObject(Object key) {
        log.debug("Get cached query result from redis: key={}", key);
        return getRedisTemplate().opsForHash().get(getId(), key.toString());
    }
    @Override
    public Object removeObject(Object key) {
        log.debug("Remove cached query result from redis: key={}", key);
        return getRedisTemplate().opsForHash().delete(getId(), key.toString());
    }
    @Override
    public void clear() {
        log.debug("Clear all cached query results from redis for namespace: {}", getId());
        getRedisTemplate().delete(getId());
    }
    @Override
    public int getSize() {
        Long size = getRedisTemplate().opsForHash().size(getId());
        return size == null ? 0 : size.intValue();
    }
    @Override
    public ReadWriteLock getReadWriteLock() {
        return readWriteLock;
    }
    private RedisTemplate getRedisTemplate() {
        if (redisTemplate == null) {
            // 从 Spring 容器中获取 RedisTemplate
            redisTemplate = SpringUtil.getBean("redisTemplate");
        }
        return redisTemplate;
    }
}

方案 B:使用静态 ApplicationContext 持有者(如果不使用 Hutool)

如果不依赖 Hutool,那就写一个 SpringContextHolder 类,实现 ApplicationContextAware 接口来静态持有 Bean。然后在 MybatisRedisCache 中调用 SpringContextHolder.getBean("redisTemplate") 即可。

4. 开启二级缓存

全局配置 (application.yml)

mybatis-plus:
  configuration:
    cache-enabled: true # 全局开启二级缓存
    # 其他配置...

Mapper 级别配置

在具体的 Mapper 接口或 XML 中指定使用刚才写的 Redis 缓存。

方式一:注解方式(推荐)

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.CacheNamespace;
@CacheNamespace(implementation = MybatisRedisCache.class)
public interface UserMapper extends BaseMapper {
    // 查询方法
}

方式二:XML 方式

在对应的 UserMapper.xml 里加这么一段:


    
    
    
    

5. 注意事项

  1. 实体类序列化:所有要存入缓存的实体类(比如 User)必须实现 Serializable 接口,不然 JSON 序列化可能会翻车。
  2. 缓存一致性:MyBatis 二级缓存默认在 insert/update/delete 操作后会清空该 Namespace 下的所有缓存。在分布式高并发场景下,这种行为可能不够精细。如果业务对缓存一致性要求高,可以考虑在服务层用 Spring Cache(比如 @Cacheable)来替代 MyBatis 二级缓存,拿到的控制粒度会更细。
  3. Key 的设计:上面的示例用了 opsForHash,把同一个 Mapper Namespace 下的缓存项都放在一个 Hash 里,Key 是查询条件的哈希或字符串。这样做方便管理和清理特定 Mapper 的缓存。
  4. 一级缓存干扰:在 Spring 集成环境下,MyBatis 的一级缓存(SqlSession 级别)因为 SqlSession 生命周期受限,效果有限。真正跨 SqlSession 共享缓存得靠二级缓存。所以,确保 cache-enabled: true 已经配好,这是关键。
本文转载于:https://www.jb51.net/program/367179qrx.htm 如有侵犯,请联系zhengruancom@outlook.com删除。
免责声明:正软商城发布此文仅为传递信息,不代表正软商城认同其观点或证实其描述。
  • using namespace 使用中遇到的问题怎么解决 正版软件
    using namespace 使用中遇到的问题怎么解决
    命名空间的基本概念与常见引入问题在C++等编程语言中,命名空间(namespace)是一种将代码标识符(如变量、函数、类名)封装在特定名称下的机制,其主要目的是避免命名冲突,尤其是在大型项目或使用多个第三方库时。使用“using namespace”指令可以将指定命名空间中的所有名称引入当前作用域,
    10天前 0
  • c语言函数递归 实操经验总结:这些技巧很实用 正版软件
    c语言函数递归 实操经验总结:这些技巧很实用
    理解递归的基本原理在C语言中,递归是一种函数调用自身的编程技术。要掌握它,首先需要理解其核心思想:将一个复杂的大问题,分解为一个或几个与原问题相似但规模更小的子问题,直到子问题足够简单,可以直接求解。这个过程通常包含两个关键部分:递归出口和递归体。递归出口定义了问题何时不再继续分解,即最简单、可直接
    10天前 0
  • c语言函数递归 怎么选?常见方案对比分析 正版软件
    c语言函数递归 怎么选?常见方案对比分析
    递归函数的基本概念与适用场景在C语言编程中,递归是一种函数调用自身的编程技巧。它并非适用于所有问题,但在处理某些具有自相似结构的问题时,能提供极其清晰和优雅的解决方案。递归的核心思想是将一个大规模问题分解为一个或多个同类型但规模更小的子问题,直到子问题简单到可以直接求解。典型的适用场景包括树形结构的
    10天前 0
  • Objective-C 内存管理入门:从 alloc 到 dealloc 的生命周期详解 正版软件
    Objective-C 内存管理入门:从 alloc 到 dealloc 的生命周期详解
    理解内存管理的基石在Objective-C的编程世界中,内存管理是开发者必须掌握的核心技能之一。它直接关系到应用的性能、稳定性与资源利用效率。与一些采用自动垃圾回收机制的语言不同,Objective-C在很长一段时间里,依赖一套基于引用计数的、需要开发者部分介入的管理规则。这套规则的核心思想是明确的
    10天前 0
  • 如何正确使用 dealloc 以避免 iOS 应用中的内存泄漏 正版软件
    如何正确使用 dealloc 以避免 iOS 应用中的内存泄漏
    理解 dealloc 的角色与时机在 iOS 应用开发中,内存管理是保障应用性能与稳定性的基石。dealloc 方法是 Objective-C 中对象生命周期结束时的关键回调,它标志着对象即将被系统回收内存。正确理解其触发时机至关重要:当一个对象的引用计数降为零时,运行时系统会自动调用该对象的 de
    10天前 0