要求幾秒鐘之內(nèi)有寫請求，哪怕配置讀數(shù)據(jù)庫，也要使用master數(shù)據(jù)庫

可以借助sPRing 的AbstractRoutingDataSource主要實(shí)現(xiàn)determineTargetDataSource抽象方法，去獲取對應(yīng)的datasource

public class DynamicDataSource extends AbstractRoutingDataSource {    public static final String DEFAULT_DATA_SOURCE = "defaultDataSource";    public static final List<String> dataSourceNames = new ArrayList<String>();    @Override    protected Object determineCurrentLookupKey() {        return DataSourceContextHolder.getDataSourceName();    }    public void setTargetDataSources(Map<Object, Object> targetDataSources) {        if (targetDataSources != null) {            Iterator iterator = targetDataSources.keySet().iterator();            while (iterator.hasNext()) {                String name = (String) iterator.next();                if (!DynamicDataSource.DEFAULT_DATA_SOURCE.equals(name)) {                    dataSourceNames.add(name);                }            }        }        super.setTargetDataSources(targetDataSources);    }
public class DataSourceContextHolder {    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();    /**     *     * @param dataSourceName     */    public static void setDataSourceName(String dataSourceName) {        contextHolder.set(dataSourceName);    }    public static String getDataSourceName() {        return contextHolder.get();    }    /**     * 清除只讀數(shù)據(jù)源     */    public static void clearDataSource() {        contextHolder.remove();    }    /**     * 設(shè)置為只讀數(shù)據(jù)源     */    public static void readDataSource() {        readDataSource(new PollingDataSourceAdapter());    }    public static void readDataSource(DataSourceAdapter adapter){        setDataSourceName(adapter.calculate(DynamicDataSource.dataSourceNames));    }    /**     * 設(shè)置為只讀數(shù)據(jù)源     */    public static void defaultDataSource() {        setDataSourceName(DynamicDataSource.DEFAULT_DATA_SOURCE);    }}
aspect
 public Object switchReadOnlyDataSource(ProceedingJoinPoint joinPoint) throws Throwable {              Object result = null;        try {            if (dataSourceHoldEnabled && DataSourceContextHolder.getDataSourceName() == null) {                MethodSignature signature = (MethodSignature) joinPoint.getSignature();                Method method = signature.getMethod();                if (method.getAnnotation(ReadOnlyDataSource.class) == null||(checkWriteInReadonly&&DistributedContext.getDBWriteRecord().isUpdatedIn(dbSyncSecond))) {//寫                    DataSourceContextHolder.defaultDataSource();                    ....                } else {//讀                    if (dataSourceAdapter == null) {                        DataSourceContextHolder.readDataSource();                    } else {                        DataSourceContextHolder.readDataSource(dataSourceAdapter);                    }                }                                           }            result = joinPoint.proceed();        } finally {            if (flag) {                DataSourceContextHolder.clearDataSource();            }        }        return result;    }
參考：http://www.cnblogs.com/surge/p/3582248.html