13518219792
本篇内容主要讲解“如何实现ElasticSearch的JavaAPI”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“如何实现ElasticSearch的JavaAPI”吧!
成都创新互联是一家专注于网站设计、成都做网站与策划设计,凭祥网站建设哪家好?成都创新互联做网站,专注于网站建设十余年,网设计领域的专业建站公司;建站业务涵盖:凭祥等地区。凭祥做网站价格咨询:13518219792
有人说学习一项技术最好的资料是官方文档，对大部分技术来说确实是这样的。但是官方文档不一定适合每个人去看，比如一个初学者，直接让他看Spring的官方文档，其实是不合适的。今天我会结合ElasticSearch的一个客户端官方文档介绍ES在Java中的API应用。
官方文档不一定好找，这里直接给出地址：
https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.6/index.html
你可以选择自己对应版本的文档来参考，我这里选择的是7.6版本，选用的是Java High Level REST Client。
首先需要创建一个项目，创建项目就不介绍了，引入ES核心依赖：
org.springframework.boot spring-boot-starter-data-elasticsearch
为了防止版本问题导致服务器客户端冲突，尽量将ES的版本设置的和自己安装的服务器端版本一致：
1.8 7.6.1
后续还会用一些json和web以及测试的操作，引入这些依赖：
org.springframework.boot spring-boot-starter-web org.projectlombok lombok true org.springframework.boot spring-boot-starter-test test com.alibaba fastjson 1.2.76
编写个配置类注入restHighLevelClient对象：
@Configuration
public class ElasticSearchConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client=new RestHighLevelClient(
RestClient.builder(
new HttpHost("192.168.78.128",9200,"http")
)
);
return client;
}
}后续会用到实体类，这里先提供了：
@Data
@AllArgsConstructor
public class User {
private String name;
private String address;
}接下来的操作都在SpringBootTest中进行，首先通过@Autowired注入
RestHighLevelClient 对象
@SpringBootTest
class ElasticsearchdemoApplicationTests {
@Autowired
private RestHighLevelClient restHighLevelClient;
}还是按照学习ES语法的顺序学习语法，找到索引API ，API中的操作很多，我主要选一些重要的讲一下
创建索引的主要对象是CreateIndexRequest
@Test
public void testCreateIndex() throws IOException {
//创建索引
CreateIndexRequest request=new CreateIndexRequest("test_index");
CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse.isAcknowledged());
}创建CreateIndexRequest对象，设置相关属性，比如切片数，副本数，超时时间等等，然后通过restHighLevelClient创建索引，获得一个结果响应。
//设置分片和副本
request.settings(Settings.builder()
.put("index.number_of_shards", 3)
.put("index.number_of_replicas", 2)
);获取一个索引，主要对象是GetIndexRequest
@Test
public void testGetIndex() throws IOException {
//获取索引
GetIndexRequest request=new GetIndexRequest("test_index");
GetIndexResponse getIndexResponse = restHighLevelClient.indices().get(request, RequestOptions.DEFAULT);
System.out.println(getIndexResponse);
}用的也是GetIndexRequest
@Test
public void testExistsIndex() throws IOException {
//获取索引
GetIndexRequest request=new GetIndexRequest("test_index");
boolean exists = restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}删除索引的请求对象是DeleteIndexRequest
@Test
public void testDeleteIndex() throws IOException {
DeleteIndexRequest request=new DeleteIndexRequest("test_index");
AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}对索引的操作可以通过图形化界面来实现，了解增删改即可。
文档的API分为单个文档处理和批量文档处理，我会介绍单个文档的增删改查和一个批量文档API
在用语法创建文档的时候，是这样的：
PUT http://ip:port/索引名/类型名/文档id
{
"name":"javayz",
"address":"hz"
}使用代码是这样的：请求对象为IndexRequest
@Test
public void testCreateDoc() throws IOException {
// PUT http://ip:port/索引名/类型名/文档id
User user=new User("javayz","hz");
IndexRequest request=new IndexRequest("text_index");
request.id("1");
request.source(JSON.toJSONString(user), XContentType.JSON);
IndexResponse index = restHighLevelClient.index(request, RequestOptions.DEFAULT);
System.out.println(index.status());
}其实两者十分相似，这也是学技术要先学基础的原因。有了基础一看就懂。
获取文档和判断是否存在这里放在一起写，请求对象都是GetRequest ：
@Test
public void testGetDoc() throws IOException{
GetRequest request=new GetRequest("text_index");
request.id("1");
boolean exists = restHighLevelClient.exists(request, RequestOptions.DEFAULT);
if (exists){
GetResponse documentFields = restHighLevelClient.get(request, RequestOptions.DEFAULT);
String sourceAsString = documentFields.getSourceAsString();
System.out.println(sourceAsString);
}else{
System.out.println(exists);
}
}更新文档的请求对象是UpdateRequest
@Test
public void testUpdateDoc() throws IOException{
UpdateRequest request=new UpdateRequest("text_index","1");
User user=new User("javayz2","hz");
request.doc(JSON.toJSONString(user),XContentType.JSON);
UpdateResponse response = restHighLevelClient.update(request, RequestOptions.DEFAULT);
System.out.println(response.status());
}删除文档的请求对象是DeleteRequest
@Test
public void testDeleteDoc() throws IOException{
DeleteRequest request=new DeleteRequest("text_index","1");
DeleteResponse deleteResponse = restHighLevelClient.delete(request, RequestOptions.DEFAULT);
System.out.println(deleteResponse.status());
}批量创建文档用到了BulkRequest ，具体的使用方式和单体很相似，只不过是把多个请求聚合到一个bulk中一起提交。
@Test
public void testBulkRequest() throws IOException{
BulkRequest request=new BulkRequest();
request.timeout("10s");
ArrayList list=new ArrayList<>();
list.add(new User("javayz1","hz"));
list.add(new User("javayz2","hz"));
//往BulkRequest对象中add文档
list.stream().forEach(x->{
request.add(new IndexRequest("text_index").source(JSON.toJSONString(x),XContentType.JSON));
});
BulkResponse bulk = restHighLevelClient.bulk(request, RequestOptions.DEFAULT);
System.out.println(bulk.status());
} 
查询操作用最常用的就是match（模糊查询）和term（精确查询），介绍最常用的查询方式：
@Test
public void testSearch() throws IOException {
SearchRequest request = new SearchRequest("text_index");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
//匹配条件
MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("name", "javayz1");
searchSourceBuilder.query(matchQueryBuilder);
request.source(searchSourceBuilder);
SearchResponse search = restHighLevelClient.search(request, RequestOptions.DEFAULT);
System.out.println(search);
}到此，相信大家对“如何实现ElasticSearch的JavaAPI”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
