ElasticSearch JavaAPI(java操作)

Posted 2022-04-04 dexi.Chi 程序猿

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了ElasticSearch JavaAPI(java操作)相关的知识，希望对你有一定的参考价值。

操作ElasticSearch分为脚本操作(运维人员常用)和java操作(开发人员常用)，今天小编主要介绍java操作方式，之前小编讲解了ES如何搭建，并介绍了IK分词器，今天基于ES环境来继续学习。

需求：使用sringboot整合ElasticSearch
实现步骤：
1、搭建springboot工程
2、引入ElasticSearch相关坐标
3、测试编码
下面是ElasticSearch的相关坐标
开始部署springboot项目

由于不是web工程，下面页面不需要勾选

直接finish完成

去pom文件引入ES所需要的坐标

<!-- 引入ES的坐标 -->
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.4.0</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.4.0</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.4.0</version>
</dependency>

写一个测试类，并启动下

这个时候我们开始整合springboot
在resource下创建application.yml

在java层级下创建ElasticSearchConfig类

package com.itheima.elasticsearchdemo.config;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@ConfigurationProperties(prefix = "elasticsearch")
public class ElasticSearchConfig 

    private String host;
    private int port;

    public String getHost() 
        return host;
    

    public void setHost(String host) 
        this.host = host;
    

    public int getPort() 
        return port;
    

    public void setPort(int port) 
        this.port = port;
    

    @Bean
    public RestHighLevelClient client()
        return  new RestHighLevelClient(RestClient.builder(
                new HttpHost(
                        host,port,"http"
                )
        ));

上方出现红条没有问题，引入一个maven坐标即可解决
重新修改测试类

package com.itheima.elasticsearchdemo;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ElasticsearchDemoApplicationTests 

    @Autowired
    private RestHighLevelClient client;

    @Test
    void contextLoads() 
        //1.创建ES客户端对象
//        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(
//                new HttpHost(
//                        "192.168.149.135",9200,"http"
//                )
//        ));
        System.out.println(client);