ES7学习笔记（十三）GEO位置搜索

ES的基本内容介绍的已经差很少了，最后咱们再来看看GEO位置搜索，如今大部分APP都有基于位置搜索的功能，好比：咱们点外卖，能够按照离咱们的距离进行排序，这样能够节省咱们的配送费和送餐的时间；还有找工做时，也能够按照离本身家的距离进行排序，谁都想找个离家近的工做，对吧。这些功能都是基于GEO搜索实现的，目前支持GEO搜索功能的中间件有不少，像MySQL、Redis、ES等。咱们看看在ES当中怎么实现GEO位置搜索。前端

GEO字段的建立

GEO类型的字段是不能使用动态映射自动生成的，咱们须要在建立索引时指定字段的类型为geo_point，geo_point类型的字段存储的经纬度，咱们看看经纬度是怎么定义的，java

	英文	简写	正数	负数
维度	latitude	lat	北纬	南纬
经度	longitude	lon或lng	东经	西经

经度的简写有2个，通常经常使用的是lon，lng则在第三方地图的开放平台中使用比较多。下面咱们先建立一个带有geo_point类型字段的索引，以下：git

PUT /my_geo
{
    "settings":{
        "analysis":{
            "analyzer":{
                "default":{
                    "type":"ik_max_word"
               }
           }
       }
   },
    "mappings":{
        "dynamic_date_formats":[
            "MM/dd/yyyy",
            "yyyy/MM/dd HH:mm:ss",
            "yyyy-MM-dd",
            "yyyy-MM-dd HH:mm:ss"
       ],
        "properties":{
            "location":{
                "type":"geo_point"
           }
       }
   }
}

建立了一个my_geo索引，在索引中有一些基础的配置，默认IK分词器，动态映射的时间格式。重点是最后咱们添加了一个字段location，它的类型是geo_point。shell

索引建立完了，咱们添加两条数据吧，假设，路人甲在北京站，路人乙在朝阳公园。那么咱们怎么“北京站”和“朝阳公园”的经纬度呢？咱们在作项目时，前端都会接地图控件，经纬度的信息能够调用地图控件的API获取。在我们的示例中，也不接地图控件了，太麻烦了，直接在网上找到“北京站”和“朝阳公园”的坐标吧。json

咱们查到“北京站”的坐标以下：微信

而后添加一条数据：
app

POST /my_geo/_doc
{
    "name":"路人甲",
    "location":{
        "lat": 39.90279998006104,
        "lon": 116.42703999493406
   }
}

再查“朝阳公园”的坐标elasticsearch

再添加“路人乙”的信息
ide

POST /my_geo/_doc
{
    "name":"路人乙",
    "location":{
        "lat": 39.93367367974064,
        "lon": 116.47845257733152
   }
}

咱们再用elasticsearch-head插件看一下索引中的数据：ui

GEO查询

“路人甲”和“路人乙”的信息都有了，可是没有location字段的信息，由于location是特性类型的字段，在这里是展现不出来的。咱们搜索一下吧，看看怎么用geo搜索，假设“我”的位置在“工体”，咱们先要查到“工体”的坐标，

而后再查询5km范围内都有谁，发送请求以下：

POST /my_geo/_search
{
    "query":{
        "bool":{
            "filter":{
                "geo_distance":{
                    "distance":"5km",
                    "location":{
                        "lat":39.93031708627304,
                        "lon":116.4470385453491
                   }
               }
           }
       }
   }
}

在查询的时候用的是filter查询，在filter查询里再使用geo_distance查询，咱们定义距离distance为5km，再指定geo类型的字段location，当前的坐标为：39.93031708627304N，116.4470385453491E。查询一下，看看结果：

