# 使用JAVA操作ElasticSearch，让搜索更强大 #

后端

2023-09-13 15:19:34

利用 Java 和 Elasticsearch 提升搜索能力

在当今以数据驱动的世界中，高效地检索和分析海量数据至关重要。关系数据库管理系统 (RDBMS) 虽然在许多情况下表现出色，但在处理大规模数据时可能会遇到效率问题。这就是 Elasticsearch 发挥作用的地方。

Elasticsearch 是一个基于 Apache Lucene 的分布式搜索引擎，专为快速可靠地检索和分析大量数据而设计。它具有以下主要特性：

分布式： Elasticsearch 可以跨多个服务器分布数据，从而提高可扩展性和容错能力。
可扩展： 可以根据需要轻松添加或删除节点，以满足不断变化的数据需求。
快速： 使用倒排索引存储数据，可以实现超快速的数据检索。
准确： 通过相关性评分、拼写检查和同义词扩展等技术确保搜索结果的准确性。

使用 Java 操作 Elasticsearch

要开始使用 Java 操作 Elasticsearch，请按照以下步骤进行操作：

导入依赖项： 在您的项目中添加以下依赖项：

<dependency>
  <groupId>org.elasticsearch.client</groupId>
  <artifactId>elasticsearch-rest-high-level-client</artifactId>
  <version>7.17.6</version>
</dependency>

创建 Elasticsearch 客户端： 使用 RestClientBuilder 创建一个 RestHighLevelClient：

RestHighLevelClient client = new RestHighLevelClient(
  RestClient.builder(
    new HttpHost("localhost", 9200, "http")
  )
);

创建索引： 索引是 Elasticsearch 中存储数据的基本单位，类似于数据库中的表：

CreateIndexRequest request = new CreateIndexRequest("my_index");
client.indices().create(request, RequestOptions.DEFAULT);

创建文档： 文档是 Elasticsearch 中存储数据的最小单位，类似于数据库中的行：

IndexRequest request = new IndexRequest("my_index", "my_type", "1");
request.source(
  XContentFactory.jsonBuilder()
    .startObject()
    .field("title", "ElasticSearch")
    .field("content", "ElasticSearch is a distributed search engine.")
    .endObject()
);
client.index(request, RequestOptions.DEFAULT);

查询文档： 使用 SearchSourceBuilder 查询文档：

SearchRequest request = new SearchRequest("my_index");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(QueryBuilders.matchQuery("title", "ElasticSearch"));
request.source(sourceBuilder);
SearchResponse response = client.search(request, RequestOptions.DEFAULT);

删除文档： 删除不再需要的文档：

DeleteRequest request = new DeleteRequest("my_index", "my_type", "1");
client.delete(request, RequestOptions.DEFAULT);

关闭 Elasticsearch 客户端： 使用完 Elasticsearch 客户端后，请务必关闭它：
```
client.close();
```

与 Spring Boot 集成

Elasticsearch 可以轻松与 Spring Boot 集成：

导入依赖项： 在您的 Spring Boot 项目中添加以下依赖项：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

配置 Elasticsearch： 在 application.properties 中配置 Elasticsearch 属性：
```
spring.elasticsearch.rest.uris=http://localhost:9200
```

创建 Elasticsearch 操作类：

@RestController
public class ElasticSearchController {

  @Autowired
  private ElasticSearchOperations elasticSearchOperations;

  @PostMapping("/index")
  public void index() {
    IndexQuery query = new IndexQuery();
    query.setId("1");
    query.setObject(new MyObject("ElasticSearch", "ElasticSearch is a distributed search engine."));
    elasticSearchOperations.index(query);
  }

  @GetMapping("/search")
  public List<MyObject> search() {
    SearchQuery query = new SearchQuery();
    query.setQuery(new TermQueryBuilder("title", "ElasticSearch"));
    SearchHits<MyObject> hits = elasticSearchOperations.search(query, MyObject.class);
    List<MyObject> result = new ArrayList<>();
    for (SearchHit<MyObject> hit : hits) {
      result.add(hit.getContent());
    }
    return result;
  }
}