ElasticSearch 8.7 Java版GeoShapeQuery使用方法求助

核心场景说明 #

你的需求是判断某个地理点位是否处于指定区域内，对应Elasticsearch中GeoShapeQuery的Contains关系查询——即筛选出「存储的区域形状包含目标点位」的文档。

示例代码拆解 #

你提供的代码是ES 8.x Java客户端的写法，以下是逐部分解释：

1. 构建GeoShape查询条件 #

Query geoShape = GeoShapeQuery.of(f->f.field(ConvertUtils.FULL_GEO)
                        .shape(s->s.relation(GeoShapeRelation.Contains).shape(shape)))._toQuery();

• field(ConvertUtils.FULL_GEO)：指定ES中存储地理形状（你的目标区域）的字段名，该字段类型必须是geo_shape。
• relation(GeoShapeRelation.Contains)：设置关系为「包含」，表示要查询字段存储的区域包含目标点位的文档，这正好匹配你的需求。
• shape(shape)：这里的shape就是你要判断的目标点位，需要构建成Elasticsearch的Point类型对象，示例构建方式：

  // 构建目标点位（格式为[经度, 纬度]，示例：北京天安门附近坐标）
  Point shape = Point.of(p -> p.coordinates(Arrays.asList(116.403874, 39.914885)));
  

2. 组合布尔查询 #

Query bool = BoolQuery.of(b->b
                        .filter(geoShape)
                        .should(rankFeature)
                        )._toQuery();

• .filter(geoShape)：将GeoShape查询作为过滤条件，过滤出符合区域包含点位的文档，过滤条件不影响文档评分，性能更优。
• .should(rankFeature)：可选的评分补充条件，满足该条件的文档会获得更高评分，可根据业务需求调整或直接移除。

完整执行流程示例 #

import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.core.SearchRequest;
import org.elasticsearch.client.core.SearchResponse;
import org.elasticsearch.index.query.Query;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.geometry.Point;
import java.util.Arrays;

// 1. 初始化ES客户端（根据项目已有配置完成，此处省略）
RestHighLevelClient client = ...;

// 2. 构建待判断的目标点位
Point targetPoint = Point.of(p -> p.coordinates(Arrays.asList(116.403874, 39.914885)));

// 3. 构建GeoShape查询
Query geoShapeQuery = GeoShapeQuery.of(f -> f
        .field("full_geo") // 替换为你的geo_shape类型字段名
        .shape(s -> s
                .relation(GeoShapeRelation.Contains)
                .shape(targetPoint)
        )
)._toQuery();

// 4. 构建布尔查询
Query boolQuery = BoolQuery.of(b -> b
        .filter(geoShapeQuery)
        // .should(...) 按需添加你的rankFeature查询逻辑
)._toQuery();

// 5. 构建搜索请求并执行
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder().query(boolQuery);
SearchRequest searchRequest = new SearchRequest("your_index_name").source(sourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);

// 6. 解析搜索结果（根据业务需求处理命中的文档）

注意事项 #

• 确保ES索引中对应的字段类型是geo_shape，否则无法使用GeoShapeQuery进行地理关系判断。
• ES地理坐标的标准格式是**[经度, 纬度]**，不要搞反顺序，否则会导致判断结果错误。

内容的提问来源于stack exchange，提问作者hld942614