ElasticSearch做分布式的搜索引擎练习
需要导入的pom文件
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.1.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--引入es的坐标-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.4.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.4.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.4.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.4</version>
</dependency>
</dependencies>
application.yaml文件
elasticsearch:
host: 127.0.0.1
port: 9200
启动类创建
package com.atguigu;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ElasticsearchDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ElasticsearchDemoApplication.class, args);
}
}
创建一个客户端的类
import lombok.Data;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Data
@Configuration
@ConfigurationProperties(prefix = "elasticsearch")
public class ElasticSearchConfig {
private Integer port;
private String host;
//注册一个客户端
@Bean
public RestHighLevelClient client(){
return new RestHighLevelClient(RestClient.builder(new HttpHost(host,port,"http")));
}
}
创建一个JavaBean对象
@Data
public class Person implements Serializable {
private Integer age;
private String name;
private String address;
// private Integer id;
}
创建一个测试类进行增删改查索引,文档,以及进行批量添加删除等操作
@SpringBootTest
@RunWith(SpringRunner.class)
public class ElasticSearchTest {
//导入客户端
@Autowired
private RestHighLevelClient client;
/**
* 创建索引
* @throws Exception
*/
@Test
public void test1()throws Exception{
//获取操作索引的对象
IndicesClient indices = client.indices();
//创建索引的请求
CreateIndexRequest request = new CreateIndexRequest("abc");
//利用索引的对象创建索引
CreateIndexResponse createIndexResponse = indices.create(request, RequestOptions.DEFAULT);
//创建完成返回结果
System.out.println(createIndexResponse.isAcknowledged());
}
/**
* 添加索引与映射
*/
@Test
public void test2()throws Exception{
//获取索引创建对象
IndicesClient indices = client.indices();
//创建请求
CreateIndexRequest indexRequest = new CreateIndexRequest("aaa");
//将映射放进请求
String mapping="{\n" +
" \"properties\" : {\n" +
" \"address\" : {\n" +
" \"type\" : \"text\",\n" +
" \"analyzer\" : \"ik_max_word\"\n" +
" },\n" +
" \"age\" : {\n" +
" \"type\" : \"long\"\n" +
" },\n" +
" \"name\" : {\n" +
" \"type\" : \"keyword\"\n" +
" }\n" +
" }\n" +
" }";
indexRequest.mapping(mapping, XContentType.JSON);
//创建索引以及映射
CreateIndexResponse createIndexResponse = indices.create(indexRequest, RequestOptions.DEFAULT);
System.out.println(createIndexResponse.isAcknowledged());
}
/**
* 查询索引
*/
@Test
public void test3()throws Exception{
//创建索引对象
IndicesClient indices = client.indices();
//创建查询索引请求
GetIndexRequest getIndexRequest = new GetIndexRequest("aaa");
//发送请求
GetIndexResponse indexResponse = indices.get(getIndexRequest, RequestOptions.DEFAULT);
//遍历请求的参数
Map<String, MappingMetaData> mappings = indexResponse.getMappings();
Set<Map.Entry<String, MappingMetaData>> entries = mappings.entrySet();
for (Map.Entry<String, MappingMetaData> entry : entries) {
System.out.println(entry.getKey());
System.out.println(mappings.get(entry.getKey()).getSourceAsMap());
}
}
/**
* 删除索引
*/
@Test
public void test4()throws Exception{
//创建操作索引的对象
IndicesClient indices = client.indices();
//创建删除索引请求
DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("abc");
//发送请求进行删除
AcknowledgedResponse delete = indices.delete(deleteIndexRequest, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
/**
* 判断索引是否存在
*/
@Test
public void test5()throws Exception{
IndicesClient indices = client.indices();
GetIndexRequest getIndexRequest = new GetIndexRequest("abc");
boolean exists = indices.exists(getIndexRequest, RequestOptions.DEFAULT);
System.out.println("exists = " + exists);
}
/**
* 添加文档数据
* @throws Exception
*/
@Test
public void test6()throws Exception{
//创建一个map集合存数据
Map map = new HashMap();
map.put("name","小红");
map.put("age",55);
map.put("address","佛山");
//获取文档对象并添加数据
IndexRequest indexRequest = new IndexRequest("aaa").id("1").source(map);
//利用客户端发送请求
IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
System.out.println(indexResponse.getId());
}
/**
* 利用JavaBean发送请求创建文档/修改文档
*/
@Test
public void test7()throws Exception{
Person person = new Person();
person.setAddress("北京");
person.setAge(56);
person.setName("小亮");
// person.setId(2);
//将对象转成json格式
String s = JSON.toJSONString(person);
// 创建文档对象并添加数据
IndexRequest indexRequest = new IndexRequest("aaa").id("3").source(s,XContentType.JSON);
//发送请求
IndexResponse index = client.index(indexRequest, RequestOptions.DEFAULT);
System.out.println(index.getId());
}
/**
* 利用id进行查询
* @throws Exception
*/
@Test
public void test8()throws Exception{
//创建查询id请求
GetRequest getRequest = new GetRequest("aaa", "2");
//发送请求
GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);
String sourceAsString = response.getSourceAsString();
System.out.println( sourceAsString);
}
/**
* 删除文档
* @throws Exception
*/
@Test
public void test9()throws Exception{
//创建删除请求
DeleteRequest deleteRequest = new DeleteRequest("aaa", "2");
DeleteResponse response = client.delete(deleteRequest, RequestOptions.DEFAULT);
System.out.println(response.getId());
}
/**
* 批量操作
* @throws Exception
*/
@Test
public void test10()throws Exception{
//创建绑定对象请求
BulkRequest bulkRequest = new BulkRequest();
//创建增删改的请求
Person person = new Person();
person.setName("小米");
person.setAge(33);
person.setAddress("天津");
String string1 = JSON.toJSONString(person);
IndexRequest put = new IndexRequest("aaa").id("2").source(string1,XContentType.JSON);
bulkRequest.add(put);
DeleteRequest deleteRequest = new DeleteRequest("aaa", "1");
bulkRequest.add(deleteRequest);
/*
Person person1 = new Person();
person.setName("小黄");
String string = JSON.toJSONString(person1);*/
Map map=new HashMap();
map.put("name","小黄");
UpdateRequest updateRequest = new UpdateRequest("aaa", "3").doc(map);
bulkRequest.add(updateRequest);
BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(bulk.status());
}
}
