package com.hx.redisson.manager; import org.redisson.api.RedissonClient; import org.springframework.data.redis.core.RedisTemplate; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * redis管理 * * @author CJH * @date 2022-06-27 */ public class RedisManager { private Map redisTemplateMap = new ConcurrentHashMap<>(); public static Map redissonTemplateMap = new ConcurrentHashMap<>(); /** * 构造方法初始化 redisTemplateMap 的数据 * * @param redisTemplateMap */ public RedisManager(Map redisTemplateMap) { this.redisTemplateMap = redisTemplateMap; } /** * 根据数据库序号,返回对应的RedisTemplate * * @param dbIndex 序号 * @return {@link RedisTemplate} */ public RedisTemplate getRedisTemplate(Integer dbIndex) { RedisTemplate redisTemplate = redisTemplateMap.get("redisTemplate" + dbIndex); if (redisTemplate == null) { throw new RuntimeException("Map不存在该redisTemplate"); } return redisTemplate; } }