SpringBoot使用Redis实现分布式缓存

@Component
public class ApplicationContextUtils implements ApplicationContextAware {

    private  static ApplicationContext applicationContext;
    
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
    public static Object getBean(String beanName){
        return applicationContext.getBean(beanName);
    }
}

@Slf4j
public class RedisCache  implements Cache {

    private final String id;

    public RedisCache(String id){
        this.id = id;
    }

    // 操作模块的mapper文件的命名空间 唯一标识符
    @Override
    public String getId() {
        log.info("id= {}",id);
        return this.id;
    }

    // 将数据写入redis
    @Override
    public void putObject(Object key, Object value) {

        log.info("===============将查询的数据开始写入缓存===============");
        RedisTemplate redisTemplate = getRedisTemplate();
        redisTemplate.opsForHash().put(id, key.toString(), value);

        log.info("===============将查询的数据写入缓存完毕===============");

    }

    // 获取缓存中的数据
    @Override
    public Object getObject(Object key) {
        log.info("============开始从缓存中获取数据=============");
        RedisTemplate redisTemplate = getRedisTemplate();
        log.info("============从缓存中获取数据完毕=============");
        return redisTemplate.opsForHash().get(id, key.toString());
    }

    // 移除缓存中的数据
    @Override
    public Object removeObject(Object key) {
        return null;
    }

    // 清空缓存
    @Override
    public void clear() {
        log.info("==========清空缓存=============");
        RedisTemplate redisTemplate = getRedisTemplate();
        redisTemplate.delete(id);
    }

    // 获取缓存的数量
    @Override
    public int getSize() {
        RedisTemplate redisTemplate = (RedisTemplate) 			ApplicationContextUtils.getBean("redisTemplate");
        redisTemplate.seTKEySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        int size = redisTemplate.opsForHash().size(id).intValue();
        return size;
    }


    private RedisTemplate getRedisTemplate(){
        RedisTemplate redisTemplate = (RedisTemplate) ApplicationContextUtils.getBean("redisTemplate");
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        return redisTemplate;
    }

}

@CacheNamespaceRef(DeptMapper.class)  // 引用有关联关系的命名空间
public interface EmpMapper extends BaseMapper<Emp> {

}
注：以上设置完成后，两个模块会使用相同的key(命名空间)存储数据到缓存中  

DigestUtils.md5DigestAsHex(key.toString().getBytes()) // 通过该操作可以减少key的长度

info replication

replicaof  主机ip 主机redis接口
masterauth 密码

info replication

ps aux|grep  redis

./redis-cli -a cyclone -c -h 192.168.220.11 -p 7001   连接

-a 表示连接密码  没有可省略
-c 表示集群方式进行启动
-h ip 地址
-p 表示端口号

redis:
    cluster: 
       nodes: 192.168.1.1:6379 ,.....