簡介 redis 多數據源主要的運用場景是在需要使用多個 redis 伺服器或者使用多個 redis 庫,本文采用的是 fastdep 依賴集成框架,快速集成 Redis 多數據源並集成 lettuce 連接池,只需引入依賴後在 yaml 文件中配置多數據源連接信息即可。 源碼地址 希望大家可以 s ...
簡介
redis 多數據源主要的運用場景是在需要使用多個 redis
伺服器或者使用多個 redis
庫,本文采用的是 fastdep
依賴集成框架,快速集成 Redis
多數據源並集成 lettuce
連接池,只需引入依賴後在 yaml
文件中配置多數據源連接信息即可。
源碼地址
希望大家可以 star 支持一下,後續還會加入其它依賴的簡易整合。
https://github.com/louislivi/fastdep
引入依賴
Maven
<dependency> <groupId>com.louislivi.fastdep</groupId> <artifactId>fastdep-redis</artifactId> <version>1.0.1</version> </dependency>
Gradle
compile group: 'com.louislivi.fastdep', name: 'fastdep-redis', version: '1.0.1'
配置文件
fastdep:
redis:
redis1: #連接名稱
database: 0
host: 192.168.12.88
port: 6379
lettuce: #下麵為連接池的補充設置
shutdown-timeout: 100 # 關閉超時時間
pool:
max-active: 18 # 連接池最大連接數(使用負值表示沒有限制)
max-idle: 8 # 連接池中的最大空閑連接
max-wait: 30 # 連接池最大阻塞等待時間(使用負值表示沒有限制)
min-idle: 0 # 連接池中的最小空閑連接
redis2: #連接名稱
database: 1
host: 192.168.12.88
port: 6379
lettuce: #下麵為連接池的補充設置
shutdown-timeout: 100 # 關閉超時時間
pool:
max-active: 18 # 連接池最大連接數(使用負值表示沒有限制)
max-idle: 8 # 連接池中的最大空閑連接
max-wait: 30 # 連接池最大阻塞等待時間(使用負值表示沒有限制)
min-idle: 0 # 連接池中的最小空閑連接
運用
@Autowired
private StringRedisTemplate redis1StringRedisTemplate;
// 註入時 redis1 代表配置文件中的連接名稱 StringRedisTemplate 為固定註入redis對象類型,
// 會自動根據註入的變數名進行匹配
@Autowired
private StringRedisTemplate redis2StringRedisTemplate;
@GetMapping("redis")
public void redis() {
System.out.println(redis1StringRedisTemplate.opsForValue().get("test"));
System.out.println(redis2StringRedisTemplate.opsForValue().get("test"));
}
擴展
有時候需要自定義 redisTemplate
序列化和增加一些額外的配置,這時候我們可以封裝一個 redis
工具類來實現
package com.louislivi.fastdep.test.utils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.stereotype.Component;
/**
* RedisUtil
*
* @author : louislivi
*/
@Component
public class RedisUtil {
@Autowired
private StringRedisTemplate redis1StringRedisTemplate;
@Autowired
private StringRedisTemplate redis2StringRedisTemplate;
@Autowired
private RedisTemplate redis2RedisTemplate;
@Autowired
private RedisTemplate redis1RedisTemplate;
public RedisTemplate redisTemplate(String name) {
RedisTemplate redisTemplate;
switch (name) {
case "redis2":
redisTemplate = redis2RedisTemplate;
break;
default:
redisTemplate = redis1RedisTemplate;
break;
}
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringRedisSerializer);
redisTemplate.setValueSerializer(stringRedisSerializer);
redisTemplate.setHashKeySerializer(stringRedisSerializer);
redisTemplate.setHashValueSerializer(stringRedisSerializer);
return redisTemplate;
}
public StringRedisTemplate stringRedisTemplate(String name) {
StringRedisTemplate stringRedisTemplate;
switch (name) {
case "redis2":
stringRedisTemplate = redis2StringRedisTemplate;
break;
default:
stringRedisTemplate = redis1StringRedisTemplate;
break;
}
stringRedisTemplate.setEnableTransactionSupport(true);
return stringRedisTemplate;
}
}
@Autowired
private RedisUtil redisUtil;
@GetMapping("redis")
public void redis() {
System.out.println(redisUtil.redisTemplate("redis1").opsForValue().get("test"));
System.out.println(redisUtil.stringRedisTemplate("redis2").opsForValue().get("test"));
}
原理
使用 ImportBeanDefinitionRegistrar
BeanDefinitionBuilder.genericBeanDefinition
動態註入 Bean
其實很簡單有興趣可以去看看源碼,這樣的依賴集成是不是簡單了很多呢?
希望大家能夠支持開源,給個小星星,後續還會繼續開發其他依賴的整合,甚至相容其他框架使用。fastdep
讓 java
整合依賴更簡單。在此也招募有志同道合的 coder
共同完善這個項目。
最後註意:光理論是不夠的。在此順便送大家十套2020最新JAVA架構項目實戰教程及大廠面試題庫,進我扣裙 :七吧傘吧零而衣零傘 (數字的諧音)轉換下可以找到了,還可以跟老架構師交流
本文的文字及圖片來源於網路加上自己的想法,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理