官方文檔：

https://www.elastic.co/guide/en/elasticsearch/reference/2.4/query-dsl-geo-distance-query.html#_geohash_3

歡迎訪問(wèn)本人博客：http://wangnan.tech

索引mapping定義:

索引中定義一個(gè)字段pin而涉，添加一個(gè)屬性location及汉，type為geo_point

"pin" : {
  "properties" : {
    "location" : {
      "type" : "geo_point"
        }
      }
    }

DSL:

報(bào)文中的包含一個(gè)match all的query , filter中的distance指定了距離范圍拜秧，pin.location是經(jīng)緯度

{
"bool" : {
    "must" : {
        "match_all" : {}
    },
    "filter" : {
        "geo_distance" : {
            "distance" : "200km",
            "pin.location" : {
                "lat" : 40,
                "lon" : -70
            }
        }
    }
}
}

代碼：

拼裝 query 和 sort

           QueryBuilder builder = new GeoDistanceRangeQueryBuilder （"pin.location"） 
                    .point(lat,lon)
                    .from("0km")  
                    .to("10000km")  
                    .includeLower(true)  
                    .includeUpper(false)  
                    .optimizeBbox("memory")  
                    .geoDistance(GeoDistance.ARC);  
     
              GeoDistanceSortBuilder sort = SortBuilders.geoDistanceSort("location");  
              GeoDistanceSortBuilder sort = new GeoDistanceSortBuilder("location");  
              sort.unit(DistanceUnit.KILOMETERS); 
              sort.order(SortOrder.ASC);  
              sort.point(lat,lon); 

構(gòu)造dsl生產(chǎn)器

    
            SearchSourceBuilder sourceBuilder = SearchSourceBuilder.searchSource(); 
            sourceBuilder.query(QueryBuilders.boolQuery())                
            .must(builder)
            sourceBuilder.sort(sort);

調(diào)用elasticsearch

    final SearchResponse response = executeGet(new ClientCallback<SearchResponse>() {
            @Override
            public ActionFuture<SearchResponse> execute(final Client client) {
            final SearchSourceBuilder sourceBuilder =    SearchParamUtils
            .genSearchSourceBuilderFromSearchParam(searchParam);  
            String[] indexNames = new String[aliasIndexNameList.size()];
            SearchRequest request = Requests.searchRequest(aliasIndexNameList.toArray(indexNames))
            .types(type);
            request.source(sourceBuilder.toString());
            if (searchParam.getSearchType() != null) {
                    request.searchType(searchParam.getSearchType());
            }
                return client.search(request);
            }
        });

獲取每條記錄的距離

            SearchResult searchResult = new SearchResult();
            SearchHits hits = response.getHits();
            for (SearchHit hit : hits.getHits()) {
            Object[] sortArray = hit.getSortValues();
                if(sortArray!=null&&sortArray.length>0){
                    BigDecimal geoDis = new BigDecimal((Double) sortArray[sortArray.length-1]);
                    map.put("geoDistance", geoDis.setScale(0, BigDecimal.ROUND_HALF_DOWN));
                            System.out.println("距離" + hit.getSource().get("geoDistance"));
                }
            }