网站admin后台界面模板,wordpress 压缩图片,西安招标网,论坛与网站做优化哪个更好六、SpringBoot整合ElasticSearch
1、浏览官方文档
1、查找跟ES客户端相关的文档 使用Java REST Client 选择Java Hight Level REST Client
2、创建项目的准备
1.找到原生的依赖 2.找到对象 3.分析这个类里面的方法
3、正式创建项目
1.创建工程 2.导入依赖
注意依赖版本…六、SpringBoot整合ElasticSearch
1、浏览官方文档
1、查找跟ES客户端相关的文档 使用Java REST Client 选择Java Hight Level REST Client
2、创建项目的准备
1.找到原生的依赖 2.找到对象 3.分析这个类里面的方法
3、正式创建项目
1.创建工程 2.导入依赖
注意依赖版本和安装的版本一致 propertiesjava.version1.8/java.version!-- 统一版本 --elasticsearch.version7.6.1/elasticsearch.version
/properties导入elasticsearch
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-elasticsearch/artifactId
/dependency提前导入fastjson、lombok
dependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion1.2.70/version
/dependency
!-- lombok需要安装插件 --
dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdoptionaltrue/optional
/dependency分析依赖
①导入的依赖使用的transport是6.8.6的版本太低需要重新导入 ②找到ES的版本的默认配置进行手动配置 ③自定义配置es版本依赖保证和本地的一致 ④查看重新导入的依赖 3.创建并编写配置类 Configuration
public class ElasticSearchConfig {// 注册 rest高级客户端 Beanpublic RestHighLevelClient restHighLevelClient(){RestHighLevelClient client new RestHighLevelClient(RestClient.builder(new HttpHost(127.0.0.1,9200,http)));return client;}
}分析源码(Au、PS) ①先找到Au自动配置类 ②先找到es目录查看包下的静态类 ③也可以在data目录下查找封装的所有方法类 ④核心配置类 4、创建并编写实体类
Data
NoArgsConstructor
AllArgsConstructor
public class User implements Serializable {private static final long serialVersionUID -3843548915035470817L;private String name;private Integer age;
}5、编写测试类 所有测试均在 SpringbootElasticsearchApplicationTests中编写 注入 RestHighLevelClient Autowired
public RestHighLevelClient restHighLevelClient;6、索引的操作
1索引的创建
// 测试索引的创建 Request PUT lbj_index
Test
public void testCreateIndex() throws IOException {CreateIndexRequest request new CreateIndexRequest(lbj_index);CreateIndexResponse response restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);System.out.println(response.isAcknowledged());// 查看是否创建成功System.out.println(response);// 查看返回对象restHighLevelClient.close();
}2索引的获取并判断其是否存在
// 测试获取索引并判断其是否存在
Test
public void testIndexIsExists() throws IOException {GetIndexRequest request new GetIndexRequest(index);boolean exists restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);System.out.println(exists);// 索引是否存在restHighLevelClient.close();
}3索引的删除
// 测试索引删除
Test
public void testDeleteIndex() throws IOException {DeleteIndexRequest request new DeleteIndexRequest(lbj_index);AcknowledgedResponse response restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);System.out.println(response.isAcknowledged());// 是否删除成功restHighLevelClient.close();
}7、文档的操作
1文档的添加 // 测试添加文档(先创建一个User实体类添加fastjson依赖)
Test
public void testAddDocument() throws IOException {// 创建一个User对象User lbj new User(lbj, 18);// 创建请求IndexRequest request new IndexRequest(lbj_index);// 制定规则 PUT /lbj_index/_doc/1request.id(1);// 设置文档IDrequest.timeout(TimeValue.timeValueMillis(1000));// request.timeout(1s)// 将我们的数据放入请求中request.source(JSON.toJSONString(lbj), XContentType.JSON);// 客户端发送请求获取响应的结果IndexResponse response restHighLevelClient.index(request, RequestOptions.DEFAULT);System.out.println(response.status());// 获取建立索引的状态信息 CREATEDSystem.out.println(response);// 查看返回内容 IndexResponse[indexlbj_index,type_doc,id1,version1,resultcreated,seqNo0,primaryTerm1,shards{total:2,successful:1,failed:0}]
}2文档信息的获取 // 测试获得文档信息
Test
public void testGetDocument() throws IOException {GetRequest request new GetRequest(lbj_index,1);GetResponse response restHighLevelClient.get(request, RequestOptions.DEFAULT);System.out.println(response.getSourceAsString());// 打印文档内容System.out.println(request);// 返回的全部内容和命令是一样的restHighLevelClient.close();
}3文档的获取并判断其是否存在 // 获取文档判断是否存在 get /lbj_index/_doc/1
Test
public void testDocumentIsExists() throws IOException {GetRequest request new GetRequest(lbj_index, 1);// 不获取返回的 _source的上下文了request.fetchSourceContext(new FetchSourceContext(false));request.storedFields(_none_);boolean exists restHighLevelClient.exists(request, RequestOptions.DEFAULT);System.out.println(exists);
}4文档的更新 // 测试更新文档内容
Test
public void testUpdateDocument() throws IOException {UpdateRequest request new UpdateRequest(lbj_index, 1);User user new User(lmk,11);request.doc(JSON.toJSONString(user),XContentType.JSON);UpdateResponse response restHighLevelClient.update(request, RequestOptions.DEFAULT);System.out.println(response.status()); // OKrestHighLevelClient.close();
}5文档的删除 // 测试删除文档
Test
public void testDeleteDocument() throws IOException {DeleteRequest request new DeleteRequest(lbj_index, 1);request.timeout(1s);DeleteResponse response restHighLevelClient.delete(request, RequestOptions.DEFAULT);System.out.println(response.status());// OK
}6批量添加数据
前面的操作都无法批量添加数据
// 上面的这些api无法批量增加数据只会保留最后一个source
Test
public void test() throws IOException {IndexRequest request new IndexRequest(bulk);// 没有id会自动生成一个随机IDrequest.source(JSON.toJSONString(new User(liu,1)),XContentType.JSON);request.source(JSON.toJSONString(new User(min,2)),XContentType.JSON);request.source(JSON.toJSONString(new User(kai,3)),XContentType.JSON);IndexResponse index restHighLevelClient.index(request, RequestOptions.DEFAULT);System.out.println(index.status());// created
}大数据情况下都是使用随机的id // 特殊的真的项目一般会 批量插入数据
Test
public void testBulk() throws IOException {BulkRequest bulkRequest new BulkRequest();bulkRequest.timeout(10s);ArrayListUser users new ArrayList();users.add(new User(lbj-1,1));users.add(new User(lbj-2,2));users.add(new User(lbj-3,3));users.add(new User(lbj-4,4));users.add(new User(lbj-5,5));users.add(new User(lbj-6,6));// 批量请求处理for (int i 0; i users.size(); i) {bulkRequest.add(// 这里是数据信息new IndexRequest(bulk).id((i 1)) // 没有设置id 会自定生成一个随机id.source(JSON.toJSONString(users.get(i)),XContentType.JSON));}BulkResponse bulk restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);System.out.println(bulk.status());// ok
}7文档的查询 // 查询
// SearchRequest 搜索请求
// SearchSourceBuilder 条件构造
// HighlightBuilder 高亮
// TermQueryBuilder 精确查询
// MatchAllQueryBuilder
// xxxQueryBuilder ...
Test
public void testSearch() throws IOException {// 1.创建查询请求对象SearchRequest searchRequest new SearchRequest();// 2.构建搜索条件SearchSourceBuilder searchSourceBuilder new SearchSourceBuilder();// (1)查询条件 使用QueryBuilders工具类创建// 精确查询TermQueryBuilder termQueryBuilder QueryBuilders.termQuery(name, lbj);// // 匹配查询// MatchAllQueryBuilder matchAllQueryBuilder QueryBuilders.matchAllQuery();// (2)其他可有可无可以参考 SearchSourceBuilder 的字段部分// 设置高亮searchSourceBuilder.highlighter(new HighlightBuilder());// // 分页// searchSourceBuilder.from();// searchSourceBuilder.size();searchSourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));// (3)条件投入searchSourceBuilder.query(termQueryBuilder);// 3.添加条件到请求searchRequest.source(searchSourceBuilder);// 4.客户端查询请求SearchResponse search restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);// 5.查看返回结果SearchHits hits search.getHits();System.out.println(JSON.toJSONString(hits));System.out.println();for (SearchHit documentFields : hits.getHits()) {System.out.println(documentFields.getSourceAsMap());}
}ElasticSearch-SpringBoot整合ElasticSearch 到此完结笔者归纳、创作不易大佬们给个3连再起飞吧
