elasticsearch命令(elasticsearch使用教程)

jar导入配置文件ES工具类编写

代码示例：

	   
       
           com.alibaba
           fastjson
           1.2.78
       

       
       
           org.springframework.boot
           spring-boot-starter-data-elasticsearch
       

配置示例：

#ES配置
#ES连接地址
spring.elasticsearch.uris=ip:9200
#ES账号
spring.elasticsearch.username=username
#ES密码
spring.elasticsearch.password=password
spring.elasticsearch.connection-timeout=30s

代码示例：

package com.xxx;【修改引用地址】

import com.alibaba.fastjson.JSON;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.support.WriteRequest;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.core.Timevalue;
import org.elasticsearch.rest.RestStatus;
import org.springframework.stereotype.Service;

import java.io.IOException;


@Service
public class EsUtils {

    
    public final RestHighLevelClient esClient;

    public EsUtils(RestHighLevelClient esClient) {
        this.esClient = esClient;
    }

    
    public boolean index(String index, String id, Object object) {
        try {
            //创建ES客户端
            IndexRequest indexRequest = new IndexRequest(index)
                    .id(id)
                    .source(JSON.toJSONString(object), XContentType.JSON);
            //使用IMMEDIATE刷新策略【请求向ElasticSearch提交了数据，立即进行数据刷新，然后再结束请求】
            indexRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
            //新增ES数据
            IndexResponse response = esClient.index(indexRequest, RequestOptions.DEFAULT);
            return response.getShardInfo().getFailed() == 0;
        } catch (Exception e) {
            System.out.println("添加缓存索引数据{}-异常==" + JSON.toJSONString(object) + "异常==" + e);
            return false;
        }
    }

    
    public boolean updateById(String index, String id, Object object) throws IOException {
        try {
            //创建ES客户端
            UpdateRequest updateRequest = new UpdateRequest(index, id);
            //封存实例对象
            updateRequest.doc(JSON.toJSONString(object), XContentType.JSON);
            //设置响应时间
            updateRequest.timeout(Timevalue.timevalueSeconds(1));
            //使用WAIT_UNTIL刷新策略【请求向ElasticSearch提交了数据，等待数据完成刷新，然后再结束请求】
            updateRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
            //常规更新（更新部分字段）
            UpdateResponse updateResponse = esClient.update(updateRequest, RequestOptions.DEFAULT);
            return RestStatus.OK.equals(updateResponse.status());
        } catch (Exception e) {
            System.out.println("添加缓存索引数据{}-异常==" + JSON.toJSONString(object) + "异常==" + e);
            return false;
        }
    }

    
    public boolean updateByIdUpsert(String index, String id, Object object) throws IOException {
        try {
            //创建ES客户端
            UpdateRequest updateRequest = new UpdateRequest(index, id);
            IndexRequest indexRequest = new IndexRequest(index, id).source(JSON.toJSONString(object), XContentType.JSON);
            //封存实例对象
            updateRequest.doc(indexRequest);
            updateRequest.docAsUpsert(true);
            //设置响应时间
            updateRequest.timeout(Timevalue.timevalueSeconds(1));
            //使用WAIT_UNTIL刷新策略【请求向ElasticSearch提交了数据，等待数据完成刷新，然后再结束请求】
            updateRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
            //常规更新（更新部分字段）
            UpdateResponse updateResponse = esClient.update(updateRequest, RequestOptions.DEFAULT);
            return RestStatus.OK.equals(updateResponse.status());
        } catch (Exception e) {
            System.out.println("添加缓存索引数据{}-异常==" + JSON.toJSONString(object) + "异常==" + e);
            return false;
        }
    }

    
    public boolean deleteById(String index, String id) {
        try {
            //创建ES客户端
            DeleteRequest request = new DeleteRequest(index)
                    .id(id);
            //根据ID删除数据
            DeleteResponse response = esClient.delete(request, RequestOptions.DEFAULT);
            return RestStatus.OK.equals(response.status());
        } catch (Exception e) {
            System.out.println("删除{}索引数据{}-异常==" + "index=" + index + "id=" + id + e);
            return false;
        }
    }
}