redis切换db方法

article/2025/11/11 7:28:48

//最近发现redis 数据都是默认存在db0的看着就崩溃了。这么做无非就是想让不同类型的数据属于不同的应用程序而彼此分开后面自己总结了三种方法给大家分享下有什么不足的地方大家也可以指出来哦

提供了三种方式切换db的方法

1- 第一种方式最简单先看看redis 的yml 文件的配置这个是单机的配配置

spring:thymeleaf:cache: falseredis:#REDIS 数据库索引（默认为0）database: 0#redis服务地址host: 127.0.0.1#redis服务连接端口port: 6379#redis密码（没有密码默认为空）password:#连接池最大连接数（使用负值表示没有限制）jedis:pool:max-active: 8lettuce:pool:#连接池最大堵塞等待时间（使用负值表示没有限制）max-wait: -1#连接池最大空闲连接max-idle: 8#连接池中的最小空闲连接min-idle: 0#连接超时时间（毫秒）timeout: 5000

第二步我们用最简单的方法实现切库

    /*** 添加字符串** @param key*/@RequestMapping("/ha")@ResponseBodypublic void demo02(String key) {//Redis服务Jedis jedis = new  Jedis();//切库表示你要存的db几jedis.select(10);//写进数据jedis.set("K1", key);System.out.println(key);}

2- 现在介绍第二种方式切换的方式

2-1 :先配置yml文件的信息@value 调用的方法

redis:#REDIS 数据库索引（默认为0）database: 0#redis服务地址host: 127.0.0.1#redis服务连接端口port: 6379#redis密码（没有密码默认为空）password:#连接池最大连接数（使用负值表示没有限制）#连接池最大堵塞等待时间（使用负值表示没有限制）maxWait: -1#连接池最大空闲连接maxIdle: 8#连接池中的最小空闲连接minIdle: 0#连接超时时间（毫秒）timeout: 5000#redis切库默认0默认第一个值 表示现在只能切换db0和db1如果想切换更多的可以在逗号后面多添加几个值dbs: 0,1

2-2:我们看下配置容器下的配置

package com.lwq.demo.config;import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.stereotype.Component;
import redis.clients.jedis.JedisPoolConfig;import javax.annotation.PostConstruct;
import java.io.Serializable;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
@Slf4j
public class redisDbConfig {@Value("${redis.host}")private String hostName;@Value("${redis.port}")private int port;@Value("${redis.password}")private String passWord;@Value("${redis.maxIdle}")private int maxIdl;@Value("${redis.minIdle}")private int minIdl;@Value("${redis.timeout}")private int timeout;private int defaultDb;@Value("${redis.dbs}")private List<Integer> dbs;public static Map<Integer, RedisTemplate<Serializable, Object>> redisTemplateMap = new HashMap<>();/*** 只加载一次的服务器* @throws Exception*/@PostConstructpublic void initRedisTemp() throws Exception {log.info("###### START 初始化 Redis 连接池 START ######");defaultDb = dbs.get(0);for (Integer db : dbs) {log.info("###### 正在加载Redis-db-" + db+ " ######");redisTemplateMap.put(db, redisTemplateObject(db));}log.info("###### END 初始化 Redis 连接池 END ######");}private RedisTemplate<Serializable, Object> redisTemplateObject(Integer db) {RedisTemplate<Serializable, Object> redisTemplateObject = new RedisTemplate<Serializable, Object>();redisTemplateObject.setConnectionFactory(redisConnectionFactory(jedisPoolConfig(),db));setSerializer(redisTemplateObject);redisTemplateObject.afterPropertiesSet();return redisTemplateObject;}private void setSerializer(RedisTemplate<Serializable, Object> template) {template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());}public RedisTemplate<Serializable, Object> getRedisTemplate(int db){return redisTemplateMap.get(db);}public RedisTemplate<Serializable, Object> getRedisTemplate(){return redisTemplateMap.get(defaultDb);}/*** 连接池配置* @return*/private JedisPoolConfig jedisPoolConfig() {JedisPoolConfig poolConfig = new JedisPoolConfig();// 最大连接数poolConfig.setMaxIdle(maxIdl);// 最小空闲连接数poolConfig.setMinIdle(minIdl);poolConfig.setTestOnBorrow(true);poolConfig.setTestOnReturn(true);poolConfig.setTestWhileIdle(true);poolConfig.setNumTestsPerEvictionRun(10);poolConfig.setTimeBetweenEvictionRunsMillis(60000);// 当池内没有可用的连接时，最大等待时间poolConfig.setMaxWaitMillis(10000);// ------其他属性根据需要自行添加-------------return poolConfig;}/*** jedis连接工厂** @param jedisPoolConfig* @return*/public RedisConnectionFactory redisConnectionFactory(JedisPoolConfig jedisPoolConfig, int db) {// 单机版jedisRedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();// 设置redis服务器的host或者ip地址redisStandaloneConfiguration.setHostName(hostName);// 设置默认使用的数据库redisStandaloneConfiguration.setDatabase(db);// 设置密码redisStandaloneConfiguration.setPassword(RedisPassword.of(passWord));// 设置redis的服务的端口号redisStandaloneConfiguration.setPort(port);// 获得默认的连接池构造器(怎么设计的，为什么不抽象出单独类，供用户使用呢)JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcb = (JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();// 指定jedisPoolConifig来修改默认的连接池构造器（真麻烦，滥用设计模式！）jpcb.poolConfig(jedisPoolConfig);// 通过构造器来构造jedis客户端配置JedisClientConfiguration jedisClientConfiguration = jpcb.build();// 单机配置 + 客户端配置 = jedis连接工厂return new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration);}}

2-3：测试的方法：

    //redis 数据结构配置@Autowiredprivate redisDbConfig redisDb;/*** 添加字符串** @param key*/@GetMapping("/hi")@ResponseBodypublic void demo03(String key) {//配置结构 表示你想配置切换的db几 getRedisTemplate(1) 如果不写默认为db0redisDb.getRedisTemplate(1).opsForValue().set("k2",key);System.out.println(key);}

//此信息部分参考这位大佬 https://ld246.com/article/1594863004207

//3-现在我们介绍第三种方式也是最简单最直接的方法

// 还有直接用yml 文件切换 database 1 就这样直接切换db1了

spring:thymeleaf:cache: falseredis:#REDIS 数据库索引（默认为0） 分片想存在那里就存在那里 0-15database: 1#redis服务地址host: 127.0.0.1#redis服务连接端口port: 6379#redis密码（没有密码默认为空）password:#连接池最大连接数（使用负值表示没有限制）jedis:pool:max-active: 8lettuce:pool:#连接池最大堵塞等待时间（使用负值表示没有限制）max-wait: -1#连接池最大空闲连接max-idle: 8#连接池中的最小空闲连接min-idle: 0#连接超时时间（毫秒）timeout: 5000

//我们来演示一下

    @Autowiredprivate StringRedisTemplate stringRedisTemplate;/*** 添加字符串** @param key*/@RequestMapping("/haha")@ResponseBodypublic void demo01(String key) {stringRedisTemplate.opsForValue().set("K3", key);System.out.println(key);}