elasticsearch学习总结（三） Java API的使用范例1

一、关键词查询

/**

* es中查询日志 * @param page * @param esAppLog * @return */ public List<EsAppLog> getEsAppLogs(Page<EsAppLog> page, EsAppLog esAppLog) {

  //前端参数

  String index = esAppLog.getIndex();

  String keyword = esAppLog.getKeyWord();

   //查询的索引数组

  SearchRequestBuilder responsebuilder = client.prepareSearch(index.split(","));

  //关键词查询

  if(StringUtils.isNotEmpty(keyword)){     responsebuilder.setQuery(QueryBuilders.matchQuery("message", keyword));   }   if(null != page){     int size = page.getPageSize();     int start = (page.getPageNo() - 1) * size;     responsebuilder.setFrom(start).setSize(size);   }   //执行查询

  SearchResponse myresponse = responsebuilder.setExplain(true).get();

  SearchHits hits = myresponse.getHits();    //总条数   if(null != page){     page.setCount(hits.getTotalHits());

  }

  //转换成对象

  List<EsAppLog> logs = new ArrayList<EsAppLog>();   EsAppLog log = null;   for (int i = 0; i < hits.getHits().length; i++) {             Map<String,Object> item = hits.getHits()[i].getSource();           log = new EsAppLog();           log.setIp((String)item.get("host"));           log.setTime((String)item.get("@timestamp"));           log.setLogName((String)item.get("path"));           log.setLogContent((String)item.get("message"));                      logs.add(log);    }   return logs;

}

二、多条件查询并返回指定字段

public void getCPUEsData(){

  //索引值   SearchRequestBuilder responsebuilder = client.prepareSearch("system");   //返回指定字段   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();   String[] fields = {"@timestamp","value"};   FetchSourceContext sourceContext = new FetchSourceContext(fields);   searchSourceBuilder.fetchSource(sourceContext);   responsebuilder.setSource(searchSourceBuilder);   //collectd=cpu and type_instance=system条件查询   responsebuilder.setQuery(QueryBuilders.boolQuery().must(QueryBuilders.termQuery("collectd_type", "cpu")).must(QueryBuilders.termQuery("type_instance", "system")));

  //执行查询   SearchResponse myresponse = responsebuilder.get();   SearchHits hits = myresponse.getHits();    for (int i = 0; i < hits.getHits().length; i++) {  

    Map<String,Object> item = hits.getHits()[i].getSource();     System.out.println(item);   } }