单个API，多个Elasticsearch实例

Question

我们有一个Spring Boot Restful API，它需要从两个不同的Elasticsearch实例（在不同的服务器上）获取数据，一个用于“共享”数据（上面有大约5个不同的索引），一个用于“私有”数据（有大约3个不同的索引）。目前只针对“私有”数据实例运行，一切都很好。但我们现在需要获取“共享”数据。

在我们的Spring Boot应用程序中，我们启用了如下Elasticsearch存储库

@SpringBootApplication
@EnableElasticsearchRepositories(basePackages = {
    "com.company.core.repositories",  //<- private repos here...
    "com.company.api.repositories"  //<-- shared repos here...
})
public class Application { //... }

然后我们使用Elasticsearch chRepository访问“私有”数据，例如：

package com.company.core.repositories

public interface DocRepository extends ElasticsearchRepository<Doc, Integer> { ... }

在我们的终点，我们有。。。

@RestController
@CrossOrigin
@RequestMapping("/v2/statuses/")
public class StatusEndpoint {
    @Resource
    private ElasticsearchTemplate template;

    @Autowired
    private DocRepository docRepository;

    @Autowired
    private Validator validator;
    //...
}

现在我们要添加另一个存储库，如：

package com.company.api.repositories

public interface LookupRepository extends ElasticsearchRepository<Lookup, Integer> { ... }

然后在我们的API层中，我们将添加一个自动连接的实例...

@Autowired
private LookupRepository lookupRepo;

我们在想我们可以定义多个具有不同名称的Bean，但是我们如何将每个“elasticsearch chTemboard”bean与需要它们的不同Elasticsearch chRepository实例相关联？此外，我们如何将“私有”bean/配置与注入的实例相关联

@Resource
private ElasticsearchTemplate template;

我们需要在哪里本地使用它？

Answer 1

可能有多种方法可以做到这一点。这是一种利用@Bean名称和@Resources名称的方法。

@Configuration
public class MyElasticConfig{

    @Bean //this is your private template
    public ElasticsearchTemplate template(){
        //construct your template
        return template;
    }

    @Bean //this is your public template
    public ElasticsearchTemplate publicTemplate(){
        //construct your template
        return template;
    }
}

然后你可以这样得到他们...

@Resource
private ElasticsearchTemplate template;

@Resource
private ElasticsearchTemplate publicTemplate;

或

@Resource(name="template")
private ElasticsearchTemplate anyName;

@Resource(name="publicTemplate")
private ElasticsearchTemplate anyOtherName;

您还可以直接命名@Bean，而不是依赖@Bean的方法名。

    @Bean (name="template")
    public ElasticsearchTemplate myPrivateTemplate(){
        //construct your template
        return template;
    }

    @Bean (name="publicTemplate")
    public ElasticsearchTemplate myPubTemplate(){
        //construct your template
        return template;
    }

看看这些关于这个话题的精彩资源。

SPRING注入@RESOURCE、@AUTOWIRED和@INJECT
Bean注释类型
AUTOWIRED vs RESOURCE

Answer 2

您可以使用2个唯一的Elasticsearch配置bean和StatusEndpoint控制器中模板注入的@Resources（name="XXX"）注释来解决这个问题。

如果根据应使用的Elasticsearch集群将存储库分隔为不同的包，则可以使用@EnableElasticsearchRepositories注释将它们与不同的配置相关联。

例如：

如果您有这些包和类：

com.company.data.repositories.private.YourPrivateRepository
com.company.data.repositories.shared.YourSharedRepository

然后是这些配置：

@Configuration
@EnableElasticsearchRepositories( 
    basePackages = {"com.company.data.repositories.private"},
    elasticsearchTemplateRef = "privateElasticsearchTemplate")
public class PrivateElasticsearchConfiguration {

    @Bean(name="privateElasticsearchTemplate")
    public ElasticsearchTemplate privateTemplate() {
       //code to create connection to private ES cluster
    }
}

@Configuration
@EnableElasticsearchRepositories( 
    basePackages = {"com.company.data.repositories.shared"},
    elasticsearchTemplateRef = "sharedElasticsearchTemplate")
public class SharedElasticsearchConfiguration {

    @Bean(name="sharedElasticsearchTemplate")
    public ElasticsearchTemplate sharedTemplate() {
       //code to create connection to shared ES cluster
    }
}

由于@EnableElasticsearch chRepositories注释中的elasticsearch chTemplateRef参数，实现存储库的JPA代码将使用base Packages列表中存储库的指定模板。

对于StatusEndpoint部分，只需为@Resource注释提供正确的模板bean名称即可。您的StatusEndpoint如下所示：

@RestController
@CrossOrigin
@RequestMapping("/v2/statuses/")
public class StatusEndpoint {

    @Resource(name="privateElasticsearchTemplate")
    private ElasticsearchTemplate template;

    @Autowired
    private DocRepository docRepository;

    @Autowired
    private Validator validator;
    //...
}