初始化

xiangpei

2025-04-18 ccadf9480d4e6a9dcc227a2a0b1f9ae0612e36fd

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
package com.monkeylessey.redis;
 
import com.monkeylessey.utils.ApplicationContextUtil;
import org.apache.ibatis.cache.Cache;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
 
/**
 * mybatis二级缓存使用redis
 * @author 29443
 * @version 1.0
 * @date 2022/4/11
 */
public class MybatisRedisCache implements Cache {
 
    // 必须要定义一个id,以及id的构造函数（这个id是Mapper的namespace）
    private final String id;
 
    private RedisTemplate redisTemplate;
 
    public MybatisRedisCache(String id) {
        this.id = id;
        System.out.println("id的值为：" + id);
        // 因为Cache的实现类是mybatis实例化的，并不是由Spring容器管理。所以我们并不能直接注入RedisTemplate。
        //redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");
    }
 
    // getId()必须返回该id
    @Override
    public String getId() {
        return id;
    }
 
    // 添加缓存
    @Override
    public void putObject(Object key, Object value) {
        if (redisTemplate == null) {
            redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");
        }
        redisTemplate.opsForHash().put(id, key.toString(), value);
    }
 
    // 获取缓存
    @Override
    public Object getObject(Object key) {
        if (redisTemplate == null) {
            redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");
        }
        return this.redisTemplate.opsForHash().get(id,key.toString());
    }
 
    // 从3.3.0开始，此方法仅在回滚期间调用
    @Override
    public Object removeObject(Object key) {
        return null;
    }
 
    // 删除缓存
    @Override
    public void clear() {
        if (redisTemplate == null) {
            redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");
        }
        redisTemplate.delete(id);
    }
 
    @Override
    public int getSize() {
        if (redisTemplate == null) {
            redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");
        }
        return Math.toIntExact(redisTemplate.opsForHash().size(id));
    }
}