springboot+ElasticSearch入门
1、使用STS构建项目
2、修改EL的版本
<properties>
<java.version>1.8</java.version>
<elasticsearch.version>7.10.1</elasticsearch.version>
</properties>
增加fastjson
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.62</version>
</dependency>
3、配置EL
ElasticSearchClientConfig.java
package com.asia.config;
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("127.0.0.1", 9200, "http")));
return client;
}
}
4、User实体类
package com.asia.pojo;
import org.springframework.stereotype.Component;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Component
public class User {
private String name;
private int age;
}
5、常量类
package com.asia.utils;
public class ESConst {
public static final String ES_INDEX="kuang_index";
}
6、EL API接口测试
package com.asia;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.MatchAllQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import com.alibaba.fastjson.JSON;
import com.asia.pojo.User;
import com.asia.utils.ESConst;
@SpringBootTest
class SpringbootEsApiApplicationTests {
@Autowired
@Qualifier("restHighLevelClient")
RestHighLevelClient client;
// 创建索引
@Test
void testCreateIndex() throws IOException {
CreateIndexRequest request = new CreateIndexRequest(ESConst.ES_INDEX);
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse);
}
// 判断索引是否存在
@Test
void testExistIndex() throws IOException {
GetIndexRequest request = new GetIndexRequest(ESConst.ES_INDEX);
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
// 删除索引
@Test
void testDelIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest(ESConst.ES_INDEX);
AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
// 添加文档
@Test
void testAddDocument() throws IOException {
User user = new User("狂神说", 3);
IndexRequest request = new IndexRequest(ESConst.ES_INDEX);
request.id("1");
request.source(JSON.toJSONString(user), XContentType.JSON);
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
System.out.println(response.toString());
System.out.println(response.status());
}
// 获取文档
@Test
void testIsExists() throws IOException {
GetRequest request = new GetRequest(ESConst.ES_INDEX, "1");
request.fetchSourceContext(new FetchSourceContext(false));
request.storedFields("_none_");
boolean exists = client.exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
// 获取文档信息
@Test
void testGetDoc() throws IOException {
GetRequest request = new GetRequest(ESConst.ES_INDEX, "1");
GetResponse response = client.get(request, RequestOptions.DEFAULT);
System.out.println(response.getSourceAsString());
System.out.println(response);
}
// 更新文档
@Test
void testUpdateDoc() throws IOException {
UpdateRequest request = new UpdateRequest(ESConst.ES_INDEX, "1");
User user = new User("Java", 18);
request.doc(JSON.toJSONString(user), XContentType.JSON);
UpdateResponse response = client.update(request, RequestOptions.DEFAULT);
System.out.println(response.status());
}
// 删除文档
@Test
void testDelDoc() throws IOException {
DeleteRequest request = new DeleteRequest(ESConst.ES_INDEX, "1");
DeleteResponse delete = client.delete(request, RequestOptions.DEFAULT);
System.out.println(delete);
}
// 批量添加文档
@Test
void testBulkAddDoc() throws IOException {
BulkRequest request = new BulkRequest();
List<User> list = new ArrayList<User>();
list.add(new User("kuangshen1", 2));
list.add(new User("kuangshen2", 2));
list.add(new User("kuangshen3", 2));
list.add(new User("kuangshen4", 2));
list.add(new User("kuangshen5", 2));
list.add(new User("kuangshen6", 2));
list.add(new User("kuangshen7", 2));
list.add(new User("kuangshen8", 2));
list.add(new User("kuangshen9", 2));
list.add(new User("kuangshen10", 2));
for (int i = 0; i < list.size(); i++) {
// 批量更新+批量删除-在此变更即可
request.add(new IndexRequest(ESConst.ES_INDEX).id("" + (i + 1)).source(JSON.toJSONString(list.get(i)),
XContentType.JSON));
}
BulkResponse bulk = client.bulk(request, RequestOptions.DEFAULT);
System.out.println(bulk.hasFailures());// 是否失败
}
// 查询
// SearchRequest 搜索请求
// SearchSourceBuilder 条件构造
// HighLightBuilder 构建高亮
// TermQueryBuilder 精确查询
// MatchAllQueryBuilder 全部查询
// xxxQueryBuilder 对应命令
@Test
void testSearch() throws IOException {
SearchRequest reqeust = new SearchRequest(ESConst.ES_INDEX);
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
// 查询条件-精确查询
TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "kuangshen8");
// 查询所有
// MatchAllQueryBuilder matchAllQuery = QueryBuilders.matchAllQuery();
sourceBuilder.query(termQueryBuilder);
// 构建请求
reqeust.source(sourceBuilder);
SearchResponse search = client.search(reqeust, RequestOptions.DEFAULT);
System.out.println(JSON.toJSONString(search.getHits()));
System.out.println("======================");
for (SearchHit documentFields : search.getHits().getHits()) {
System.out.println(documentFields.getSourceAsMap());
}
}
}
特别鸣谢:狂神说Java,跟着狂神学EL,边学边记。