配置類①：

import com.zxl.common.utils.json.FastJsonRedisSerializer; import org.springframework.beans.factory.annotation.Value; 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.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.StringRedisSerializer; import redis.clients.jedis.JedisPoolConfig;import java.time.Duration;@Configuration public class DictRedisConfigLocal {@Value("${spring.dictRedis.host}")private String host;@Value("${spring.dictRedis.port}")private int port;@Value("${spring.dictRedis.password}")private String password;@Value("${spring.dictRedis.maxTotal}")private Integer maxTotal;@Value("${spring.dictRedis.maxIdle}")private Integer maxIdle;@Value("${spring.dictRedis.maxWaitMillis}")private Integer maxWaitMillis;@Value("${spring.dictRedis.timeout}")private int timeout;@Value("${spring.dictRedis.database}")private int database;@Bean(name = "dictRedis")public RedisConnectionFactory cacheRedisConnectionFactory() {JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(maxTotal);poolConfig.setMaxIdle(maxIdle);poolConfig.setMaxWaitMillis(maxWaitMillis);poolConfig.setTestOnBorrow(true);poolConfig.setTestOnReturn(false);poolConfig.setTestWhileIdle(true);JedisClientConfiguration clientConfig = JedisClientConfiguration.builder().usePooling().poolConfig(poolConfig).and().readTimeout(Duration.ofMillis(timeout)).build();// 單點redisRedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration();// 哨兵redis// RedisSentinelConfiguration redisConfig = new RedisSentinelConfiguration();// 集群redis// RedisClusterConfiguration redisConfig = new RedisClusterConfiguration();redisConfig.setHostName(host);redisConfig.setPassword(RedisPassword.of(password));redisConfig.setPort(port);redisConfig.setDatabase(database);return new JedisConnectionFactory(redisConfig, clientConfig);}/*** 配置redisTemplate 注入方式使用@Resource(name="") 方式注入** @return*/@Bean(name = "dictRedisLocalTemplate")public RedisTemplate<String, Object> cacheRedisTemplate() {RedisTemplate<String, Object> template = new RedisTemplate<>();/* //使用fastjson序列化FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(Object.class);// value值的序列化采用fastJsonRedisSerializertemplate.setValueSerializer(fastJsonRedisSerializer);template.setHashValueSerializer(fastJsonRedisSerializer);// key的序列化采用StringRedisSerializertemplate.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());*/ //template.setConnectionFactory(cacheRedisConnectionFactory());return template;} // // /** // * 對hash類型的數據操作 // * // * @param redisTemplate // * @return // */ // @Bean(name = "dictRedisHashOperations") // public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) { // return redisTemplate.opsForHash(); // } // // /** // * 對redis字符串類型數據操作 // * // * @param redisTemplate // * @return // */ // @Bean(name = "dictRedisValueOperations") // public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) { // return redisTemplate.opsForValue(); // } // // /** // * 對鏈表類型的數據操作 // * // * @param redisTemplate // * @return // */ // @Bean(name = "dictRedisListOperations") // public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) { // return redisTemplate.opsForList(); // } // // /** // * 對無序集合類型的數據操作 // * // * @param redisTemplate // * @return // */ // @Bean(name = "dictRedisSetOperations") // public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) { // return redisTemplate.opsForSet(); // } // // /** // * 對有序集合類型的數據操作 // * // * @param redisTemplate // * @return // */ // @Bean(name = "dictRedisZSetOperations") // public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) { // return redisTemplate.opsForZSet(); // } }

配置類②：

import com.zxl.common.utils.json.FastJsonRedisSerializer; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.data.redis.RedisProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.data.redis.cache.RedisCacheConfiguration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.cache.RedisCacheWriter; 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.*; import org.springframework.data.redis.serializer.RedisSerializationContext; import org.springframework.data.redis.serializer.StringRedisSerializer; import redis.clients.jedis.JedisPoolConfig;import java.time.Duration;@Configuration @EnableCaching @ConditionalOnClass(RedisOperations.class) @EnableConfigurationProperties(RedisProperties.class) public class RedisConfig {@Value("${spring.setRedis.host}")private String host;@Value("${spring.setRedis.port}")private int port;@Value("${spring.setRedis.password}")private String password;@Value("${spring.setRedis.maxTotal}")private Integer maxTotal;@Value("${spring.setRedis.maxIdle}")private Integer maxIdle;@Value("${spring.setRedis.maxWaitMillis}")private Integer maxWaitMillis;@Value("${spring.setRedis.timeout}")private int timeout;@Value("${spring.setRedis.database}")private int database;@Primary@Beanpublic RedisConnectionFactory cacheBusinessRedisConnectionFactory() {JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(maxTotal);poolConfig.setMaxIdle(maxIdle);poolConfig.setMaxWaitMillis(maxWaitMillis);poolConfig.setTestOnBorrow(true);poolConfig.setTestOnReturn(false);poolConfig.setTestWhileIdle(true);JedisClientConfiguration clientConfig = JedisClientConfiguration.builder().usePooling().poolConfig(poolConfig).and().readTimeout(Duration.ofMillis(timeout)).build();// 單點redisRedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration();// 哨兵redis// RedisSentinelConfiguration redisConfig = new RedisSentinelConfiguration();// 集群redis// RedisClusterConfiguration redisConfig = new RedisClusterConfiguration();redisConfig.setHostName(host);redisConfig.setPassword(RedisPassword.of(password));redisConfig.setPort(port);redisConfig.setDatabase(database);return new JedisConnectionFactory(redisConfig, clientConfig);}/*** 管理緩存 springboot2** @param redisTemplate* @return*/@Beanpublic RedisCacheManager redisCacheManager(RedisTemplate redisTemplate) {//初始化一個RedisCacheWriterRedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisTemplate.getConnectionFactory());RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig().serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisTemplate.getValueSerializer()));//設置序列化//設置默認超過期時間是30秒redisCacheConfiguration.entryTtl(Duration.ofSeconds(30));//初始化RedisCacheManagerRedisCacheManager cacheManager = new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);return cacheManager;}@Beanpublic RedisTemplate<String, Object> redisTemplate() {RedisTemplate<String, Object> template = new RedisTemplate<>();// Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class); // template.setValueSerializer(jackson2JsonRedisSerializer); // template.setHashValueSerializer(jackson2JsonRedisSerializer);//使用fastjson序列化FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(Object.class);// value值的序列化采用fastJsonRedisSerializertemplate.setValueSerializer(fastJsonRedisSerializer);template.setHashValueSerializer(fastJsonRedisSerializer);// key的序列化采用StringRedisSerializertemplate.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer()); //template.setConnectionFactory(cacheBusinessRedisConnectionFactory());return template;}/*** 對hash類型的數據操作** @param redisTemplate* @return*/@Beanpublic HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForHash();}/*** 對redis字符串類型數據操作** @param redisTemplate* @return*/@Beanpublic ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForValue();}/*** 對鏈表類型的數據操作** @param redisTemplate* @return*/@Beanpublic ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForList();}/*** 對無序集合類型的數據操作** @param redisTemplate* @return*/@Beanpublic SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForSet();}/*** 對有序集合類型的數據操作** @param redisTemplate* @return*/@Beanpublic ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForZSet();} }

配置文件：

spring:setRedis:host: 192.168.109.100port: 6379password: 12345678maxIdle: 300maxTotal: 600maxWaitMillis: 1000timeout: 3000database: 5dictRedis:host: 192.168.109.100port: 6379password: 12345678maxIdle: 300maxTotal: 600maxWaitMillis: 1000timeout: 3000database: 0

?

總結

以上是生活随笔為你收集整理的Spring Boot连接多个Redis库配置方案及代码示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。