ElasticSearch-整合Java High Level REST Client  测试

导入依赖

导入pom文件 依据自己版本 <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>7.4.2</version> </dependency> 设置版本 <properties> <java.version>1.8</java.version> <elasticsearch.version>7.4.2</elasticsearch.version> </properties> //新建配置类 并设置Client和指定端口号 @Configuration public class GulimallElasticSearchConfig { @Bean //放到容器中 public RestHighLevelClient esRestClient(){ RestHighLevelClient client = new RestHighLevelClient( RestClient.builder( new HttpHost("192.168.56.10", 9200, "http"))); return client; } }

操作文档 https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-high.html

GulimallElasticSearchConfig

@Configuration public class GulimallElasticSearchConfig { public static final RequestOptions COMMON_OPTIONS; static { RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder(); //builder.addHeader("Authorization", "Bearer " + TOKEN); //builder.setHttpAsyncResponseConsumerFactory( // new HttpAsyncResponseConsumerFactory // .HeapBufferedResponseConsumerFactory(30 * 1024 * 1024 * 1024)); COMMON_OPTIONS = builder.build(); } @Bean //放到容器中 public RestHighLevelClient esRestClient(){ RestHighLevelClient client = new RestHighLevelClient( RestClient.builder( new HttpHost("192.168.56.10", 9200, "http"))); return client; } }

测试简单索引

@Autowired private RestHighLevelClient client;

@Test //测试es 存储数据 public void indexData() throws IOException { IndexRequest indexRequest = new IndexRequest("users"); indexRequest.id("1"); User user = new User(); user.setUserName("咱三"); user.setAge(18); user.setGender("男"); String jsonString = JSON.toJSONString(user);//转换String类型 indexRequest.source(jsonString, XContentType.JSON);//保存内容 //执行操作 IndexResponse index = client.index(indexRequest, GulimallElasticSearchConfig.COMMON_OPTIONS); // System.out.println(index); }

测试复杂

@Test //复杂检索测试 public void searchData() throws IOException { //1.创建索引请求 SearchRequest searchRequest = new SearchRequest(); //2.指定索引 searchRequest.indices("bank"); //指定DSL检索条件 SearchSourceBuilder 封装的全部检索 SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); sourceBuilder.query(QueryBuilders.matchQuery("address", "mill")); //年龄聚合 TermsAggregationBuilder ageAgg = AggregationBuilders.terms("ageAgg").field("age").size(10); sourceBuilder.aggregation(ageAgg); //计算平均薪资 AvgAggregationBuilder balanceAvg = AggregationBuilders.avg("balanceAvg").field("balance"); sourceBuilder.aggregation(balanceAvg); System.out.println("检索条件" + sourceBuilder.toString()); searchRequest.source(sourceBuilder); //执行检索 SearchResponse searchResponse = client.search(searchRequest, GulimallElasticSearchConfig.COMMON_OPTIONS); //分析结果 System.out.println("检索结果" + searchResponse.toString()); //封装成map 数据从map中获取 //Map map = JSON.parseObject(searchResponse.toString(), Map.class); //获取所有查到的数据？ 先拿到外边的hits SearchHits hits = searchResponse.getHits(); //拿到里面真是的hits SearchHit[] searchHits = hits.getHits(); for (SearchHit hit : searchHits) { //getSource转为string String string = hit.getSourceAsString(); //json转对象 把string转换成Accout.class类型的对象 Accout accout = JSON.parseObject(string, Accout.class); System.out.println("accout" + accout); } //获取聚合信息 Aggregations aggregations = searchResponse.getAggregations(); //将聚合信息都做成list 在增强for //for (Aggregation aggregation : aggregations.asList()) { // aggregation.getName(); //} //获取ageAgg 并转换 Terms Terms ageAgg1 = aggregations.get("ageAgg"); for (Terms.Bucket bucket : ageAgg1.getBuckets()) { String keyAsString = bucket.getKeyAsString(); System.out.println("年龄" + keyAsString + "--->" + bucket.getDocCount()); } //balanceAvg 并转换 Avg Avg balanceAvg1 = aggregations.get("balanceAvg"); double value = balanceAvg1.getValue(); System.out.println("平均薪资" + value); }