admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-07 00:58:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add "Load Balance" for multi dataSource

Browse Source
This commit is contained in:
开源海哥 2023-07-27 10:35:43 +08:00
parent 665f3fc7a4
commit 66d50d1621
2 changed files with 27 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/DataSourceKey.java
View File

@ -25,7 +25,7 @@ public class DataSourceKey {
private static final ThreadLocal<String> keyThreadLocal = new ThreadLocal<>();
public static void use(String dataSourceKey) {
keyThreadLocal.set(dataSourceKey);
keyThreadLocal.set(dataSourceKey.trim());
}
public static <T> T use(String dataSourceKey, Supplier<T> supplier) {

32
mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/FlexDataSource.java
View File

@ -30,15 +30,15 @@ import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.*;
import java.util.concurrent.ThreadLocalRandom;
/**
* @author michael
*/
public class FlexDataSource extends AbstractDataSource {
private static final char LOAD_BALANCE_KEY_SUFFIX = '*';
private static final Log log = LogFactory.getLog(FlexDataSource.class);
private final Map<String, DataSource> dataSourceMap = new HashMap<>();
@ -194,9 +194,29 @@ public class FlexDataSource extends AbstractDataSource {
if (dataSourceMap.size() > 1) {
String dataSourceKey = DataSourceKey.get();
if (StringUtil.isNotBlank(dataSourceKey)) {
dataSource = dataSourceMap.get(dataSourceKey);
if (dataSource == null) {
throw new IllegalStateException("Cannot get target DataSource for dataSourceKey [" + dataSourceKey + "]");
//负载均衡 key
if (dataSourceKey.charAt(dataSourceKey.length() - 1) == LOAD_BALANCE_KEY_SUFFIX) {
String prefix = dataSourceKey.substring(0, dataSourceKey.length() - 1);
List<String> matchedKeys = new ArrayList<>();
for (String key : dataSourceMap.keySet()) {
if (key.startsWith(prefix)) {
matchedKeys.add(key);
}
}
if (matchedKeys.isEmpty()) {
throw new IllegalStateException("Can not matched dataSource by key: \"" + dataSourceKey + "\"");
}
String randomKey = matchedKeys.get(ThreadLocalRandom.current().nextInt(matchedKeys.size()));
return dataSourceMap.get(randomKey);
}
//非负载均衡 key
else {
dataSource = dataSourceMap.get(dataSourceKey);
if (dataSource == null) {
throw new IllegalStateException("Cannot get target dataSource by key: \"" + dataSourceKey + "\"");
}
}
}
}