网站制作是不是要一个后台,asp用什么软件编写,鲜花销售网站模板,营销式网站一 SpringBoot Elasticsearch 项目环境搭建
1.1 修改pom文件添加依赖
目前使用spring-boot-starter-parent版本为2.2.8.RELEASE
对应spring-data-elasticsearch版本为2.2.8.RELEASE#xff0c;版本对应可以自行百度#xff0c;如果不行直接用elasticsearch-rest-high-lev…一 SpringBoot Elasticsearch 项目环境搭建
1.1 修改pom文件添加依赖
目前使用spring-boot-starter-parent版本为2.2.8.RELEASE
对应spring-data-elasticsearch版本为2.2.8.RELEASE版本对应可以自行百度如果不行直接用elasticsearch-rest-high-level-client工具类吧 dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-elasticsearch/artifactIdversion2.2.8.RELEASE/version/dependencydependencygroupIdorg.elasticsearch/groupIdartifactIdelasticsearch/artifactIdversion7.5.0/version/dependencydependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-client/artifactIdversion7.5.0/version/dependencydependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion7.5.0/version/dependency1.2 新建配置文件
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;/*** ES配置类** author lc* version 1.0* date 2022/3/25 10:53*/
Configuration
public class ElasticSearchClientConfig {Beanpublic RestHighLevelClient restHighLevelClient() {RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(192.168.1.100, 9200, http)));return client;}
}二 RestHighLevelClient的使用
RestHighLevelClient是Elasticsearch 的操作方法我们先进行引用吧。
Autowired
private RestHighLevelClient client;1、创建索引 Testvoid testCreateIndex() throws IOException {//1 创建索引请求CreateIndexRequest request new CreateIndexRequest(zlc_index);//2 客户端执行请求CreateIndexResponse createIndexResponse client.indices().create(request, RequestOptions.DEFAULT);System.out.println(createIndexResponse);}2、索引是否存在
Testvoid testExistIndex() throws IOException {GetIndexRequest request new GetIndexRequest(zlc_index);boolean exists client.indices().exists(request, RequestOptions.DEFAULT);System.out.println(exists);}3、删除索引
Testvoid testDeleteIndex() throws IOException {DeleteIndexRequest request new DeleteIndexRequest(zlc_index);AcknowledgedResponse delete client.indices().delete(request, RequestOptions.DEFAULT);System.out.println(delete.isAcknowledged());}4、添加文档
Testvoid testAddDocument() throws IOException {//创建对象UserES user new UserES();user.setUserName(suwerw);user.setUserPhone(178245774);//创建请求IndexRequest request new IndexRequest(zlc_index);//规则 put /zlc_index/_doc/1request.id(1);request.timeout(TimeValue.timeValueSeconds(1));request.timeout(1s);//将数据放入请求request.source(JSON.toJSONString(user), XContentType.JSON);//客户端发送请求获取响应结果IndexResponse indexResponse client.index(request, RequestOptions.DEFAULT);System.out.println(indexResponse.toString());System.out.println(indexResponse.status());}5、判断文档是否存在
Testvoid testIsExists() throws IOException {GetRequest getRequest new GetRequest(zlc_index, 1);//不获取返回的 _source 的上下文提高效率getRequest.fetchSourceContext(new FetchSourceContext(false));getRequest.storedFields(_none_);boolean exists client.exists(getRequest, RequestOptions.DEFAULT);System.out.println(exists);}6、获取文档 Testvoid testGetDocument() throws IOException {GetRequest getRequest new GetRequest(zlc_index, 1);GetResponse getResponse client.get(getRequest, RequestOptions.DEFAULT);System.out.println(getResponse);System.out.println(getResponse.getSourceAsString());}7、更新文档信息 Testvoid testUpdateDocument() throws IOException {UpdateRequest updateRequest new UpdateRequest(zlc_index, 1);updateRequest.timeout(1s);UserES user new UserES();user.setUserName(Zhou_LC);user.setUserPhone(233669);updateRequest.doc(JSON.toJSONString(user), XContentType.JSON);UpdateResponse updateResponse client.update(updateRequest, RequestOptions.DEFAULT);System.out.println(updateResponse);System.out.println(updateResponse.status());}8、删除文档 Testvoid testDeleteDocument() throws IOException {DeleteRequest deleteRequest new DeleteRequest(zlc_index, 1);deleteRequest.timeout(1s);DeleteResponse deleteResponse client.delete(deleteRequest, RequestOptions.DEFAULT);System.out.println(deleteResponse);System.out.println(deleteResponse.status());}
