ElasticSearch - 根据经纬度，简单搜索指定距离范围内的数据

深碍√TFBOYSˉ_ 2023-10-13 09:41 45阅读 0赞

ES的地图检索方式

ES支持的地图检索方式有以下几种；

###### geo\_distance   geo\_bounding\_box   geo\_polygon ######

1、**geo\_distance**：直线距离检索，如给定点A，要求返回地图上距离点A三千米的商家（点外卖场景）

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1eGludGRyaA_size_16_color_FFFFFF_t_70]

2、查找索引内距离北京站(116.433733,39.908404)3000米内的点  
geo\_distance涉及的参数如下

location：确定一个点；  
distance：确定一个半径，单位米  
distance\_type：确定一个图形的类型；一般是圆形，arc

POST /map/_search
    {
      "query": {
        "geo_distance":
        {
          "location":
          {
            "lon":116.433733
            ,"lat":39.908404
          },
          "distance":3000,
          "distance_type":"arc"
        }
      }
    }

创建geo\_point类型字段映射：

PUT test 
    {
      "mappings": {
        "user": {
          "properties": {
            "location": {
              "type": "geo_point"
            }
          }
        }
      }
    }

加入依赖：

使用spring-data-elasticsearch依赖

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
            </dependency>

3、创建Doc文档对象：

package cn.nagisa.geo.doc;
    
    import lombok.Data;
    import org.springframework.data.elasticsearch.annotations.Document;
    import org.springframework.data.elasticsearch.annotations.GeoPointField;
    import org.springframework.data.elasticsearch.core.geo.GeoPoint;
    
    /**
     * @author nagisa
     */
    @Data
    @Document(indexName = "test",type = "user")
    public class UserDoc {
        private Long id;
    
        private String username;
    
        @GeoPointField
        private GeoPoint location;
    }

这里的Doc相当于entity，注意加上@GeoPointField，表示localcation是Es当中geo\_point类型的字段

/**
         * @param lat 区域中心的纬度
         * @param lng 区域中心经度
         * @param distance 区域半径
         * @return 符合条件的数据
         */
        @Override
        public JsonResult fixedArea(Double lat, Double lng, Integer distance) {
            BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
            // 以某点为中心，搜索指定范围
            GeoDistanceQueryBuilder distanceQueryBuilder = new GeoDistanceQueryBuilder("location");
            distanceQueryBuilder
                    .point(lat, lng)
                    .distance(distance, DistanceUnit.KILOMETERS);
            boolQueryBuilder.filter(distanceQueryBuilder);
    
            //查询封装
            NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();
            NativeSearchQuery build = nativeSearchQueryBuilder
                    .withQuery(boolQueryBuilder)
                    .build();
            return JsonResult.me().setResult(userRepository.search(build));
        }

## 错误排查： ##

Error: all shards failed 
    	可能原因：经纬度调换，传反了

[ES--经纬度查询\_es 经纬度查询\_宝哥大数据的博客-CSDN博客][ES--_es _-CSDN]

[SpringBoot+ElasticSearch根据经纬度，简单搜索指定距离范围内的数据\_springboot经纬度在5公里内\_Nagisa-的博客-CSDN博客][SpringBoot_ElasticSearch_springboot_5_Nagisa-_-CSDN]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1eGludGRyaA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210401095843614.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1eGludGRyaA==,size_16,color_FFFFFF,t_70
[ES--_es _-CSDN]: https://blog.csdn.net/wuxintdrh/article/details/115367301
[SpringBoot_ElasticSearch_springboot_5_Nagisa-_-CSDN]: https://blog.csdn.net/weixin_44472746/article/details/117780408