ElasticSearch Java client 简单使用

引入maven依赖

需要引入 elasticsearch 和 elasticsearch-rest-high-level-client，到 maven 仓库搜索最新版本。

创建客户端

HttpHost httpHost = new HttpHost("localhost",9200);
RestClientBuilder restClientBuilder = RestClient.builder(httpHost);
client = new RestHighLevelClient(restClientBuilder);

GetIndexRequest getIndexRequest = new GetIndexRequest(index);
getIndexRequest.humanReadable(true);
boolean exists = client.indices().exists(getIndexRequest, RequestOptions.DEFAULT);

CreateIndexRequest request = new CreateIndexRequest(index);
Map properties = new HashMap<>();
autoBuildProperties(clazz, properties);
Map mapping = new HashMap<>();
mapping.put("properties", properties);
request.mapping(mapping);
client.indices().create(request, RequestOptions.DEFAULT);

异步插入或更新文档

IndexRequest request = new IndexRequest("index");
request.id(id);
request.source(beanToMap(object));
client.indexAsync(request, RequestOptions.DEFAULT, new ActionListener(){
    @Override
    public void onResponse(IndexResponse response) {
        //
    }

    @Override
    public void onFailure(Exception e) {
        //
    }
});

DeleteRequest request = new DeleteRequest("index", String.valueOf(id));
client.deleteAsync(request, RequestOptions.DEFAULT, new ActionListener() {
    @Override
    public void onResponse(DeleteResponse deleteResponse) {
        //
    }

    @Override
    public void onFailure(Exception e) {
        //
    }
});

SearchRequest searchRequest = new SearchRequest("index");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
// 构造查询条件，这里是全都返回
sourceBuilder.query(QueryBuilders.matchAllQuery());
searchRequest.source(searchSourceBuilder(batchQuery));
SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);