0. ES版本

6.x版本

1. 创建索引

PUT /location
{"settings": {"number_of_shards": 1,"number_of_replicas": 0},"mappings": {"location": {"properties": {"id": {"type": "keyword"},"name": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_max_word"},"coordinate": {"type": "geo_point"}}}}
}

2. 批量插入数据

注意：这里的coordinate用的是字符串插入，所以要用纬经度。试了下用数组的形式（“coordinate”:[116.64002551005981,40.17836693398477]）会报错，应该是6.x的版本不支持吧

PUT /location/location/_bulk
{"index":{"_id":"1"}}
{"name":"资料名称1","coordinate":"40.17836693398477,116.64002551005981"}
{"index":{"_id":"2"}}
{"name":"资料名称2","coordinate":"40.19103839805197,116.5624013764374"}
{"index":{"_id":"3"}}
{"name":"资料名称3","coordinate":"40.13933715136454,116.63441990026217"}
{"index":{"_id":"4"}}
{"name":"资料名称4","coordinate":"40.14901664712196,116.53067995860928"}
{"index":{"_id":"5"}}
{"name":"资料名称5","coordinate":"40.125057718315716,116.62963567059545"}
{"index":{"_id":"6"}}
{"name":"资料名称6","coordinate":"40.19216257806647,116.64025980109571"}
{"index":{"_id":"7"}}
{"name":"资料名称7","coordinate":"40.16371689899584,116.63095084701624"}
{"index":{"_id":"8"}}
{"name":"资料名称8","coordinate":"40.146045218040605,116.5696251832195"}
{"index":{"_id":"9"}}
{"name":"资料名称9","coordinate":"40.144735806234166,116.60712460957835"}

3. geo_bounding_box查询

3.1 解释

geo_bounding_box是查询一个矩形内的所有数据，提供左上角和右上角的经纬度坐标

3.2 经纬度属性查询

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": {"lat": 40.187328,"lon": 116.498353},"bottom_right": {"lat": 40.084509,"lon": 116.610461}}}}
}

3.3 经纬度数组查询

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": [116.498353, 40.187328],"bottom_right": [116.610461, 40.084509]}}}
}

3.4 经纬度字符串查询

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top_left": "40.187328, 116.498353","bottom_right": "40.084509, 116.610461"}}}
}

3.5 经纬度边界框WKT查询

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"wkt": "BBOX(116.498353,116.610461,40.187328,40.084509)"}}}
}

3.6 经纬度顶点属性查询

GET /location/location/_search
{"query": {"geo_bounding_box": {"coordinate": {"top": 40.187328,"left": 116.498353,"bottom": 40.084509,"right": 116.610461}}}
}

4. geo_polygon查询

4.1 解释

geo_polygon查询一个多边形区域内的所有数据，需要按顺序形成一个闭合的区域，不管从哪个坐标开始，只要能形成一个闭合区域就行

4.2 查询

GET /location/location/_search
{"query": {"geo_polygon": {"coordinate": {"points": ["40.178012,116.577188","40.169329,116.586315","40.178288,116.591813"]}}}
}

GET /location/location/_search
{"query": {"geo_polygon": {"coordinate": {"points": ["40.178012,116.577188","40.169329,116.586315","40.178288,116.591813","40.171975,116.587105"]}}}
}

5. Springboot中使用geo_bounding_box查询

5.1 实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "location", type = "location")
public class AddressEsEntity {@Idprivate String id;@Field(type = FieldType.Text, analyzer = "ik_max_word")private String name;@Field(type = FieldType.Keyword)private String coordinate;
}

5.2 geoBoundingBoxQuery

这里的setCorners里面直接传topLeft和bottomRight会报错，具体原因还没研究

String topLeft = "40.187328,116.498353";
String bottomRight = "40.084509,116.610461";
try {SearchRequest searchRequest = new SearchRequest("location");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.geoBoundingBoxQuery("coordinate").setCorners(new GeoPoint("40.187328,116.498353"), new GeoPoint("40.084509,116.610461")));searchRequest.types("location").source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);SearchHit[] hits = searchResponse.getHits().getHits();System.out.println(searchResponse);
} catch (IOException e) {e.printStackTrace();
}

5.3 geoPolygonQuery

List<GeoPoint> points = new ArrayList<>();
points.add(new GeoPoint("40.178012,116.577188"));
points.add(new GeoPoint("40.169329,116.586315"));
points.add(new GeoPoint("40.178288,116.591813"));
try {SearchRequest searchRequest = new SearchRequest("address");SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();searchSourceBuilder.query(QueryBuilders.geoPolygonQuery("coordinate", points));searchRequest.types("address").source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);SearchHit[] hits = searchResponse.getHits().getHits();System.out.println(searchResponse);
} catch (IOException e) {e.printStackTrace();
}