来自不同数据源或数据库的异步多个查询

Question

我无法找到适当的解决方案：

我有几个数据库具有相同的结构，但具有不同的数据。当我的Web应用程序执行查询时，它必须为每个数据库分开此查询并异步执行，然后汇总来自所有数据库的结果并将其作为单一结果返回。另外我想能够传递一个数据库的列表，其中将执行查询，并且我希望传递查询执行的最大过期时间。结果还必须包含每个数据库的元信息，例如超额执行时间。

如果可以使用其他数据源（如具有特定API的远程Web服务而不是关系数据库），那将会很棒。

我使用Spring/Grail并需要Java解决方案，但我会很乐意提供任何建议。

UPD：我想找到准备好的解决方案，也许框架或类似的东西。

Answer 1

这是基本的OO。您需要抽象出您正在尝试实现的内容 - 从您使用的机制中加载数据 - 实现数据库查询或Web服务调用。

这样的设计通常会涉及一个接口，该接口定义可以完成什么的合同，然后是根据其实现情况实现的多个实现类。

例如，你想最终，看上去像一个接口：

public interface DataLoader 
{ 
    public Collection<Data> loadData() throws DataLoaderException; 
} 

那么你将不得不实现比如JdbcDataLoader，WebServiceDataLoader等。在你的情况，你就需要另一种类型的实现是给定DataLoader的一个或多个实例，每个运算每个累计汇总结果。这个实现看起来像这样：

public class AggregatingDataLoader implements DataLoader 
{ 
    private Collection<DataLoader> dataLoaders; 
    private ExecutorService executorService; 

    public AggregatingDataLoader(ExecutorService executorService, Collection<DataLoader> dataLoaders) 
    { 
    this.executorService = executorService; 
    this.dataLoaders = dataLoaders; 
    } 

    public Collection<Data> loadData() throws DataLoaderException 
    { 
    Collection<DataLoaderCallable>> dataLoaderCallables = new ArrayList<DataLoaderCallable>>(); 

    for (DataLoader dataLoader : dataLoaders) 
    { 
     dataLoaderCallables.add(new DataLoaderCallable(dataLoader)); 
    } 

    List<Future<Collection<Data>>> futures = executorService.invokeAll(dataLoaderCallables); 

    Collection<Data> data = new ArrayList<Data>(); 
    for (Future<Collection<Data>> future : futures) 
    { 
     add.addAll(future.get()); 
    }  

    return data; 
    } 

    private class DataLoaderCallable implements Callable<Collection<Data>> 
    { 
    private DataLoader dataLoader; 

    public DataLoaderCallable(DataLoader dataLoader) 
    { 
     this.dataLoader = dataLoader; 
    } 

    public Collection<Data> call() 
    { 
     return dataLoader.load(); 
    } 
    } 
} 

你需要添加一些超时和异常处理逻辑，但你得到的主旨。

另一个重要的是你的通话代码应该只使用DataLoader接口，这样你就可以在测试过程中交换不同的实现或者使用模拟。