<em>Mac</em>Book项目 2009年学校开始实施<em>Mac</em>Book项目,所有师生配备一本<em>Mac</em>Book,并同步更新了校园无线网络。学校每周进行电脑技术更新,每月发送技术支持资料,极大改变了教学及学习方式。因此2011
2021-06-01 09:32:01
springboot2+es7使用RestHighLevelClient的範例程式碼
2022-07-01 14:00:43
由於spring和es的整合並不是特別友好，es的高低版本相容問題、api更新頻率高等問題，所以我選擇是官網提供的原生Client(RestHighLevelClient)，但又不想去關注es的設定類以及和spring的整合設定、jar包衝突等問題，所以使用spring-boot-starter-data-elasticsearch。
一、引入依賴jar
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency>
二、application.properties設定
spring.elasticsearch.rest.uris=http://127.0.0.1:9200,http://127.0.0.1:9201,http://127.0.0.1:9202 spring.elasticsearch.rest.connection-timeout=5s spring.elasticsearch.rest.read-timeout=30s logging.level.org.springframework.data.convert.CustomConversions=error
spring-boot-starter-data-elasticsearch中自動裝配es的設定類：ElasticsearchRestClientAutoConfiguration、ElasticsearchRestClientProperties。
ElasticsearchRestClientAutoConfiguration：
@ConditionalOnClass({RestHighLevelClient.class})
@ConditionalOnMissingBean({RestClient.class})
@EnableConfigurationProperties({ElasticsearchRestClientProperties.class})
public class ElasticsearchRestClientAutoConfiguration {
@Configuration(
proxyBeanMethods = false
)
@ConditionalOnMissingBean({RestHighLevelClient.class})
static class RestHighLevelClientConfiguration {
RestHighLevelClientConfiguration() {
}
@Bean
RestHighLevelClient elasticsearchRestHighLevelClient(RestClientBuilder restClientBuilder) {
return new RestHighLevelClient(restClientBuilder);
}
}
@Configuration(
proxyBeanMethods = false
)
@ConditionalOnMissingBean({RestClientBuilder.class})
static class RestClientBuilderConfiguration {
RestClientBuilderConfiguration() {
}
@Bean
RestClientBuilderCustomizer defaultRestClientBuilderCustomizer(ElasticsearchRestClientProperties properties) {
return new ElasticsearchRestClientAutoConfiguration.DefaultRestClientBuilderCustomizer(properties);
}
@Bean
RestClientBuilder elasticsearchRestClientBuilder(ElasticsearchRestClientProperties properties, ObjectProvider<RestClientBuilderCustomizer> builderCustomizers) {
HttpHost[] hosts = (HttpHost[])properties.getUris().stream().map(this::createHttpHost).toArray((x$0) -> {
return new HttpHost[x$0];
});
RestClientBuilder builder = RestClient.builder(hosts);
builder.setHttpClientConfigCallback((httpClientBuilder) -> {
builderCustomizers.orderedStream().forEach((customizer) -> {
customizer.customize(httpClientBuilder);
});
return httpClientBuilder;
});
builder.setRequestConfigCallback((requestConfigBuilder) -> {
builderCustomizers.orderedStream().forEach((customizer) -> {
customizer.customize(requestConfigBuilder);
});
return requestConfigBuilder;
});
builderCustomizers.orderedStream().forEach((customizer) -> {
customizer.customize(builder);
});
return builder;
}
private HttpHost createHttpHost(String uri) {
try {
return this.createHttpHost(URI.create(uri));
} catch (IllegalArgumentException var3) {
return HttpHost.create(uri);
}
}
private HttpHost createHttpHost(URI uri) {
if (!StringUtils.hasLength(uri.getUserInfo())) {
return HttpHost.create(uri.toString());
} else {
try {
return HttpHost.create((new URI(uri.getScheme(), (String)null, uri.getHost(), uri.getPort(), uri.getPath(), uri.getQuery(), uri.getFragment())).toString());
} catch (URISyntaxException var3) {
throw new IllegalStateException(var3);
}
}
}
}
}ElasticsearchRestClientProperties：
@ConfigurationProperties(
prefix = "spring.elasticsearch.rest"
)
public class ElasticsearchRestClientProperties {
private List<String> uris = new ArrayList(Collections.singletonList("http://localhost:9200"));
private String username;
private String password;
private Duration connectionTimeout = Duration.ofSeconds(1L);
private Duration readTimeout = Duration.ofSeconds(30L);
public ElasticsearchRestClientProperties() {
}
public List<String> getUris() {
return this.uris;
}
public void setUris(List<String> uris) {
this.uris = uris;
}
public String getUsername() {
return this.username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return this.password;
}
public void setPassword(String password) {
this.password = password;
}
public Duration getConnectionTimeout() {
return this.connectionTimeout;
}
public void setConnectionTimeout(Duration connectionTimeout) {
this.connectionTimeout = connectionTimeout;
}
public Duration getReadTimeout() {
return this.readTimeout;
}
public void setReadTimeout(Duration readTimeout) {
this.readTimeout = readTimeout;
}
}三、使用
ES基本操作持久層
/**
* es持久層
*
* @author yangzihe
* @date 2022/1/24
*/
@Repository
@Slf4j
public class EsRepository {
@Resource
private RestHighLevelClient highLevelClient;
/**
* 判斷索引是否存在
*/
public boolean existIndex(String index) {
try {
return highLevelClient.indices().exists(new GetIndexRequest(index), RequestOptions.DEFAULT);
} catch (IOException e) {
log.error("es持久層異常！index={}", index, e);
}
return Boolean.FALSE;
}
/**
* 建立索引
*/
public boolean createIndex(String index, Map<String, Object> columnMap) {
if (existIndex(index)) {
return Boolean.FALSE;
}
CreateIndexRequest request = new CreateIndexRequest(index);
if (columnMap != null && columnMap.size() > 0) {
Map<String, Object> source = new HashMap<>();
source.put("properties", columnMap);
request.mapping(source);
}
try {
highLevelClient.indices().create(request, RequestOptions.DEFAULT);
return Boolean.TRUE;
} catch (IOException e) {
log.error("es持久層異常！index={}, columnMap={}", index, columnMap, e);
}
return Boolean.FALSE;
}
/**
* 刪除索引
*/
public boolean deleteIndex(String index) {
try {
if (existIndex(index)) {
AcknowledgedResponse response = highLevelClient.indices().delete(new DeleteIndexRequest(index), RequestOptions.DEFAULT);
return response.isAcknowledged();
}
} catch (Exception e) {
log.error("es持久層異常！index={}", index, e);
}
return Boolean.FALSE;
}
/**
* 資料新增
*/
public boolean insert(String index, String jsonString) {
IndexRequest indexRequest = new IndexRequest(index);
indexRequest.id(new Snowflake().nextIdStr());
indexRequest.source(jsonString, XContentType.JSON);
try {
log.info("indexRequest={}", indexRequest);
IndexResponse indexResponse = highLevelClient.index(indexRequest, RequestOptions.DEFAULT);
log.info("indexResponse={}", indexResponse);
return Boolean.TRUE;
} catch (IOException e) {
log.error("es持久層異常！index={}, jsonString={}", index, jsonString, e);
}
return Boolean.FALSE;
}
/**
* 資料更新，可以直接修改索引結構
*/
public boolean update(String index, Map<String, Object> dataMap) {
UpdateRequest updateRequest = new UpdateRequest(index, dataMap.remove("id").toString());
updateRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
updateRequest.doc(dataMap);
try {
highLevelClient.update(updateRequest, RequestOptions.DEFAULT);
} catch (IOException e) {
log.error("es持久層異常！index={}, dataMap={}", index, dataMap, e);
return Boolean.FALSE;
}
return Boolean.TRUE;
}
/**
* 刪除資料
*/
public boolean delete(String index, String id) {
DeleteRequest deleteRequest = new DeleteRequest(index, id);
try {
highLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);
} catch (IOException e) {
log.error("es持久層異常！index={}, id={}", index, id, e);
return Boolean.FALSE;
}
return Boolean.TRUE;
}
}ES查詢持久層
/**
* es查詢持久層
*
* @author yangzihe
* @date 2022/1/25
*/
@Repository
@Slf4j
public class EsSearchRepository {
@Resource
private RestHighLevelClient highLevelClient;
/**
* 分頁查詢
*
* @param queryPO 分頁查詢物件
*
* @return 分頁查詢結果
*/
public EsQueryRespPO<Map<String, Object>> searchPage(EsQueryReqPO queryPO) {
// 預設分頁引數設定
if (queryPO.getPageNum() == null) {
queryPO.setPageNum(1);
}
if (queryPO.getPageSize() == null) {
queryPO.setPageSize(10);
}
// 設定索引
SearchRequest searchRequest = new SearchRequest(queryPO.getIndex());
// 封裝查詢源物件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
searchRequest.source(sourceBuilder);
// 查詢條件
sourceBuilder.query(queryPO.getQuery());
// 排序欄位
if (StringUtils.isNotBlank(queryPO.getSortField()) && queryPO.getSort() != null) {
FieldSortBuilder order = new FieldSortBuilder(queryPO.getSortField()).order(queryPO.getSort());
sourceBuilder.sort(order);
}
// 開始行數，預設0
sourceBuilder.from((queryPO.getPageNum() - 1) * queryPO.getPageSize());
// 頁大小，預設10
sourceBuilder.size(queryPO.getPageSize());
// 查詢結果
SearchResponse searchResponse = null;
try {
// log.info("es查詢請求物件：searchRequest={}", searchRequest);
log.info("es查詢請求物件source：sourceBuilder={}", searchRequest.source());
// 執行搜尋
searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);
log.info("es查詢響應結果：searchResponse={}", searchResponse);
} catch (IOException e) {
log.error("es查詢，IO異常！searchRequest={}", searchRequest, e);
// 例外處理
return EsQueryRespPO.error("es查詢，IO異常！");
}
if (RestStatus.OK.equals(searchResponse.status())) {
// 解析物件
SearchHit[] hits = searchResponse.getHits().getHits();
// 獲取source
List<Map<String, Object>> sourceList = Arrays.stream(hits).map(SearchHit::getSourceAsMap).collect(Collectors.toList());
long totalHits = searchResponse.getHits().getTotalHits().value;
return EsQueryRespPO.success(sourceList, queryPO.getPageNum(), queryPO.getPageSize(), totalHits);
} else {
log.error("es查詢返回的狀態碼異常！searchResponse.status={}, searchRequest={}", searchResponse.status(), searchRequest);
return EsQueryRespPO.error("es查詢返回的狀態碼異常！");
}
}
/**
* 聚合的分頁查詢
*
* @param queryPO 查詢請求物件
*
* @return 聚合分頁查詢結果
*/
public EsQueryRespPO<AggregationBucketPO> searchAggregation(EsQueryReqPO queryPO) {
// 設定索引
SearchRequest searchRequest = new SearchRequest(queryPO.getIndex());
// 封裝查詢源物件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
searchRequest.source(sourceBuilder);
// 查詢條件
sourceBuilder.query(queryPO.getQuery());
// 排序欄位
if (StringUtils.isNotBlank(queryPO.getSortField()) && queryPO.getSort() != null) {
FieldSortBuilder order = new FieldSortBuilder(queryPO.getSortField()).order(queryPO.getSort());
sourceBuilder.sort(order);
}
// 頁大小0，只返回聚合結果
sourceBuilder.size(0);
// 設定聚合查詢,可以設定多個聚合查詢條件，只要聚合查詢命名不同就行
// 聚合分組條件, group by
sourceBuilder.aggregation(queryPO.getTermsAggregation());
// 聚合統計條件, count分組後的資料，計算分組後的總大小
sourceBuilder.aggregation(queryPO.getCardinalityAggregation());
// 查詢結果
SearchResponse searchResponse = null;
try {
// log.info("es查詢請求物件：searchRequest={}", searchRequest);
log.info("es查詢請求物件source：sourceBuilder={}", searchRequest.source());
// 執行搜尋
searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);
log.info("es查詢響應結果：searchResponse={}", searchResponse);
} catch (IOException e) {
log.error("es查詢，IO異常！searchRequest={}", searchRequest, e);
return EsQueryRespPO.error("es查詢，IO異常！");
}
if (RestStatus.OK.equals(searchResponse.status())) {
// 解析物件
Aggregations aggregations = searchResponse.getAggregations();
long docTotal = searchResponse.getHits().getTotalHits().value;
// 遍歷terms聚合結果
Terms terms = aggregations.get(queryPO.getTermsAggregation().getName());
List<AggregationBucketPO> bucketList = terms.getBuckets().stream().map(bucket -> {
String key = bucket.getKeyAsString();
long docCount = bucket.getDocCount();
return new AggregationBucketPO(key, docCount, docTotal);
}).collect(Collectors.toList());
// 總數量
Cardinality cardinality = aggregations.get(queryPO.getCardinalityAggregation().getName());
long totalHits = cardinality.getValue();
return EsQueryRespPO.success(bucketList, queryPO.getPageNum(), queryPO.getPageSize(), totalHits);
} else {
log.error("es查詢返回的狀態碼異常！searchResponse.status={}, searchRequest={}", searchResponse.status(), searchRequest);
return EsQueryRespPO.error("es查詢返回的狀態碼異常！");
}
}
}其中，EsQueryReqPO、EsQueryRespPO、AggregationBucketPO等類如下：
/**
* es查詢請求物件
*/
@Data
public class EsQueryReqPO {
/**
* 索引名
*/
String[] index;
/**
* 查詢條件
*/
QueryBuilder query;
/**
* 排序欄位
*/
String sortField;
/**
* 排序方式 SortOrder.ASC、SortOrder.DESC
*/
SortOrder sort;
/**
* 頁數
*/
private Integer pageNum;
/**
* 頁大小
*/
private Integer pageSize;
/**
* 聚合分組條件, group by
*/
private TermsAggregationBuilder termsAggregation;
/**
* 聚合統計條件, count分組後的資料
*/
private CardinalityAggregationBuilder cardinalityAggregation;
}
/**
* es分頁響應物件
*
* @author yangzihe
* @date 2022/1/25
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class EsQueryRespPO<T> {
/**
* 是否成功
*/
private Boolean success;
/**
* 資訊
*/
private String message;
/**
* 頁數
*/
private Integer pageNum;
/**
* 頁大小
*/
private Integer pageSize;
/**
* 總大小
*/
private Long totalSize;
/**
* 資料
*/
private List<T> sourceList;
public static <T> EsQueryRespPO<T> success(List<T> sourceList, Integer pageNum, Integer pageSize,
Long totalSize) {
EsQueryRespPO<T> esQueryRespPO = new EsQueryRespPO<>();
esQueryRespPO.setSuccess(true);
esQueryRespPO.setSourceList(sourceList);
esQueryRespPO.setPageNum(pageNum);
esQueryRespPO.setPageSize(pageSize);
esQueryRespPO.setTotalSize(totalSize);
return esQueryRespPO;
}
public static EsQueryRespPO error() {
EsQueryRespPO esQueryRespPO = new EsQueryRespPO();
esQueryRespPO.setSuccess(false);
esQueryRespPO.setMessage("es查詢異常");
return esQueryRespPO;
}
public static EsQueryRespPO error(String message) {
EsQueryRespPO esQueryRespPO = new EsQueryRespPO();
esQueryRespPO.setSuccess(false);
esQueryRespPO.setMessage(message);
return esQueryRespPO;
}
}/**
* 聚合桶物件
*
* @author yangzihe
* @date 2022/1/26
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class AggregationBucketPO {
/**
* 聚合Bucket的key名
*/
private String key;
/**
* 聚合Bucket的檔案數量
*/
private Long docCount;
/**
* 檔案總數量
*/
private Long docTotal;
}ES多級(二級)聚合分桶查詢
import com.yy.armor.manager.common.exception.EsException;
import com.yy.armor.manager.persist.es.po.AggregationBucketPO;
import com.yy.armor.manager.persist.es.po.EsMultiAggregationReqPO;
import java.io.IOException;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.pulsar.shade.org.apache.commons.compress.utils.Lists;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.rest.RestStatus;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.FieldSortBuilder;
import org.springframework.stereotype.Repository;
@Repository
@Slf4j
public class EsSearchRepository {
@Resource
private RestHighLevelClient highLevelClient;
/**
* 多級聚合查詢(二級聚合)
*
* @param reqPO 查詢請求物件
*
* @return 聚合查詢結果
*/
public List<AggregationBucketPO> searchMultiAggregation(EsMultiAggregationReqPO reqPO) {
// 設定索引
SearchRequest searchRequest = new SearchRequest(reqPO.getIndex());
// 封裝查詢源物件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
searchRequest.source(sourceBuilder);
// 查詢條件
sourceBuilder.query(reqPO.getQuery());
// 排序欄位
if (StringUtils.isNotBlank(reqPO.getSortField()) && reqPO.getSort() != null) {
FieldSortBuilder order = new FieldSortBuilder(reqPO.getSortField()).order(reqPO.getSort());
sourceBuilder.sort(order);
}
// 頁大小0，只返回聚合結果
sourceBuilder.size(0);
// 聚合分桶。建立terms桶聚合，聚合名字=terms_by_XXX, 欄位=XXX
TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders.terms("terms_by_" + reqPO.getField()).field(reqPO.getField());
if (reqPO.getFieldSize() != null) {
termsAggregationBuilder.size(reqPO.getFieldSize());
}
// 二級聚合分桶
TermsAggregationBuilder subTermsAggregationBuilder = AggregationBuilders.terms("terms_by_" + reqPO.getSubField()).field(reqPO.getSubField());
if (reqPO.getSubFieldSize() != null) {
subTermsAggregationBuilder.size(reqPO.getSubFieldSize());
}
termsAggregationBuilder.subAggregation(subTermsAggregationBuilder);
// 聚合分組條件
sourceBuilder.aggregation(termsAggregationBuilder);
// 查詢結果
SearchResponse searchResponse = null;
try {
log.info("es查詢請求物件source：sourceBuilder={}", searchRequest.source());
// 執行搜尋
searchResponse = highLevelClient.search(searchRequest, RequestOptions.DEFAULT);
log.info("es查詢響應結果：searchResponse={}", searchResponse);
} catch (IOException e) {
log.error("es查詢，IO異常！searchRequest={}", searchRequest, e);
throw new EsException("es查詢，IO異常！");
}
if (RestStatus.OK.equals(searchResponse.status())) {
// 遍歷terms聚合結果
Terms terms = searchResponse.getAggregations().get(termsAggregationBuilder.getName());
List<AggregationBucketPO> bucketList = terms.getBuckets().stream().map(bucket -> {
// 一級聚合分桶的資料
String key = bucket.getKeyAsString();
long docCount = bucket.getDocCount();
// 二級聚合分桶的資料
Terms subTerms = bucket.getAggregations().get(subTermsAggregationBuilder.getName());
List<AggregationBucketPO> subBucketList = convertTerms(subTerms);
return new AggregationBucketPO(key, docCount, subBucketList);
}).collect(Collectors.toList());
return bucketList;
} else {
log.error("es查詢返回的狀態碼異常！searchResponse.status={}, searchRequest={}", searchResponse.status(), searchRequest);
throw new EsException("es查詢返回的狀態碼異常！");
}
}
private List<AggregationBucketPO> convertTerms(Terms terms) {
if (CollectionUtils.isEmpty(terms.getBuckets())) {
return Lists.newArrayList();
}
return terms.getBuckets().stream().map(bucket -> {
String key = bucket.getKeyAsString();
long docCount = bucket.getDocCount();
return new AggregationBucketPO(key, docCount);
}).collect(Collectors.toList());
}
}其中，EsMultiAggregationReqPO、AggregationBucketPO類如下：
@Data
public class EsMultiAggregationReqPO {
/**
* 索引名
*/
String[] index;
/**
* 查詢條件
*/
QueryBuilder query;
/**
* 聚合分桶欄位
*/
private String field;
/**
* 二級聚合分桶欄位
*/
private String subField;
/**
* 聚合分桶大小，非必傳
*/
private Integer fieldSize;
/**
* 二級聚合分桶大小，非必傳
*/
private Integer subFieldSize;
/**
* 排序欄位，非必傳
*/
String sortField;
/**
* 排序方式 SortOrder.ASC、SortOrder.DESC，非必傳
*/
SortOrder sort;
}@Data
@NoArgsConstructor
@AllArgsConstructor
public class AggregationBucketPO {
/**
* 聚合Bucket的key名
*/
private String key;
/**
* 聚合Bucket的檔案數量
*/
private Long docCount;
/**
* 子桶集合
*/
private List<AggregationBucketPO> subBucketList;
public AggregationBucketPO(String key, Long docCount) {
this.key = key;
this.docCount = docCount;
}
}
二級聚合分桶測試程式碼
@PostConstruct
private void init() {
// 查詢物件的封裝
EsMultiAggregationReqPO reqPO = new EsMultiAggregationReqPO();
reqPO.setIndex(new String[]{"test_log"});
List<Long> ids = Lists.newArrayList();
ids.add(140L);
ids.add(141L);
ids.add(142L);
QueryBuilder queryBuilder4 = QueryBuilders.termsQuery("eventId", ids);
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery().must(queryBuilder4);
reqPO.setQuery(queryBuilder);
reqPO.setField("eventId");
reqPO.setFieldSize(9999);
reqPO.setSubField("riskFlag");
// 執行查詢
List<AggregationBucketPO> esQueryRespPO = searchMultiAggregation(reqPO);
System.out.println("esQueryRespPO=" + esQueryRespPO);
}其它
如果沒有用spring-boot-starter-data-elasticsearch來自動注入es元件，那麼需要自己做es client的注入，es設定類如下：
/**
* @author yangzihe
* @date 2022/1/25
*/
@Configuration
public class EsClientConfig {
@Value("${spring.elasticsearch.rest.uris}")
private List<String> uris;
@Bean
public RestHighLevelClient restHighLevelClient() {
List<HttpHost> httpHostList = uris.stream().map(HttpHost::create).collect(Collectors.toList());
HttpHost[] httpHost = new HttpHost[uris.size()];
httpHostList.toArray(httpHost);
RestClientBuilder clientBuilder = RestClient.builder(httpHost);
return new RestHighLevelClient(clientBuilder);
}
}
Snowflake是hutool包裡的，導包：
<!-- https://mvnrepository.com/artifact/cn.hutool/hutool-all -->
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.7.14</version>
</dependency>
聚合查詢的測試用例：
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = StartApplication.class)
public class EsTest {
@Resource
private EsSearchRepository esSearchRepository;
@Test
public void testSearchAggregation() {
// 查詢物件的封裝
EsQueryReqPO queryPO = new EsQueryReqPO();
queryPO.setIndex(new String[]{"yzh1", "yzh2"});
queryPO.setPageNum(1);
queryPO.setPageSize(10);
// 時間戳範圍
QueryBuilder queryBuilder1 = QueryBuilders.rangeQuery("timestamp")
.from(System.currentTimeMillis() - 1000)
.to(System.currentTimeMillis());
// 登入標識
QueryBuilder queryBuilder2 = QueryBuilders.termQuery("name", "yang");
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery().must(queryBuilder1).must(queryBuilder2);
queryPO.setQuery(queryBuilder);
// 根據userName分組。建立terms桶聚合，聚合名字=terms_by_userName, 欄位=payload.userName.keyword
TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders
.terms("terms_by_userName").field("payload.userName.keyword");
termsAggregationBuilder.size(queryPO.getPageSize() * queryPO.getPageNum());
termsAggregationBuilder.subAggregation(new BucketSortPipelineAggregationBuilder("bucket_field", null)
.from((queryPO.getPageNum() - 1) * queryPO.getPageSize()).size(queryPO.getPageSize()));
queryPO.setTermsAggregation(termsAggregationBuilder);
// 根據userName聚合count統計. cardinality名=count_userName, 欄位=payload.userName.keyword
CardinalityAggregationBuilder cardinalityAggregationBuilder = AggregationBuilders
.cardinality("count_userName").field("payload.userName.keyword");
queryPO.setCardinalityAggregation(cardinalityAggregationBuilder);
// 執行查詢
EsQueryRespPO<AggregationBucketPO> esQueryRespPO = esSearchRepository.searchAggregation(queryPO);
}
}
到此這篇關於springboot2+es7使用RestHighLevelClient的範例程式碼的文章就介紹到這了,更多相關springboot2 es7使用RestHighLevelClient內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com！
相關文章
-
黑科技的輕簡出行，告別「電量焦慮症」：Anker氮化鎵超能充系列
综合看Anker超能充系列的性价比很高，并且与不仅和iPhone12/苹果<em>Mac</em>Book很配，而且适合多设备充电需求的日常使用或差旅场景，不管是安卓还是Switch同样也能用得上它，希望这次分享能给准备购入充电器的小伙伴们有所
2021-06-01 09:31:42
-
吳亦凡廠牌首秀，L4WUDU居然忘詞了，Rapper和明星比還是有差距！
除了L4WUDU与吴亦凡已经多次共事，成为了明面上的厂牌成员，吴亦凡还曾带领20XXCLUB全队参加2020年的一场音乐节，这也是20XXCLUB首次全员合照，王嗣尧Turbo、陈彦希Regi、<em>Mac</em> Ova Seas、林渝植等人全部出场。然而让
2021-06-01 09:31:34
-
IPFS、Chia、Bzz和ICP挖礦該怎麼選？哪一個更有優勢？
目前应用IPFS的机构：1 谷歌<em>浏览器</em>支持IPFS分布式协议 2 万维网 (历史档案博物馆)数据库 3 火狐<em>浏览器</em>支持 IPFS分布式协议 4 EOS 等数字货币数据存储 5 美国国会图书馆，历史资料永久保存在 IPFS 6 加
2021-06-01 09:31:24
-
有哪些事是買了雪佛蘭後才知道的？美事偷著樂，開拓者車主隨聊
开拓者的车机是兼容苹果和<em>安卓</em>，虽然我不怎么用，但确实兼顾了我家人的很多需求：副驾的门板还配有解锁开关，有的时候老婆开车，下车的时候偶尔会忘记解锁，我在副驾驶可以自己开门：第二排设计很好，不仅配置了一个很大的
2021-06-01 09:30:48
-
iPhone12在618最新定價，跌價幅度超過1400元，還等iPhone13嗎？
不仅是<em>安卓</em>手机，苹果手机的降价力度也是前所未有了，iPhone12也“跳水价”了，发布价是6799元，如今已经跌至5308元，降价幅度超过1400元，最新定价确认了。iPhone12是苹果首款5G手机，同时也是全球首款5nm芯片的智能机，它
2021-06-01 09:30:45