Redis实现SpringBoot集成Redis多数据源

　　背景
　　有些时候在一个项目里，由于业务问题，可能仅仅操作一个Redis数据源已经不能满足，比如某个运营系统，对接着多个不同的服务，处理数据时又不想通过远程调用，那只能增加一个数据源来解决问题，像MySQL的多数据源一样。配置示例
　　这里连接池选用的是lettuce。redis：host：localhostport：6379password：123456timeout：60000database：10lettuce：pool：minidle：0maxidle：10maxwait：1maxactive：200timebetweenevictionruns：1redislive：host：localhostport：6379password：123456database：0实现代码
　　关于序列化使用的是jackson。
　　以下提供了创建RedisTemplate以及StringRedisTemplate。
　　关于二者的区别：两者的关系是StringRedisTemplate继承RedisTemplate。两者的数据是不共通的；也就是说StringRedisTemplate只能管理StringRedisTemplate里面的数据，RedisTemplate只能管理RedisTemplate中的数据。SDR默认采用的序列化策略有两种，一种是String的序列化策略，一种是JDK的序列化策略。StringRedisTemplate默认采用的是String的序列化策略，保存的key和value都是采用此策略序列化保存的。RedisTemplate默认采用的是JDK的序列化策略，保存的key和value都是采用此策略序列化保存的。pRedisLettuce连接实例配置authorzhengshangjinversion1。0。0since1。0。0createdon20200423ConfigurationEnableCachingpublicclassRedisLettuceConfig｛live数据源Value（｛spring。redislive。host｝）privateStringredisLiveHost；Value（｛spring。redislive。port｝）privateintredisLivePort；Value（｛spring。redislive。password｝）privateStringredisLivePass；Value（｛spring。redislive。database｝）privateintredisLiveDb；公共配置Value（｛spring。redis。timeout｝）privatelongtimeout；Value（｛spring。redis。lettuce。pool。minidle｝）privateintminIdle；Value（｛spring。redis。lettuce。pool。maxidle｝）privateintmaxIdle；Value（｛spring。redis。lettuce。pool。maxactive｝）privateintmaxActive；Value（｛spring。redis。lettuce。pool。maxwait｝）privateintmaxWait；装配RedisTemplatep这里根据默认连接配置装配实例paramredisConnectionFactory默认returnredisTemplateauthorzhengshangjincreatedon20200423Bean（nameredisTemplate）publicRedisTemplateObject，ObjectredisTemplate（RedisConnectionFactoryredisConnectionFactory）｛returncreateRedisTemplate（redisConnectionFactory）；｝装配StringRedisTemplatep这里根据默认连接配置装配实例paramredisConnectionFactory默认returnStringRedisTemplateauthorzhengshangjincreatedon20200423Bean（namestringRedisTemplate）publicStringRedisTemplatestringRedisTemplate（RedisConnectionFactoryredisConnectionFactory）｛returncreateStringRedisTemplate（redisConnectionFactory）；｝装配Live数据源returnliveStringRedisTemplateauthorzhengshangjincreatedon20200423Bean（nameliveStringRedisTemplate）publicStringRedisTemplateliveStringRedisTemplate（）｛returncreateStringRedisTemplate（redisLiveHost，redisLivePort，redisLivePass，redisLiveDb）；｝创建RedisTemplateparamredisConnectionFactoryredisConnectionFactoryreturnRedisTemplateauthorzhengshangjincreatedon20200423publicRedisTemplateObject，ObjectcreateRedisTemplate（RedisConnectionFactoryredisConnectionFactory）｛ObjectMapperobjectMappernewObjectMapper（）；objectMapper。setVisibility（PropertyAccessor。ALL，JsonAutoDetect。Visibility。ANY）；objectMapper。activateDefaultTyping（LaissezFaireSubTypeValidator。instance，ObjectMapper。DefaultTyping。NONFINAL，JsonTypeInfo。As。PROPERTY）；Jackson2JsonRedisSerializerlt；？serializernewJackson2JsonRedisSerializer（Object。class）；serializer。setObjectMapper（objectMapper）；RedisTemplateObject，ObjectredisTemplatenewRedisTemplate（）；redisTemplate。setConnectionFactory（redisConnectionFactory）；redisTemplate。setKeySerializer（newStringRedisSerializer（））；redisTemplate。setValueSerializer（serializer）；redisTemplate。setHashKeySerializer（newStringRedisSerializer（））；redisTemplate。setHashValueSerializer（serializer）；redisTemplate。afterPropertiesSet（）；returnredisTemplate；｝创建StringRedisTemplateparamredisConnectionFactoryredisConnectionFactoryreturnStringRedisTemplateauthorzhengshangjincreatedon20200423publicStringRedisTemplatecreateStringRedisTemplate（RedisConnectionFactoryredisConnectionFactory）｛StringRedisTemplatestringRedisTemplatenewStringRedisTemplate（）；stringRedisTemplate。setConnectionFactory（redisConnectionFactory）；returnstringRedisTemplate；｝创建StringRedisTemplateparamhost主机paramport端口parampassword密码paramdatabase库returnStringRedisTemplateauthorzhengshangjincreatedon20200423publicStringRedisTemplatecreateStringRedisTemplate（Stringhost，intport，Stringpassword，intdatabase）｛基本配置RedisStandaloneConfigurationconfigurationnewRedisStandaloneConfiguration（）；configuration。setHostName（host）；configuration。setPort（port）；configuration。setDatabase（database）；if（ObjectUtils。isNotEmpty（password））｛RedisPasswordredisPasswordRedisPassword。of（password）；configuration。setPassword（redisPassword）；｝连接池通用配置GenericObjectPoolConfiglt；？genericObjectPoolConfignewGenericObjectPoolConfig（）；genericObjectPoolConfig。setMaxTotal（maxActive）；genericObjectPoolConfig。setMinIdle（minIdle）；genericObjectPoolConfig。setMaxIdle（maxIdle）；genericObjectPoolConfig。setMaxWaitMillis（maxWait）；LettucePoolLettucePoolingClientConfiguration。LettucePoolingClientConfigurationBuilderbuilderLettucePoolingClientConfiguration。builder（）；builder。poolConfig（genericObjectPoolConfig）；builder。commandTimeout（Duration。ofSeconds（timeout））；LettuceConnectionFactoryconnectionFactorynewLettuceConnectionFactory（configuration，builder。build（））；connectionFactory。afterPropertiesSet（）；StringRedisTemplatestringRedisTemplatenewStringRedisTemplate（）；stringRedisTemplate。setConnectionFactory（connectionFactory）；returnstringRedisTemplate；｝｝注入使用
　　根据Qualifier指定beanname来获取AutowiredQualifier（liveStringRedisTemplate）publicStringRedisTemplatestringRedisTemplate；