重庆网站建设建站收费,建筑方案设计网站,化工营销型网站,深圳网站定制价格低1⃣️环境准备
准备 Java 环境#xff1a;终端输入 java -version 命令来确认版本是否符合 Elasticsearch 要求下载并解压 Elasticsearch#xff1a;前往#xff08;https://www.elastic.co/downloads/elasticsearch#xff09;选择适合你的 Mac 系统的 Elasticsearch 版本…1⃣️环境准备
准备 Java 环境终端输入 java -version 命令来确认版本是否符合 Elasticsearch 要求下载并解压 Elasticsearch前往https://www.elastic.co/downloads/elasticsearch选择适合你的 Mac 系统的 Elasticsearch 版本进行下载设置 Elasticsearch 配置在 config 目录下找到并打开 elasticsearch.yml 配置文件。根据你的需求修改其中的一些设置比如监听的端口、集群名称等启动 Elasticsearch打开终端进入 Elasticsearch 解压目录执行以下命令启动 Elasticsearch ./bin/elasticsearch验证 Elasticsearch 是否正常运行打开浏览器访问 http://localhost:9200 地址如果能看到返回的 JSON 格式的信息说明 Elasticsearch 已经成功安装并运行。
2⃣️使用
要使用Elasticsearch进行增删改查等操作你可以通过Postman来实现。下面我将提供一个使用RESTful API来演示的示例
创建索引库 添加文档(添加行) 查询索引库 修改索引库 删除索引库 3⃣️与Java使用
如何使用Java与Elasticsearch进行索引的创建、文档的增加、查询、修改和删除操作
添加Elasticsearch Maven依赖
在pom.xml文件中添加以下依赖项
dependenciesdependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion7.13.3/version/dependencydependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactIdversion7.13.3/version/dependency
/dependencies创建索引库
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.common.xcontent.json.JsonXContent;// 创建RestHighLevelClient客户端
RestHighLevelClient client new RestHighLevelClient(RestClient.builder(localhost:9200));// 创建索引请求
CreateIndexRequest request new CreateIndexRequest(my_index);
request.settings(Settings.builder().put(index.number_of_shards, 1).put(index.number_of_replicas, 0));// 创建映射
XContentBuilder mapping JsonXContent.contentBuilder().startObject().startObject(properties).startObject(user).field(type, keyword).endObject().startObject(postDate).field(type, date).endObject().startObject(message).field(type, text).endObject().endObject().endObject();
request.mapping(mapping);// 执行创建索引请求
CreateIndexResponse response client.indices().create(request, RequestOptions.DEFAULT);
if (response.isAcknowledged()) {System.out.println(索引创建成功);
} else {System.out.println(索引创建失败);
}// 关闭客户端
client.close();添加文档
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.client.RestClient;// 创建RestHighLevelClient客户端
RestHighLevelClient client new RestHighLevelClient(RestClient.builder(localhost:9200));// 构建索引请求
IndexRequest request new IndexRequest(my_index);
request.id(1);
String jsonString { \user\:\John\, \postDate\:\2023-09-25\, \message\:\This is a sample document\ };
request.source(jsonString, XContentType.JSON);// 执行索引请求
IndexResponse response client.index(request, RequestOptions.DEFAULT);// 获取响应结果
String index response.getIndex();
String id response.getId();
if (response.getResult() DocWriteResponse.Result.CREATED) {System.out.println(文档创建成功索引 index id id);
} else if (response.getResult() DocWriteResponse.Result.UPDATED) {System.out.println(文档更新成功索引 index id id);
}// 关闭客户端
client.close();查询索引库
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.client.RestClient;// 创建RestHighLevelClient客户端
RestHighLevelClient client new RestHighLevelClient(RestClient.builder(localhost:9200));// 构建搜索请求
SearchRequest request new SearchRequest(my_index);
SearchSourceBuilder searchSourceBuilder new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchQuery(message, sample));
request.source(searchSourceBuilder);// 执行搜索请求
SearchResponse response client.search(request, RequestOptions.DEFAULT);// 处理搜索结果
SearchHits hits response.getHits();
for (SearchHit hit : hits.getHits()) {String sourceAsString hit.getSourceAsString();System.out.println(sourceAsString);
}// 关闭客户端
client.close();修改索引库
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.XContentFactory;
import org.elasticsearch.client.RestClient;// 创建RestHighLevelClient客户端
RestHighLevelClient client new RestHighLevelClient(RestClient.builder(localhost:9200));// 构建更新请求
UpdateRequest request new UpdateRequest(my_index, 1).doc(XContentFactory.jsonBuilder().startObject().field(message, Updated document).endObject());// 执行更新请求
UpdateResponse response client.update(request, RequestOptions.DEFAULT);
String index response.getIndex();
String id response.getId();
if (response.getResult() DocWriteResponse.Result.UPDATED) {System.out.println(文档更新成功索引 index id id);
} else if (response.getResult() DocWriteResponse.Result.NOOP) {System.out.println(文档未发生更新索引 index id id);
}// 关闭客户端
client.close();删除索引库
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.RestClient;// 创建RestHighLevelClient客户端
RestHighLevelClient client new RestHighLevelClient(RestClient.builder(localhost:9200));// 构建删除请求
DeleteRequest request new DeleteRequest(my_index, 1);// 执行删除请求
DeleteResponse response client.delete(request, RequestOptions.DEFAULT);
String index response.getIndex();
String id response.getId();
if (response.getResult() DocWriteResponse.Result.DELETED) {System.out.println(文档删除成功索引 index id id);
} else if (response.getResult() DocWriteResponse.Result.NOT_FOUND) {System.out.println(文档未找到索引 index id id);
}// 关闭客户端
client.close();
