ElasticSearch6.x 基于SpringBoot 实现ElasticSearch的统计查询

AggregationUtil.java 实现elasticsearch 搜索引擎针对指定索引的max（最大值）、 min（最小值）、sum（合计统计）、avg（平均值统计）、 stats（基本统计）、extendedStats（高级统计）、cardinality（基数统计）、percentiles（百分比统计）、valueCount（文档数量统计）等相关统计功能。

package com.zzg.ela.index.util; 
 
import org.elasticsearch.action.search.SearchResponse; 
import org.elasticsearch.client.transport.TransportClient; 
import org.elasticsearch.search.aggregations.AggregationBuilder; 
import org.elasticsearch.search.aggregations.AggregationBuilders; 
import org.elasticsearch.search.aggregations.metrics.avg.Avg; 
import org.elasticsearch.search.aggregations.metrics.cardinality.Cardinality; 
import org.elasticsearch.search.aggregations.metrics.max.Max; 
import org.elasticsearch.search.aggregations.metrics.min.Min; 
import org.elasticsearch.search.aggregations.metrics.percentiles.Percentiles; 
import org.elasticsearch.search.aggregations.metrics.stats.extended.ExtendedStats; 
import org.elasticsearch.search.aggregations.metrics.sum.Sum; 
import org.elasticsearch.search.aggregations.metrics.valuecount.ValueCount; 
import org.elasticsearch.threadpool.ThreadPoolStats.Stats; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.stereotype.Component; 
 
/** 
 * ela 工具类 
 *  
 * @author zzg 
 * 
 */ 
@Component 
public class AggregationUtil { 
		// 引入 Ela 连接实列化对象 
		@Autowired 
		private TransportClient client; 
		 
		/** 
		 * 最大值 
		 * @param index  索引 
		 * @param field  文档属性 
		 * @return 
		 */ 
	    public double max(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("max_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.max(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).get(); 
	        Max max=response.getAggregations().get(name); 
	        return max.getValue(); 
	    } 
	     
	    /** 
	     * 最小值统计 
	     * @param index  索引 
		 * @param field  文档属性 
	     * @return 
	     */ 
	    public double min(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("min_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.min(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).get(); 
	        Min min=response.getAggregations().get(name); 
	        return min.getValue(); 
	    } 
	     
	    /** 
	     * 合计统计 
	     * param index  索引 
	     * @param field 文档属性 
	     * @return 
	     */ 
	    public double sum(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("sum_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.sum(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).get(); 
	        Sum sum=response.getAggregations().get(name); 
	        return sum.getValue(); 
	    } 
	     
	     
	    /** 
	     * 平均值统计 
	     * param index  索引 
	     * @param field 文档属性 
	     * @return 
	     */ 
	    public double avg(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("avg_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.avg(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).get(); 
	        Avg avg=response.getAggregations().get(name); 
	        return avg.getValue(); 
	    } 
	     
	    /** 
	     * 基本统计 
	     * @param index  索引 
	     * @param field 文档属性 
	     * @return 
	     */ 
	    public Stats stats(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("stats_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.stats(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet(); 
	        return response.getAggregations().get(name); 
	    } 
 
	 
	    /** 
	     * 高级统计 
	     * @param index  索引 
	     * @param field  文档属性 
	     * @return 
	     */ 
	    public ExtendedStats extendedStats(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("extendedStats_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.extendedStats(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet(); 
	        return response.getAggregations().get(name); 
	    } 
	     
	     
	    /** 
	     * 基数统计 
	     * @param index  索引 
	     * @param field  文档属性 
	     * @return 
	     */ 
	    public double cardinality(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("cardinality_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.cardinality(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).get(); 
	        Cardinality c=response.getAggregations().get(name); 
	        return c.getValue(); 
	    } 
	     
	    /** 
	     * 百分位统计 
	     * @param index  索引 
	     * @param field  文档属性 
	     * @return 
	     */ 
	    public Percentiles percentiles(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("percentiles_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.percentiles(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet(); 
	        return response.getAggregations().get(name); 
	    } 
	     
	     
	    /** 
	     * 文档数量统计 
	     * @param index  索引 
	     * @param field  文档属性 
	     * @return 
	     */ 
	    public double valueCount(String index, String field){ 
	    	StringBuilder builder = new StringBuilder(); 
	    	builder.append("valueCount_").append(field); 
	    	String name = builder.toString(); 
	    	 
	        AggregationBuilder agg=AggregationBuilders.count(name).field(field); 
	        SearchResponse response=client.prepareSearch(index).addAggregation(agg).execute().actionGet(); 
	        ValueCount count=response.getAggregations().get(name); 
	        return count.getValue(); 
	    } 
 
}