ElasticSearch 实现分词全文检索 - 经纬度定位商家距离查询

elasticsearch,实现,分词,全文检索,经纬度,定位,商家,距离,查询 · 浏览次数 : 163

小编点评

**ElasticSearch 实现分词全文检索** **概述** ElasticSearch 是一个开源搜索引擎，它可以用于构建一个可扩展的搜索索引。ElasticSearch 提供分词功能，允许您在搜索中使用多个词语进行搜索。 **安装** 您可以使用以下命令安装 Elasticsearch： ``` curl -O elasticsearch-setup.zip - | sudo -E unzip -d /usr/local/bin ``` **配置** 您可以使用以下命令配置 Elasticsearch： ``` elasticsearch -e ``` **RESTful 基本操作** 您可以使用以下 RESTful API 进行分词搜索： * `POST /map/_search`：用于搜索按地理位置的地理距离搜索结果。 * `GET /map/_search`：用于搜索所有地理距离搜索结果。 * `GET /map/_doc/id`：用于获取指定 ID 的文档。 * `POST /map/_doc/id`：用于添加或更新文档。 **Java SpringBoot ES 索引操作** 您可以使用 Spring Boot 的 ES 客户端进行分词搜索： ```java @Autowired private ElasticsearchClient esClient; public void indexDocument(String indexName, String document) { IndexRequest request = IndexRequest.index(indexName); request.source(document); esClient.index(request); } ``` **Java SpringBoot ES 文档操作** 您可以使用 Spring Boot 的 ES 客户端进行分词搜索： ```java @Autowired private ElasticsearchClient esClient; public void searchDocuments(String indexName, String query) { SearchRequest request = SearchRequest.search(indexName); request.query(QueryBuilders.matchQuery(query)); SearchResult results = esClient.search(request); // 处理结果 } ``` **测试数据准备** 您可以使用以下方法创建一个包含多个地理位置的文档： ```java public void createIndex() { IndexRequest request = IndexRequest.index("map"); request.settings.put("number_of_shards", 2); request.settings.put("number_of_replicas", 1); request.addMapping(Mapping.of("properties", Mapping.of("name", Mapping.of("type", "text")))); esClient.index(request); } ``` **分词搜索** 您可以使用以下方法搜索包含多个词语的文档： ```java public void searchQuery() { SearchRequest request = SearchRequest.search("map"); request.query(QueryBuilders.matchQuery("location", new GeoPoint(40.013315, 116.31027))); SearchResult results = esClient.search(request); // 处理结果 } ``` **总结** ElasticSearch 实现分词全文检索，允许您在搜索中使用多个词语进行搜索。您可以使用 RESTful API 或 Java SpringBoot ES 客户端进行分词搜索。

正文

地图经纬度搜索

ES 中提供了一个数据类型 geo_point, 用来存储经纬度

创建ES索引

# 创建一个索引，指定 name,location
PUT /map
{
  "settings": {
    "number_of_shards": 2,
    "number_of_replicas": 1
  },
  "mappings": { 
    "properties":{
      "name":{
        "type":"text"
      },
      "location":{
        "type":"geo_point"
      }
    } 
  }
}

百度地图经纬度：http://api.map.baidu.com/lbsapi/getpoint/index.html

添加数据

# 添加数据
PUT /map/_doc/1
{
  "name":"天安门",
  "location":{
    "lon":116.403119,
    "lat":39.915599
  }
}

PUT /map/_doc/2
{
  "name":"北京大学",
  "location":{
    "lon":116.316486,
    "lat":39.999416
  }
}

PUT /map/_doc/3
{
  "name":"清华大学",
  "location":{
    "lon":116.333267,
    "lat":40.010276
  }
}

ES地图搜索方式

geo_distance: 直线距离检索方式
geo_bound_box：以两个点确定一个巨型，获取在矩形内的全部数据
geo_polygon：以多个点，确定一个多边形，获取多边形内的全部数据

实现地图检索

# 直接距离
POST /map/_search
{ 
  "query":{
    "geo_distance":{
      "location":{     #确定一个点
        "lon":116.433589,
        "lat":39.909235
      },
      "distance":3000,  # 2000 查不到，当前定位中，3公里内维护的数据（类似外卖）
      "distance_type":"arc"   # 指定形状为圆形，直接距离
    }
  }
}

# 左上、右下，确定巨型范围
POST /map/_search
{ 
  "query":{
    "geo_bounding_box":{
      "location":{
        "top_left":{       # 圆明园
          "lon":116.309695,
          "lat":40.013094
        },
        "bottom_right":{    # 天安门
          "lon":116.403119,
          "lat":39.915599
        }
      }
    }
  }
}

# 多点确定范围
POST /map/_search
{
  "query":{
    "geo_polygon":{
      "location":{
        "points":[
          { 
            "lon":116.31027,
            "lat":40.013315
          },
          { 
            "lon":116.335854,
            "lat":39.998282
          },{ 
            "lon":116.301359,
            "lat":39.992534
          }
        ]
      }
    }
  }
}

Java

@Test
void geoPolygon() throws Exception {
    String indexName = "map";
    RestHighLevelClient client = ESClient.getClient();

    //1. 创建SearchRequest对象
    SearchRequest request = new SearchRequest(indexName);

    //2. 指定查询条件
    List<GeoPoint> points = new ArrayList<>();
    points.add(new GeoPoint(40.013315, 116.31027));
    points.add(new GeoPoint( 39.998282,116.335854));
    points.add(new GeoPoint( 39.992534,116.301359));

    SearchSourceBuilder builder = new SearchSourceBuilder();
    builder.query(QueryBuilders.geoPolygonQuery("location", points));
    request.source(builder);

    //3. 执行查询
    SearchResponse resp = client.search(request, RequestOptions.DEFAULT);

    //4. 输出返回值
    for (SearchHit hit : resp.getHits().getHits()) {
        System.out.println(hit.getSourceAsMap());
    }
}