import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
/**
* @author ck
* @create 2019-05-25 19:54
*/
public class MyRedis {
/**
* 切换redis数据库
* @param redisTemplate springboot封装的redis对象
* @param index 数据库下标
*/
public static void select(RedisTemplate redisTemplate, int index){
LettuceConnectionFactory lettuceConnectionFactory = (LettuceConnectionFactory) redisTemplate.getConnectionFactory();
if(lettuceConnectionFactory != null){
lettuceConnectionFactory.setDatabase(index);
redisTemplate.setConnectionFactory(lettuceConnectionFactory);
lettuceConnectionFactory.resetConnection();
}
}
}
测试
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
public void test06(){
//切换到1库
MyRedis.select(stringRedisTemplate,1);
stringRedisTemplate.opsForValue().set("k1","v1");
//切换到0库
MyRedis.select(stringRedisTemplate,0);
stringRedisTemplate.opsForValue().set("k0","v0");
}
结果
