共计 6888 个字符，预计需要花费 18 分钟才能阅读完成。
一、导入 elasticsearch 依赖
在 pom.xml 里退出如下依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
复制代码
十分重要：查看依赖版本是否与你以后所用的版本是否统一，如果不统一，会连贯失败！
二、创立高级客户端
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ElasticSearchClientConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(
new HttpHost(“ 服务器 IP”, 9200, “http”)));
return client;
}
}
复制代码
三、根本用法
1. 创立、判断存在、删除索引
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
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.indices.GetIndexRequest;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.io.IOException;
@SpringBootTest
class ElasticsearchApplicationTests {
@Autowired
private RestHighLevelClient restHighLevelClient;
@Test
void testCreateIndex() throws IOException {
//1. 创立索引申请
CreateIndexRequest request = new CreateIndexRequest(“ljx666”);
//2. 客户端执行申请 IndicesClient，执行 create 办法创立索引，申请后取得响应
CreateIndexResponse response=
restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
System.out.println(response);
}
@Test
void testExistIndex() throws IOException {
//1. 查问索引申请
GetIndexRequest request=new GetIndexRequest(“ljx666”);
//2. 执行 exists 办法判断是否存在
boolean exists=restHighLevelClient.indices().exists(request,RequestOptions.DEFAULT);
System.out.println(exists);
}
@Test
void testDeleteIndex() throws IOException {
//1. 删除索引申请
DeleteIndexRequest request=new DeleteIndexRequest(“ljx666”);
// 执行 delete 办法删除指定索引
AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
}
复制代码
2. 对文档的 CRUD
创立文档：
留神：如果增加时不指定文档 ID，他就会随机生成一个 ID，ID 惟一。
创立文档时若该 ID 已存在，发送创立文档申请后会更新文档中的数据。
@Test
void testAddUser() throws IOException {
//1. 创建对象
User user=new User(“Go”,21,new String[]{“ 内卷 ”,” 吃饭 ”});
//2. 创立申请
IndexRequest request=new IndexRequest(“ljx666”);
//3. 设置规定 PUT /ljx666/_doc/1
// 设置文档 id=6，设置超时 =1s 等，不设置会应用默认的
// 同时反对链式编程如 request.id(“6”).timeout(“1s”);
request.id(“6”);
request.timeout(“1s”);
//4. 将数据放入申请，要将对象转化为 json 格局
//XContentType.JSON，通知它传的数据是 JSON 类型
request.source(JSONValue.toJSONString(user), XContentType.JSON);
//5. 客户端发送申请，获取响应后果
IndexResponse indexResponse=restHighLevelClient.index(request,RequestOptions.DEFAULT);
System.out.println(indexResponse.toString());
System.out.println(indexResponse.status());
}
复制代码
获取文档中的数据：
@Test
void testGetUser() throws IOException {
//1. 创立申请, 指定索引、文档 id
GetRequest request=new GetRequest(“ljx666″,”1”);
GetResponse getResponse=restHighLevelClient.get(request,RequestOptions.DEFAULT);
System.out.println(getResponse);// 获取响应后果
//getResponse.getSource() 返回的是 Map 汇合
System.out.println(getResponse.getSourceAsString());// 获取响应后果 source 中内容，转化为字符串
}
复制代码
更新文档数据:
留神：须要将 User 对象中的属性全副指定值，不然会被设置为空，如 User 只设置了名称，那么只有名称会被批改胜利，其余会被批改为 null。
@Test
void testUpdateUser() throws IOException {
//1. 创立申请, 指定索引、文档 id
UpdateRequest request=new UpdateRequest(“ljx666″,”6”);
User user =new User(“GoGo”,21,new String[]{“ 内卷 ”,” 吃饭 ”});
// 将创立的对象放入文档中
request.doc(JSONValue.toJSONString(user),XContentType.JSON);
UpdateResponse updateResponse=restHighLevelClient.update(request,RequestOptions.DEFAULT);
System.out.println(updateResponse.status());// 更新胜利返回 OK
}
复制代码
删除文档:
@Test
void testDeleteUser() throws IOException {
// 创立删除申请，指定要删除的索引与文档 ID
DeleteRequest request=new DeleteRequest(“ljx666″,”6”);
DeleteResponse updateResponse=restHighLevelClient.delete(request,RequestOptions.DEFAULT);
System.out.println(updateResponse.status());// 删除胜利返回 OK，没有找到返回 NOT_FOUND
}
复制代码
3. 批量 CRUD 数据
这里只列出了批量插入数据，其余与此相似
留神：hasFailures()办法是返回是否失败，即它的值为 false 时阐明上传胜利
@Test
void testBulkAddUser() throws IOException {
BulkRequest bulkRequest=new BulkRequest();
// 设置超时
bulkRequest.timeout(“10s”);
ArrayList<User> list=new ArrayList<>();
list.add(new User(“Java”,25,new String[]{“ 内卷 ”}));
list.add(new User(“Go”,18,new String[]{“ 内卷 ”}));
list.add(new User(“C”,30,new String[]{“ 内卷 ”}));
list.add(new User(“C++”,26,new String[]{“ 内卷 ”}));
list.add(new User(“Python”,20,new String[]{“ 内卷 ”}));
int id=1;
// 批量解决申请
for (User u :list){
// 不设置 id 会生成随机 id
bulkRequest.add(new IndexRequest(“ljx666”)
.id(“”+(id++))
.source(JSONValue.toJSONString(u),XContentType.JSON));
}
BulkResponse bulkResponse=restHighLevelClient.bulk(bulkRequest,RequestOptions.DEFAULT);
System.out.println(bulkResponse.hasFailures());// 是否执行失败,false 为执行胜利
}
复制代码
4. 查问所有、含糊查问、分页查问、排序、高亮显示
@Test
void testSearch() throws IOException {
SearchRequest searchRequest=new SearchRequest(“ljx666”);// 外面能够放多个索引
SearchSourceBuilder sourceBuilder=new SearchSourceBuilder();// 结构搜寻条件
// 此处能够应用 QueryBuilders 工具类中的办法
//1. 查问所有
sourceBuilder.query(QueryBuilders.matchAllQuery());
//2. 查问 name 中含有 Java 的
sourceBuilder.query(QueryBuilders.multiMatchQuery(“java”,”name”));
//3. 分页查问
sourceBuilder.from(0).size(5);
//4. 依照 score 正序排列
//sourceBuilder.sort(SortBuilders.scoreSort().order(SortOrder.ASC));
//5. 依照 id 倒序排列（score 会生效返回 NaN）
//sourceBuilder.sort(SortBuilders.fieldSort(“_id”).order(SortOrder.DESC));
//6. 给指定字段加上指定高亮款式
HighlightBuilder highlightBuilder=new HighlightBuilder();
highlightBuilder.field(“name”).preTags(“<span style=’color:red;’>”).postTags(“</span>”);
sourceBuilder.highlighter(highlightBuilder);
searchRequest.source(sourceBuilder);
SearchResponse searchResponse=restHighLevelClient.search(searchRequest,RequestOptions.DEFAULT);
// 获取总条数
System.out.println(searchResponse.getHits().getTotalHits().value);
// 输入后果数据（如果不设置返回条数，大于 10 条默认只返回 10 条）
SearchHit[] hits=searchResponse.getHits().getHits();
for(SearchHit hit :hits){
System.out.println(“ 分数:”+hit.getScore());
Map<String,Object> source=hit.getSourceAsMap();
System.out.println(“index->”+hit.getIndex());
System.out.println(“id->”+hit.getId());
for(Map.Entry<String,Object> s:source.entrySet()){
System.out.println(s.getKey()+”–“+s.getValue());
}
}
}
复制代码
四、总结
1. 大抵流程
创立对应的申请 –> 设置申请（增加规定，增加数据等）–> 执行对应的办法（传入申请，默认申请选项）–> 接管响应后果（执行办法返回值）–> 输入响应后果中须要的数据（source，status 等）
2. 注意事项
如果不指定 id，会主动生成一个随机 id
失常状况下，不应该这样应用 new IndexRequest(“ljx777”)，如果索引产生扭转了，那么代码都须要批改，能够定义一个枚举类或者一个专门寄存常量的类，将变量用 final static 等进行润饰，并指定索引值。其余中央援用该常量即可，须要批改也只需批改该类即可。
elasticsearch 相干的货色，版本都必须统一，不然会报错
elasticsearch 很耗费内存，倡议在内存较大的服务器上运行 elasticsearch，否则会因为内存不足导致 elasticsearch 主动 killed。
