@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文件的命名空間 唯一標(biāo)識(shí)符
    @Override
    public String getId() {
        log.info("id= {}",id);
        return this.id;
    }

    // 將數(shù)據(jù)寫(xiě)入redis
    @Override
    public void putObject(Object key, Object value) {

        log.info("===============將查詢的數(shù)據(jù)開(kāi)始寫(xiě)入緩存===============");
        RedisTemplate redisTemplate = getRedisTemplate();
        redisTemplate.opsForHash().put(id, key.toString(), value);

        log.info("===============將查詢的數(shù)據(jù)寫(xiě)入緩存完畢===============");

    }

    // 獲取緩存中的數(shù)據(jù)
    @Override
    public Object getObject(Object key) {
        log.info("============開(kāi)始從緩存中獲取數(shù)據(jù)=============");
        RedisTemplate redisTemplate = getRedisTemplate();
        log.info("============從緩存中獲取數(shù)據(jù)完畢=============");
        return redisTemplate.opsForHash().get(id, key.toString());
    }

    // 移除緩存中的數(shù)據(jù)
    @Override
    public Object removeObject(Object key) {
        return null;
    }

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

    // 獲取緩存的數(shù)量
    @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)  // 引用有關(guān)聯(lián)關(guān)系的命名空間
public interface EmpMapper extends BaseMapper<Emp> {

}
注：以上設(shè)置完成后，兩個(gè)模塊會(huì)使用相同的key(命名空間)存儲(chǔ)數(shù)據(jù)到緩存中  

DigestUtils.md5DigestAsHex(key.toString().getBytes()) // 通過(guò)該操作可以減少key的長(zhǎng)度

info replication

replicaof  主機(jī)ip 主機(jī)redis接口
masterauth 密碼

info replication

ps aux|grep  redis

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

-a 表示連接密碼  沒(méi)有可省略
-c 表示集群方式進(jìn)行啟動(dòng)
-h ip 地址
-p 表示端口號(hào)

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