Elasticsearch6.6.x 版本的学习（一）es 安装 和 JestClient 进行操作Elasticsearch6.6.x

npm  run  start

 <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.7.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>



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



 <dependency>
            <groupId>io.searchbox</groupId>
            <artifactId>jest</artifactId>
            <version>6.3.1</version>
 </dependency>

spring.elasticsearch.jest.uris=http://127.0.0.1:9200
spring.data.elasticsearch.cluster-nodes=localhost:9300
spring.data.elasticsearch.cluster-name=my-application

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class people {

    private Integer id;

    private String name;

    private String phone;
}

@RestController
public class IndexController {

导入依赖，就可以直接使用
    @Autowired
    private JestClient jestClient;

    @GetMapping("createIndex")
    public String createIndex(String indexName) throws Exception{
        CreateIndex createIndex = new CreateIndex.Builder(indexName).build();

        System.out.println(createIndex);
        JestResult result = jestClient.execute(createIndex);
        return result.getJsonString();
    }

    @GetMapping("deleteIndex")
    public String deleteIndex(String indexName) throws Exception{
        DeleteIndex deleteIndex = new DeleteIndex.Builder(indexName).build();
        JestResult result = jestClient.execute(deleteIndex);
        return result.getJsonString();
    }

  @GetMapping("creatDoc")
    public String creatDoc() throws Exception{

        people people = new people();
        people.setPhone("ddd");
        people.setName("iii");
        people.setId(55);
        Index.Builder builder = new Index.Builder(people);
        Index index = builder.index("people").type("peopledoc").build();
        JestResult result = jestClient.execute(index);
        return result.getJsonString();
    }

 @GetMapping("deleteDoc")
    public String deleteDoc(String id) throws Exception{
        Delete index = new Delete.Builder(id).index("people").type("peopledoc").build();
        JestResult result = jestClient.execute(index);
        return result.getJsonString();
    }

 @GetMapping("search")
    public String search(String Keyword) throws Exception{
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();


        searchSourceBuilder.query(new MultiMatchQueryBuilder(Keyword, "name","phone"));


        System.out.println(searchSourceBuilder.toString());


        SearchResult result = jestClient.execute(new Search.Builder(searchSourceBuilder.toString())
                .addIndex("people")
                .addType("peopledoc")
                .build());



        List<SearchResult.Hit<people, Void>> hits = result.getHits(people.class);


        for(SearchResult.Hit<people, Void> hit:  hits){
            people source = hit.source;

            System.out.println(source.getId());
            System.out.println(source.getPhone());
            System.out.println(source.getName());
            System.out.println("==============");
        }




        return result.getJsonString();
    }