一、下載ES
ES：下載中心 - Elastic 中文社區(qū)
?安裝需要JDK，JAVA_HOMEElasticSearch下載并解壓，進(jìn)入bin目錄，雙擊elasticsearch.bat就能啟動(dòng)，訪問(wèn)地址localhost:9200
?
?注：本文使用的的ES版本為7.17.0文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-522163.html
二、創(chuàng)建springboot項(xiàng)目，引入依賴
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.4.2</version>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.4.2</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.4.2</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.4.6</version>
</dependency>三、新建ES配置，注入RestHighLevelClient 客戶端
@Configuration
public class ElasticSearchClientConfig {
@Bean
public RestHighLevelClient restHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("127.0.0.1",9200,"http"))
);
return client;
}
}四、測(cè)試索引API
@Autowired
@Qualifier("restHighLevelClient")
public RestHighLevelClient client;
@Test
void testCreateIndex() throws Exception{
//創(chuàng)建索引請(qǐng)求
CreateIndexRequest request = new CreateIndexRequest("xr_index");
//客戶端執(zhí)行請(qǐng)求，獲得響應(yīng)
CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(JSONUtil.toJsonStr(response));
}
//測(cè)試索引的是否存在
@Test
void testExistIndex() throws Exception {
GetIndexRequest request= new GetIndexRequest("xr_index");
boolean exist = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exist);
}
//刪除索引
@Test
void testDeleteIndex() throws Exception {
DeleteIndexRequest request= new DeleteIndexRequest("xr_index");
AcknowledgedResponse response = client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(JSONUtil.toJsonStr(response));
}五、測(cè)試測(cè)試文檔API
//添加文檔
@Test
void testAddDocument() throws Exception {
Map<String, String> hashMap = new HashMap<>();
hashMap.put("name","雪人");
hashMap.put("age","22");
//創(chuàng)建請(qǐng)求
IndexRequest request = new IndexRequest("bai_index");
//規(guī)則 put/bai_index/_doc/1
request.id("2");
request.timeout(TimeValue.timeValueSeconds(1));
//放入數(shù)據(jù)
request.source(JSONUtil.toJsonStr(hashMap), XContentType.JSON);
//發(fā)送請(qǐng)求
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
System.out.println(JSONUtil.toJsonStr(response));
}
//測(cè)試文檔是否存在
@Test
void testExitDocument() throws Exception{
GetRequest request = new GetRequest("xr_index", "2");
boolean exists = client.exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
//測(cè)試獲取文檔
@Test
void testGetDocument() throws Exception{
GetRequest request = new GetRequest("xr_index", "2");
GetResponse response = client.get(request, RequestOptions.DEFAULT);
System.out.println(response.getSourceAsString());
}
//測(cè)試修改文檔
@Test
void testUpdateDocument() throws Exception{
UpdateRequest request = new UpdateRequest("xr", "2");
request.timeout(TimeValue.timeValueSeconds(1));
Map<String, String> hashMap = new HashMap<>();
hashMap.put("name","獨(dú)自堆雪人");
hashMap.put("age","22");
request.doc(JSONUtil.toJsonStr(hashMap),XContentType.JSON);
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
System.out.println(JSONUtil.toJsonStr(response));
}
//測(cè)試刪除文檔
@Test
void testDeleteDocument() throws Exception {
DeleteRequest request= new DeleteRequest("獨(dú)自堆雪人","2");
request.timeout(TimeValue.timeValueSeconds(1));
DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
System.out.println(response.status());
}
//測(cè)試添加文檔
@Test
void testBulkAddDocument() throws Exception {
BulkRequest request = new BulkRequest();
request.timeout(TimeValue.timeValueSeconds(1));
List<Object> userlist=new ArrayList<>();
for (int i = 0; i < 10; i++) {
Map<String, String> hashMap = new HashMap<>();
hashMap.put("name","bai"+i);
hashMap.put("age",""+i);
userlist.add(hashMap);
}
//批量處理請(qǐng)求 （下面如果不設(shè)置id就會(huì)隨機(jī)生成一個(gè)id）
for (int i = 0; i < userlist.size(); i++) {
request.add(
new IndexRequest("bai_index")
.id(""+(i+1))
.source(JSONUtil.toJsonStr(userlist.get(i)),XContentType.JSON)
);
}
BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);
System.out.println(response.hasFailures());//返回false表示添加成功
}
//測(cè)試查詢文檔
@Test
void testSearchDocument() throws Exception {
SearchRequest request = new SearchRequest("bai_index");
//構(gòu)建搜索條件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.highlighter();
TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "bai1");
sourceBuilder.query(termQueryBuilder);
sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
request.source(sourceBuilder);
SearchResponse response = client.search(request, RequestOptions.DEFAULT);
System.out.println(JSONUtil.toJsonStr(response.getHits()));
System.out.println("=====================");
for (SearchHit documentFields : response.getHits().getHits()) {
System.out.println(documentFields.getSourceAsMap());
}
}注意ES版本與引入ES客戶端對(duì)應(yīng)，否則會(huì)出現(xiàn)一些api調(diào)用兼容問(wèn)題。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-522163.html
到了這里，關(guān)于Es集成Springboot的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
