为每个数据库创建一个RedisTemplate实例通常涉及到配置多个数据源和对应的RedisTemplate。以下是如何在Spring Boot中配置和使用多个RedisTemplate实例的步骤：
1. 配置多个Redis连接工厂
首先，你需要为每个Redis数据库配置一个RedisConnectionFactory。这可以通过在配置类中定义多个@Bean方法来实现。
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;@Configuration
public class RedisConfig {@Beanpublic RedisConnectionFactory redisConnectionFactory1() {return new LettuceConnectionFactory("redis-host1", 6379);}@Beanpublic RedisConnectionFactory redisConnectionFactory2() {return new LettuceConnectionFactory("redis-host2", 6379);}// 其他数据库的连接工厂...
}
2. 为每个连接工厂创建RedisTemplate
接下来，为每个连接工厂创建一个RedisTemplate实例，并指定序列化器等配置。
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisConfig {// RedisTemplate for database 1@Beanpublic RedisTemplate<String, Object> redisTemplate1(RedisConnectionFactory redisConnectionFactory1) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(redisConnectionFactory1);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());template.afterPropertiesSet();return template;}// RedisTemplate for database 2@Beanpublic RedisTemplate<String, Object> redisTemplate2(RedisConnectionFactory redisConnectionFactory2) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(redisConnectionFactory2);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());template.afterPropertiesSet();return template;}// 其他数据库的RedisTemplate...
}
3. 使用RedisTemplate实例
在业务代码中，你可以通过注入不同的RedisTemplate实例来操作不同的Redis数据库。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;@Service
public class RedisService {private final RedisTemplate<String, Object> redisTemplate1;private final RedisTemplate<String, Object> redisTemplate2;@Autowiredpublic RedisService(RedisTemplate<String, Object> redisTemplate1, RedisTemplate<String, Object> redisTemplate2) {this.redisTemplate1 = redisTemplate1;this.redisTemplate2 = redisTemplate2;}public void operateDatabase1(String key, Object value) {redisTemplate1.opsForValue().set(key, value);}public void operateDatabase2(String key, Object value) {redisTemplate2.opsForValue().set(key, value);}
}
在上面的代码中，RedisService类注入了两个不同的RedisTemplate实例，分别对应两个不同的Redis数据库。通过调用不同的RedisTemplate的方法，可以操作不同的数据库。
确保在实际部署时，每个LettuceConnectionFactory连接到正确的Redis服务器和数据库，并且配置了正确的认证信息（如果需要）。这样，你就可以在Spring Boot应用中灵活地操作多个Redis数据库了。
