连接到Spring启动应用程序中现有ElasticSearch实例的问题

Question

我有一个本地运行的elasticsearch实例。我有一个spring boot应用程序。在我的应用程序中，我有一个服务ServiceX，其中包含一个elasticsearch存储库，它扩展了ElasticsearchRepository。所以服务X包含YRepository扩展了ElasticsearchRepository

我有一个本地运行的elasticsearch实例。

我的弹性搜索设置是

ELASTICSEARCH (ElasticsearchProperties)
spring.data.elasticsearch.properties.http.enabled=true
spring.data.elasticsearch.properties.host = localhost
spring.data.elasticsearch.properties.port = 9300

当应用程序启动时，会创建一个弹性搜索模板。使用的客户端是NodeClient。NodeClient的设置是

"http.enabled" -> "true"
"port" -> "9300"
"host" -> "localhost"
"cluster.name" -> "elasticsearch"
"node.local" -> "true"
"name" -> "Human Robot"
"path.logs" -> "C:/dev/git/xxx/logs"

elasticsearch（本例中为人类机器人）的名称与正在运行的本地elasticsearch实例（本例中为Nikki）不匹配。

看起来是这样的。创建logstash 2的新实例。创建logstash的嵌入式实例。

我翻遍了很多资料，但找不到任何可以帮忙的留档。

请大家建议使用什么设置好吗？谢谢

Answer 1

谢谢。你相信吗，在我看到你的帖子之前，我实际上刚刚开始尝试使用配置文件。我添加了一个配置类

@Configuration
public class ElasticSearchConfig {

    @Bean
    public Client client() {
      TransportClient client = new TransportClient();
      TransportAddress address = new InetSocketTransportAddress(
              "localhost",9300);
      client.addTransportAddress(address);
      return client;
  }
}

客户端现在正被注入到elasticsearch模板中（因此不需要elasticsearch ch模板bean）。

我在尝试连接时出错，但结果是由于elasticsearch 2.2.0，我用elasticsearch 1.7.3进行了尝试，现在可以解决下一个问题了！

Answer 2

我认为，除非您希望应用程序成为集群的一部分，否则您不想使用NodeClient，而是使用TransportClient

我相信您有以下依赖关系：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artificatId>spring-boot-starter-data-elasticsearch</artificatId>
</dependency>

然后您需要创建一些配置类，如下所示：

@Configuration
@PropertySource(value = "classpath:config/elasticsearch.properties")
public class ElasticsearchConfiguration {

    @Resource
    private Environment environment;

    @Bean
    public Client client() {
        TransportClient client = new TransportClient();
        TransportAddress address = new InetSocketTransportAddress(
                environment.getProperty("elasticsearch.host"), 
                Integer.parseInt(environment.getProperty("elasticsearch.port"))
        );
        client.addTransportAddress(address);        
        return client;
    }

    @Bean
    public ElasticsearchOperations elasticsearchTemplate() {
        return new ElasticsearchTemplate(client());
    }
}

还要检查Spring靴导槽的弹性部分，尤其是关于Spring的部分。数据弹性搜索。集群节点如果你放置多个逗号分隔的主机端口列表，它将生成一个TransportClient，由你选择

试试看，希望有帮助