{
    ……
    "hits":[
       {
            "_index":"my_geo",
            "_type":"_doc",
            "_id":"AtgtXnIBOZNtuLQtIVdD",
            "_score":0,
            "_source":{
                "name":"路人甲",
                "location":{
                    "lat": 39.90279998006104,
          "lon": 116.42703999493406
               }
           }
       },
       {
            "_index":"my_geo",
            "_type":"_doc",
            "_id":"ZdguXnIBOZNtuLQtMVfA",
            "_score":0,
            "_source":{
                "name":"路人乙",
                "location":{
                    "lat": 39.93367367974064,
          "lon": 116.47845257733152
               }
           }
       }
   ]
}

看来，咱们站在“工体”，“北京站”的路人甲和“朝阳公园”的路人乙都在5km的范围内。把范围缩短一点如何，改成3km看看，搜索的请求不变，只是把distance改成3km，看看结果吧，

{
    ……
    "hits":[
       {
            "_index":"my_geo",
            "_type":"_doc",
            "_id":"ZdguXnIBOZNtuLQtMVfA",
            "_score":0,
            "_source":{
                "name":"路人乙",
                "location":{
                    "lat": 39.93367367974064,
          "lon": 116.47845257733152
               }
           }
       }
   ]
}

只有在“朝阳公园”的路人乙被搜索了出来。彻底符合预期，咱们再看看程序中怎么使用GEO搜索。

JAVA 代码

在定义实体类时，对应的GEO字段要使用特殊的类型，以下：

@Setter@Getter
public class MyGeo {

    private String name;
    private GeoPoint location;

}

location的类型是GeoPoint，添加数据的方法没有变化，转化成Json就能够了。再看看查询怎么用，

public void searchGeo() throws IOException {
    SearchRequest searchRequest = new SearchRequest("my_geo");
    SearchSourceBuilder ssb = new SearchSourceBuilder();

    //工体的坐标
    GeoPoint geoPoint = new GeoPoint(39.93367367974064d,116.47845257733152d);
    //geo距离查询 name=geo字段
    QueryBuilder qb = QueryBuilders.geoDistanceQuery("location")
        //距离 3KM
       .distance(3d, DistanceUnit.KILOMETERS)
        //坐标工体
       .point(geoPoint);

    ssb.query(qb);
    searchRequest.source(ssb);
    SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

    for (SearchHit hit : response.getHits().getHits()) {
        System.out.println(hit.getSourceAsString());
   }


}

SearchRequest指定索引my_geo
建立”工体“的坐标点GeoPoint
建立geo距离查询，指定geo字段location，距离3km，坐标点工体
其余的地方没有变化

运行一下，看看结果，

{"name":"路人乙","location":{"lat":39.93360786576342,"lon":116.47853840802}}

只有在“朝阳公园”的路人乙被查询了出来，符合预期。

距离排序

有的小伙伴可能会有这样的疑问，我不想按照距离去查询，只想把查询结果按照离“我”的距离排序，该怎么作呢？再看一下，

public void searchGeoSort() throws IOException {
    SearchRequest searchRequest = new SearchRequest("my_geo");
    SearchSourceBuilder ssb = new SearchSourceBuilder();

    //工体的坐标
    GeoPoint geoPoint = new GeoPoint(39.93367367974064d,116.47845257733152d);

    GeoDistanceSortBuilder sortBuilder = SortBuilders
       .geoDistanceSort("location", geoPoint)
       .order(SortOrder.ASC);

    ssb.sort(sortBuilder);
    searchRequest.source(ssb);
    SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

    for (SearchHit hit : response.getHits().getHits()) {
        System.out.println(hit.getSourceAsString());
   }
}

此次查询并无设置查询条件，而是建立了一个geo距离排序，一样，先指定geo字段location，和当前的坐标”工体“，再设置排序是升序。运行一下，看看结果，

{"name":"路人乙","location":{"lat":39.93360786576342,"lon":116.47853840802}}
{"name":"路人甲","location":{"lat":39.902799980059335,"lon":116.42721165631102}}

离“工体”比较近的“路人乙”排在了第一个，也是符合预期的。有问题你们评论区留言吧~

本文分享自微信公众号 - 牛初九（tech-java）。
若有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一块儿分享。