springboot redis多数据源设置
2018-06-04 13:05
417 查看
遇到这样一个需求:运营人员在发布内容的时候可以选择性的发布到测试库、开发库和线上库。
项目使用的是spring boot集成redis,实现如下:
1. 引入依赖
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
2.多数据源设置
application.yml设置(application.properties同理):
spring: redis: database: 0 pool: max-active: 8 max-idle: 9 max-wait: -1 min-idle: 0 redis-dev: host: 填redis的ip地址 prot: 填redis的端口号 password: 填redis的密码 testOnBorrow: fals redis-test: host: prot: password: testOnBorrow: false redis-online: host: prot: password: testOnBorrow: false
针对每个数据源写一个配置类:
这里就只列举其中一个,不同的数据源设置不同的@Bean和@Value注解即可
@Configuration public class RedisDevConfiguration { @Bean(name = "redisDevTemplate") public StringRedisTemplate redisTemplate(@Value("${spring.redis-dev.host}") String hostName, @Value("${spring.redis-dev.port}") int port, @Value("${spring.redis-dev.password}") String password, @Value("${spring.redis-dev.testOnBorrow}") boolean testOnBorrow, @Value("${spring.redis.pool.max-idle}") int maxIdle, @Value("${spring.redis.pool.max-active}") int maxTotal, @Value("${spring.redis.database}") int index, @Value("${spring.redis.pool.max-wait}") long maxWaitMillis) { StringRedisTemplate temple = new StringRedisTemplate(); temple.setConnectionFactory( connectionFactory(hostName, port, password, maxIdle, maxTotal, index, maxWaitMillis, testOnBorrow)); return temple; } public RedisConnectionFactory connectionFactory(String hostName, int port, String password, int maxIdle, int maxTotal, int index, long maxWaitMillis, boolean testOnBorrow) { JedisConnectionFactory jedis = new JedisConnectionFactory(); jedis.setHostName(hostName); jedis.setPort(port); if (StringUtils.isNotEmpty(password)) { jedis.setPassword(password); } if (index != 0) { jedis.setDatabase(index); } jedis.setPoolConfig(poolCofig(maxIdle, maxTotal, maxWaitMillis, testOnBorrow)); // 初始化连接pool jedis.afterPropertiesSet(); RedisConnectionFactory factory = jedis; return factory; } public JedisPoolConfig poolCofig(int maxIdle, int maxTotal, long maxWaitMillis, boolean testOnBorrow) { JedisPoolConfig poolCofig = new JedisPoolConfig(); poolCofig.setMaxIdle(maxIdle); poolCofig.setMaxTotal(maxTotal); poolCofig.setMaxWaitMillis(maxWaitMillis); poolCofig.setTestOnBorrow(testOnBorrow); return poolCofig; } }
3.构造redis实例
写一个redis实例抽象类
public abstract class AbRedisConfiguration { protected StringRedisTemplate temple; public void setData(String key, String value) { getTemple().opsForValue().set(key, value); } public String getData(String key) { return getTemple().opsForValue().get(key); } public StringRedisTemplate getTemple() { return temple; } }
继成抽象类实现操作类,这里只列举一个
@Component public class RedisDev extends AbRedisConfiguration { @Resource(name = "redisDevTemplate") private StringRedisTemplate temple; public StringRedisTemplate getTemple() { return temple; } }
4.使用
在service中注入redis操作类
@Autowired private RedisDev redisDev; @Autowired private RedisTest redisTest; @Autowired private RedisTest redisOnline;
调用不同的操作类即可使用不同的redis数据源。
相关文章推荐
- springboot redis多数据源设置
- redis结合springboot设置不同缓存失效配置
- springboot+mybatis数据源的读写分离(mysql,后期连接设置,前期项目没做好的忽入会蒙的)
- SpringBoot 设置多数据源访问
- spring-boot整合redis作为缓存(1)——redis的设置
- Spring Boot Cache + redis 设置有效时间和自动刷新缓存,时间支持在配置文件中配置
- Spring Boot缓存实战 Redis 设置有效时间和自动刷新缓存-2
- springboot + mybaties 多数据源设置
- springboot+redis+ELK(ElasticSearch+Logstash+kibana)
- spring-boot 利用 actuator 动态设置 logging 的日志级别
- 【springBoot】springBoot集成redis的key,value序列化的相关问题
- SpringBoot中使用Redis实现缓存
- SpringBoot+Redis+Nginx实现负载均衡以及Session缓存共享
- springboot中静态变量值的注入及子项目间的profile的设置
- 详解springboot采用多数据源对JdbcTemplate配置的方法
- 在SpringBoot中添加Redis及配置方法
- Spring Boot Logging Level设置为off时Bug
- spring boot + redis 实现session共享
- 使用Java(Springboot)操作Redis
- spring boot + redis 实现session共享