elasticsearch的安装与使用

在官网上下载elasticsearch压缩包,这里是使用的是7.8.0版本的,使用的环境是windows系统.
官网:[https://www.elastic.co/cn/elasticsearch/]
解压缩之后直接启动即可(bin目录下的elasticsearch.bat)

浏览器输入localhost:1001(我这里设置的端口号是1001,可以在config/yml配置文件中修改,默认端口是9200

添加依赖

        
            org.elasticsearch
            elasticsearch
            7.8.0
        

        
            org.elasticsearch.client
            elasticsearch-rest-high-level-client
            7.8.0
        

写一个main函数

RestHighLevelClient esClient = new RestHighLeveClient(
	RestClient.builder(new HttpHost("localhost",port:1001,"http"))
);

CreateIndexRequest user = new CreateIndexRequest("user");
CreateIndexResponse createIndexResponse = esClient.indices().create(user,RequestOption.DEFAULT);

响应状态
boolean ackonwledged = createIndexResponse.isAcknowledged();

GetIndexRequest user1 = new GetIndexRequest("user");
GetIndexReponse getIndexReponse = esClient.indices().get(user1,RequestOption.DEFAULT);

System.out.println(getIndexReponse.getAliases());
System.out.println(getIndexReponse.getSettings());
System.out.println(getIndexReponse.getMappings());

DeleteIndexRequest request = new DeleteIndexRequest("user");
AcknowledgedResponse delete = esClient.indices().delete(request,RequestOptions.DEFAULT);
**响应状态**
System.out.println(delete.isAcknowledged());

IndexRequest requestIndex = new IndexRequest();
requestIndex.index("user").id("1001");//id号(自定义)

User user2 = new User(){{
	setName("zhangsan");
	setAge(20);
	setSex("男");
}};

//向ES插入数据必须是JSON格式的
String writevalueAsString = new ObjectMapper().writevalueAsString(user2);
requestIndex.source(writevalueAsString,XContentType.JSON);
IndexResponse index = esClient.index(requestIndex,RequestOptions.DEFAULT);
System.out.println(index.getResult());

        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.index("user").id("1001");
        updateRequest.doc(XContentType.JSON,"sex","女");

        UpdateResponse update = esClient.update(updateRequest, RequestOptions.DEFAULT);

        System.out.println(update.getResult());

        GetRequest getRequest = new GetRequest();
        getRequest.index("user").id("1001");
        GetResponse documentFields = esClient.get(getRequest, RequestOptions.DEFAULT);

        System.out.println(documentFields.getSourceAsString());

        DeleteRequest deleteRequest = new DeleteRequest();
        deleteRequest.index("user").id("1001");

        DeleteResponse delete1 = esClient.delete(deleteRequest, RequestOptions.DEFAULT);
        System.out.println(delete1.getResult());

        BulkRequest bulkRequest = new BulkRequest();

        bulkRequest.add(new IndexRequest().index("user").id("1001").source(XContentType.JSON,"name","zhangsan"));
        bulkRequest.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON,"name","zhangsan"));
        bulkRequest.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON,"name","zhangsan"));

        BulkResponse responses = esClient.bulk(bulkRequest, RequestOptions.DEFAULT);

        System.out.println(responses.getTook());//执行时间
        System.out.println(Arrays.toString(responses.getItems()));//在批量操作中执行的每个操作的项目

 DeleteRequest deleteRequest1 = new DeleteRequest();

        bulkRequest.add(new DeleteRequest().index("user").id("1001"));
        bulkRequest.add(new DeleteRequest().index("user").id("1002"));
        bulkRequest.add(new DeleteRequest().index("user").id("1003"));

        BulkResponse responsesDele = esClient.bulk(bulkRequest, RequestOptions.DEFAULT);

        System.out.println(responses.getTook());//执行时间
        System.out.println(Arrays.toString(responses.getItems()));//在批量操作中执行的每个操作的项目
        

//关闭客户端
esClient.close();