1.下面是在Spring Boot中配置多個Redis數據庫的幾種方式：

1.1 配置如下

# application.yml
spring:redis:host: localhostport: 6379password: your_password# 連接池配置lettuce:pool:max-active: 8max-idle: 8min-idle: 0max-wait: -1mstimeout: 5000ms# 多個數據庫配置database0:database: 0  # 默認庫database1:database: 1  # 訂單庫database2:database: 2  # 用戶庫

2. Redis配置類

2.1代碼如下

@Configuration
@EnableCaching
@Slf4j
public class RedisConfig {@Bean@Primarypublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {return createRedisTemplate(connectionFactory);}@Bean(name = "redisTemplate1")public RedisTemplate<String, Object> redisTemplate1(@Qualifier("redisConnectionFactory1") RedisConnectionFactory connectionFactory) {return createRedisTemplate(connectionFactory);}@Bean(name = "redisTemplate2")public RedisTemplate<String, Object> redisTemplate2(@Qualifier("redisConnectionFactory2") RedisConnectionFactory connectionFactory) {return createRedisTemplate(connectionFactory);}@Bean@Primarypublic RedisConnectionFactory redisConnectionFactory(@Value("${spring.redis.host}") String host,@Value("${spring.redis.port}") int port,@Value("${spring.redis.password}") String password,@Value("${spring.redis.database0.database}") int database) {return createConnectionFactory(host, port, password, database);}@Bean(name = "redisConnectionFactory1")public RedisConnectionFactory redisConnectionFactory1(@Value("${spring.redis.host}") String host,@Value("${spring.redis.port}") int port,@Value("${spring.redis.password}") String password,@Value("${spring.redis.database1.database}") int database) {return createConnectionFactory(host, port, password, database);}@Bean(name = "redisConnectionFactory2")public RedisConnectionFactory redisConnectionFactory2(@Value("${spring.redis.host}") String host,@Value("${spring.redis.port}") int port,@Value("${spring.redis.password}") String password,@Value("${spring.redis.database2.database}") int database) {return createConnectionFactory(host, port, password, database);}private RedisTemplate<String, Object> createRedisTemplate(RedisConnectionFactory connectionFactory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(connectionFactory);// 配置序列化器Jackson2JsonRedisSerializer<Object> jsonSerializer = new Jackson2JsonRedisSerializer<>(Object.class);ObjectMapper mapper = new ObjectMapper();mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance,ObjectMapper.DefaultTyping.NON_FINAL);mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);mapper.registerModule(new JavaTimeModule());jsonSerializer.setObjectMapper(mapper);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(jsonSerializer);template.setHashKeySerializer(new StringRedisSerializer());template.setHashValueSerializer(jsonSerializer);template.afterPropertiesSet();return template;}private RedisConnectionFactory createConnectionFactory(String host, int port, String password, int database) {LettuceConnectionFactory factory = new LettuceConnectionFactory();factory.setHostName(host);factory.setPort(port);factory.setPassword(password);factory.setDatabase(database);// Lettuce連接池配置GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();poolConfig.setMaxTotal(8);poolConfig.setMaxIdle(8);poolConfig.setMinIdle(0);poolConfig.setMaxWaitMillis(-1);factory.afterPropertiesSet();return factory;}
}

3.Redis操作服務

3.1 代碼如下

@Service
@Slf4j
public class RedisService {@Autowired@Qualifier("redisTemplate")  // 默認庫private RedisTemplate<String, Object> redisTemplate;@Autowired@Qualifier("redisTemplate1")  // 訂單庫private RedisTemplate<String, Object> redisTemplate1;@Autowired@Qualifier("redisTemplate2")  // 用戶庫private RedisTemplate<String, Object> redisTemplate2;/*** 默認庫操作*/public void setDefault(String key, Object value) {try {redisTemplate.opsForValue().set(key, value);} catch (Exception e) {log.error("Redis默認庫操作失敗: key={}", key, e);throw new RuntimeException("Redis操作失敗", e);}}/*** 訂單庫操作*/public void setOrder(String key, Object value) {try {redisTemplate1.opsForValue().set(key, value);} catch (Exception e) {log.error("Redis訂單庫操作失敗: key={}", key, e);throw new RuntimeException("Redis操作失敗", e);}}/*** 用戶庫操作*/public void setUser(String key, Object value) {try {redisTemplate2.opsForValue().set(key, value);} catch (Exception e) {log.error("Redis用戶庫操作失敗: key={}", key, e);throw new RuntimeException("Redis操作失敗", e);}}/*** 批量操作示例*/public void batchOperation() {try {// 使用管道批量處理redisTemplate.executePipelined(new SessionCallback<Object>() {@Overridepublic Object execute(RedisOperations operations) throws DataAccessException {operations.opsForValue().set("key1", "value1");operations.opsForValue().set("key2", "value2");return null;}});redisTemplate1.executePipelined(new SessionCallback<Object>() {@Overridepublic Object execute(RedisOperations operations) throws DataAccessException {operations.opsForValue().set("order1", "value1");operations.opsForValue().set("order2", "value2");return null;}});} catch (Exception e) {log.error("Redis批量操作失敗", e);throw new RuntimeException("Redis操作失敗", e);}}
}

4. 使用示例

4.1代碼如下

@RestController
@RequestMapping("/api/redis")
@Slf4j
public class RedisController {@Autowiredprivate RedisService redisService;@PostMapping("/default")public ResponseEntity<?> setDefault(@RequestParam String key, @RequestParam String value) {try {redisService.setDefault(key, value);return ResponseEntity.ok().build();} catch (Exception e) {log.error("設置默認庫失敗", e);return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("操作失敗");}}@PostMapping("/order")public ResponseEntity<?> setOrder(@RequestParam String key, @RequestParam String value) {try {redisService.setOrder(key, value);return ResponseEntity.ok().build();} catch (Exception e) {log.error("設置訂單庫失敗", e);return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("操作失敗");}}@PostMapping("/user")public ResponseEntity<?> setUser(@RequestParam String key, @RequestParam String value) {try {redisService.setUser(key, value);return ResponseEntity.ok().build();} catch (Exception e) {log.error("設置用戶庫失敗", e);return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body("操作失敗");}}
}

5. 緩存配置（可選）

5.1 代碼如下

@Configuration
@EnableCaching
public class CacheConfig {@Beanpublic CacheManager cacheManager(RedisConnectionFactory connectionFactory) {// 創建多個緩存管理器Map<String, RedisCacheConfiguration> cacheConfigs = new HashMap<>();// 默認緩存配置cacheConfigs.put("default", RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofHours(1)));// 訂單緩存配置cacheConfigs.put("order", RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMinutes(30)));// 用戶緩存配置cacheConfigs.put("user", RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofHours(2)));return RedisCacheManager.builder(connectionFactory).cacheDefaults(RedisCacheConfiguration.defaultCacheConfig()).withInitialCacheConfigurations(cacheConfigs).build();}
}