java 怎么集成elasticsearch
时间: 2023-11-30 09:51:34 浏览: 68
java开发web搜索引擎源码-Elasticsearch-Hbase:elasticsearch+hbase海量数据查询,支持千万数据秒回查
5星 · 资源好评率100%
集成elasticsearch需要以下步骤:
1. 下载elasticsearch
首先需要在官网(https://www.elastic.co/cn/downloads/elasticsearch)下载elasticsearch的安装包,选择适合自己系统的版本进行下载。
2. 安装elasticsearch
下载完成后,解压安装包,根据官方文档进行安装。
3. 安装Java客户端
可以使用elasticsearch提供的Java客户端来对elasticsearch进行操作,需要在项目中导入Java客户端相关的依赖。
Maven依赖:
```xml
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.12.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.12.0</version>
</dependency>
```
4. 连接elasticsearch
使用Java客户端连接elasticsearch需要指定elasticsearch的地址和端口号:
```java
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http")));
```
其中,localhost为elasticsearch所在的主机地址,9200为elasticsearch的默认端口号。
5. 对elasticsearch进行操作
连接成功后,就可以使用Java客户端对elasticsearch进行操作,比如创建索引、添加文档、搜索等。
创建索引:
```java
CreateIndexRequest request = new CreateIndexRequest("my_index");
client.indices().create(request, RequestOptions.DEFAULT);
```
添加文档:
```java
IndexRequest request = new IndexRequest("my_index");
request.id("1");
String jsonString = "{" +
"\"user\":\"kimchy\"," +
"\"postDate\":\"2021-04-07\"," +
"\"message\":\"trying out Elasticsearch\"" +
"}";
request.source(jsonString, XContentType.JSON);
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
```
搜索:
```java
SearchRequest request = new SearchRequest("my_index");
SearchSourceBuilder builder = new SearchSourceBuilder();
builder.query(QueryBuilders.matchQuery("message", "trying out"));
request.source(builder);
SearchResponse response = client.search(request, RequestOptions.DEFAULT);
```
以上代码演示了如何使用Java客户端对elasticsearch进行操作,具体操作请参考官方文档。
阅读全文