1 package com.juyun.test;  2   3 import java.net.InetAddress;  4   5 import org.elasticsearch.action.search.SearchResponse;  6 import org.elasticsearch.client.Client;  7 import org.elasticsearch.common.settings.Settings;  8 import org.elasticsearch.common.transport.InetSocketTransportAddress;  9 import org.elasticsearch.index.query.QueryBuilder; 10 import org.elasticsearch.index.query.QueryBuilders; 11 import org.elasticsearch.search.SearchHit; 12 import org.elasticsearch.search.SearchHits; 13 import org.elasticsearch.search.aggregations.AggregationBuilder; 14 import org.elasticsearch.search.aggregations.AggregationBuilders; 15 import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramInterval; 16 import org.elasticsearch.search.aggregations.metrics.sum.InternalSum; 17 import org.elasticsearch.search.sort.SortBuilder; 18 import org.elasticsearch.search.sort.SortBuilders; 19 import org.elasticsearch.search.sort.SortOrder; 20 import org.elasticsearch.transport.client.PreBuiltTransportClient; 21 import org.joda.time.DateTimeZone; 22  23 public class DslQuery { 24  25     private static Client client; 26      27     // 测试时常用的几种dsl 28     public static void main(String[] args) { 29          30         try { 31             // 设置集群名称  32             Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build(); 33             // 创建client 34             client = new PreBuiltTransportClient(settings) 35                     .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("172.16.0.157"), 9300)); 36              37             long startTime=System.currentTimeMillis(); // 获取开始时间     38              39             commonQuery("newindex","newhttp"); 40             //commonQuery2("newindex","newhttp"); 41              42             long endTime=System.currentTimeMillis(); //获取结束时间 43             System.out.println("程序运行时间： "+(endTime-startTime)+"ms"); 44              45              46             // 关闭client 47             client.close(); 48  49         } catch (Exception e) { 50             e.printStackTrace(); 51         } 52     } 53  54     /** 55      * 以时间戳降序排列并查询出所有数据 56      * @param indexName 57      * @param typeName 58      */ 59     public static void commonQuery(String indexName, String typeName){ 60          61         SortBuilder sortBuilder = SortBuilders.fieldSort("@timestamp") 62                 .order(SortOrder.DESC).unmappedType("boolean"); // 定义排序方式 63         QueryBuilder queryBuilder =QueryBuilders.boolQuery() 64                 .must(QueryBuilders.queryStringQuery("*").analyzeWildcard(true).defaultField("_all")); // 定义查询方式 65                  66         SearchResponse searchResponse = client.prepareSearch(indexName).setTypes(typeName) 67                 .setQuery(queryBuilder) 68                 .addSort(sortBuilder) 69                 .setSize(500) 70                 .execute().actionGet(); 71          72         SearchHits hits = searchResponse.getHits(); // 获取搜索结果 73         for (SearchHit searchHit : hits) {    // 遍历并以字符串形式打印搜索结果 74             System.out.println(searchHit.getSourceAsString()); 75         } 76         System.out.println("查询到记录数:" + hits.getTotalHits()); 77     } 78      79      80     /** 81      * 集合查询统计总值 82      * @param indexName 83      * @param typeName 84      */ 85     public static void commonQuery2(String indexName, String typeName){ 86          87         SortBuilder sortBuilder = SortBuilders.fieldSort("@timestamp") 88                 .order(SortOrder.DESC).unmappedType("boolean"); // 定义排序方式 89         QueryBuilder queryBuilder =QueryBuilders.boolQuery() 90                 .must(QueryBuilders.queryStringQuery("*").analyzeWildcard(true).defaultField("_all")); // 定义查询方式 91          92         AggregationBuilder aggBuilder1=AggregationBuilders.dateHistogram("dateagg") // 定义时间间隔直方图 93                 .field("@timestamp") 94                 .dateHistogramInterval(DateHistogramInterval.minutes(1)) 95                 .timeZone(DateTimeZone.forID("+08:00")); 96          97         AggregationBuilder aggBuilder2=AggregationBuilders.sum("sumOfOut").field("http.bytes_out"); // 聚合统计 98         AggregationBuilder aggBuilder3=AggregationBuilders.sum("sumOfIn").field("http.bytes_in"); 99         100         SearchResponse searchResponse = client.prepareSearch(indexName).setTypes(typeName)101                 .setQuery(queryBuilder)102                 .addSort(sortBuilder)103                 .addAggregation(aggBuilder1)104                 .addAggregation(aggBuilder2)105                 .addAggregation(aggBuilder3)106                 .setSize(500)107                 .execute().actionGet();108         109         SearchHits hits = searchResponse.getHits(); // 获取搜索结果110         for (SearchHit searchHit : hits) {    // 遍历并以字符串形式打印搜索结果111             System.out.println(searchHit.getSourceAsString());112         }113         InternalSum sumOfOut = searchResponse.getAggregations().get("sumOfOut"); // 获取出流量总值114         InternalSum sumOfIn = searchResponse.getAggregations().get("sumOfIn"); // 获取进流量总值115         116         System.out.println("查询到记录数:" + hits.getTotalHits());117         System.out.println("outbyte的总值是："+sumOfOut.getValue());118         System.out.println("inbyte的总值是："+sumOfIn.getValue());119     }120 }