/**
     * 获取ES的连接client实例;
     *
     * @return TransportClient对象
     */
    private static TransportClient getTransportClient(String esIp) throws IOException {
        Settings settings = Settings.builder()
                .put(CLUSTER_NAME, "xxx")
                .put(ELASTIC.CLIENT_TRANSPORT_SNIFF, true)
                .build();
        TransportClient transportClient = TransportClient.builder().settings(settings).build();
        String[] ips =esIp.split(",");

        for (String ip : ips) {
            try {
                InetSocketTransportAddress ist = new InetSocketTransportAddress(InetAddress.getByName(ip),ELASTIC.ES_TRANSPORTCLIENT_PORT);
                transportClient.addTransportAddress(ist);
            }catch (Exception e){
            }
        }
        return transportClient;
    }

  @Test
    public  void querySearch() throws IOException {
   
        long l = System.currentTimeMillis();
        TransportClient transportClient = Factory.getTransportClient();

        //封装聚合的查询条件
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery(TIME_FIELD).from(startTime).to(endTime);
        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("xx", "xxx");
       // QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
        BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder().must(rangeQueryBuilder).must(matchQueryBuilder);
// 使用通配符‘*’来前缀匹配INDEX开头的所有索引库
        SearchResponse response=transportClient.prepareSearch("INDEX*")
        .setTypes("TYPE")
        // 设置查询类型
        // 1.SearchType.DFS_QUERY_THEN_FETCH = 精确查询
        // 2.SearchType.SCAN = 扫描查询,无序
        // 3.SearchType.COUNT = 不设置的话,这个为默认值,还有的自己去试试吧
        .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
        // 设置查询关键词
        .setQuery(boolQueryBuilder)
        // 设置查询数据的位置,分页用
        .setFrom(0)
        // 设置查询结果集的最大条数
        .setSize(1000)
        // 设置是否按查询匹配度排序
        .setExplain(true)
        // 最后就是返回搜索响应信息
        .execute()
        .actionGet();
        SearchHits searchHits=response.getHits();
//        System.out.println("-----------------在["+term+"]中搜索关键字["+queryString+"]---------------------");
        System.out.println(System.currentTimeMillis() - l);
        System.out.println("共匹配到:"+searchHits.getTotalHits()+"条记录!");
        SearchHit[]hits=searchHits.getHits();
        for(SearchHit searchHit:hits){
            Map<String, Object> sourceAsMap=searchHit.sourceAsMap();
            Set<String> keySet=sourceAsMap.keySet();
            for(String string:keySet){
                   //key value 值对应关系
                  System.out.println(string+":"+sourceAsMap.get(string));
            }
            System.out.println();
        }

    }　

//INDEX:索引库名称(不能用通配符)，TYPE:索引库的type ,ID索引库的ID  
DeleteResponse deleteResponse = client.prepareDelete("INDEX", "TYPE", "ID").get();       
//成功删除
if(deleteResponse.isFound()){
    successEs.add(rowkey);
 }else {
    failedEs.add(rowkey);
  }

@Test
  
public void removeDataFromEs() throws IOException {
        ArrayList<String> xxx= new ArrayList<>();
        xxx.add("201801001");
        xxx.add("201801001");
        TransportClient client = Factory.getTransportClient();
        BulkRequestBuilder builder=client.prepareBulk();
        for(String id:xxx){
            System.out.println(id);
            builder.add(client.prepareDelete("INDEX", "TYPE", id).request());
        }
}
BulkResponse bulkResponse = builder.get();