public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean     public Connection getConnection() throws SQLException {            return determineTargetDataSource().getConnection();        }       public Connection getConnection(String username, String password) throws SQLException {            return determineTargetDataSource().getConnection(username, password);        }  }

protected DataSource determineTargetDataSource() {        Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");        Object lookupKey = determineCurrentLookupKey();        DataSource dataSource = this.resolvedDataSources.get(lookupKey);        if (dataSource == null && (this.lenientFallback || lookupKey == null)) {            dataSource = this.resolvedDefaultDataSource;        }        if (dataSource == null) {            throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");        }        return dataSource;    }

好了, 重点来了, 这段代码的核心其实只有两点

• resolvedDefaultDataSource : 一个 Map<Object, DataSource> , 就是在配置的时候手动配置的Key与数据源的对应关系
• determineCurrentLookupKey() : 用来获取 Key 值, 需要在子类中实现获取Key的策略

思路

1. 项目中配置主从数据源, 并配置自己实现的AbstractRoutingDataSource子类做 主要的(@Primary)的DataSource
2. 实现AbstractRoutingDataSource子类, Key获取策略为从一个LocalThread变量中获取
3. 设计一个自定义注解,用于在Service层, DAO层, Repository层中使用
4. 通过AOP的方式去读取自定义注解, 然后根据注解往LocalThread里塞Key
5. 因为jetty可能会重用LocalThread, 所以需要在完成之后清空LocalThread变量, 至此, 多数据源配置完成

实现

注意

1. 要及时清空LocalThread变量, 防止LocalThread重用引起的错误
2. 这种方式, 在配置分布式事务的时候相当复杂, 具体参考 此文