一.前言

近期項(xiàng)目需要用到ElasticSearch根據(jù)坐標(biāo)獲取范圍內(nèi)的數(shù)據(jù)，以前有所接觸的僅僅是老版本，去了解了一下新版本，發(fā)現(xiàn)很多方法已經(jīng)處于棄用狀態(tài)。而在網(wǎng)絡(luò)上苦苦搜尋，卻很少見到關(guān)于4.*版本關(guān)于GeoPoint新型寫法的詳細(xì)文章，在官方文檔中，對于新人而言卻又很難理解使用。本文將記錄使用GeoPoint根據(jù)地理位置獲取數(shù)據(jù)的案例。

注：作者目前是邊學(xué)邊用，有什么不對的地方請指出

二.使用案例

作者版本信息：Elasticsearch 7.17.3

1. 依賴版本

參考官方文檔：https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#preface

依賴搜索：https://mvnrepository.com

根據(jù)自己的ES版本對照以下依賴版本

2. 依賴

父依賴

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.9</version>
    <relativePath/>
</parent>

直接導(dǎo)入spring-boot-starter-data-elasticsearch依賴

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

不需要指定版本，會(huì)根據(jù)你的SpringBoot版本自動(dòng)指定spring-data-elasticsearch 版本

3. YMAL配置類

相比較于之前的老版本，可以直接使用uris來指定地址

spring:
  elasticsearch:
    uris: http://localhost:9200

4. 實(shí)體類Document

這里用到了lombok

GeoPoint須要用@GeoPointField注解標(biāo)注

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "test",createIndex = true)
public class Test {
    @Id
    Long id;
    @Field(type = FieldType.Text)
    String name;
? ? //坐標(biāo)對象
    @GeoPointField
    GeoPoint location;
}

5. 訪問層Repository

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.data.geo.Distance;
import org.springframework.data.geo.Point;

import java.util.List;

public interface TestRepository extends ElasticsearchRepository<Test,Long> {
? ? /**
     * 根據(jù)范圍獲取數(shù)據(jù)
     * @param point x y 對應(yīng)經(jīng)緯度
     * @param distance 范圍
     * @return
     */
    List<Test> findByLocationNear(Point point, Distance distance);
}

此處的方法用法可以根據(jù)需求來

例如：findByLocationNearandAndName(Point point, Distance distance,String name);

返回值可以參考：

6. 使用

@SpringBootApplication
@EnableElasticsearchRepositories
public class Run {
    public static void main(String[] args) {
        ConfigurableApplicationContext run = SpringApplication.run(Run.class, args);
        TestRepository testRepository = run.getBean(TestRepository.class);
        Test test = testRepository.save(new Test(new Long(10001), "來打我啊", new GeoPoint().reset(50.2, 50.222)));
        System.out.println(test.toString());

        List<Test> list = testRepository.findByLocationNear(new Point(50.0,50.0), new Distance(100, Metrics.KILOMETERS));
        System.out.println("100KM內(nèi)有:");
        list.forEach(ts -> {
            System.out.println(ts.toString());
        });
        List<Test> list2 = testRepository.findByLocationNear(new Point(50.0,50.0), new Distance(10, Metrics.KILOMETERS));
        System.out.println("10KM內(nèi)有:");
        list2.forEach(ts -> {
            System.out.println(ts.toString());
        });
? ? }
}

new Distance(參1，參2);

參1：距離

參2：單位

調(diào)用新增 結(jié)果：

調(diào)用查詢 結(jié)果：

結(jié)束（有問題可以評論區(qū)或私信）文章來源地址http://www.zghlxwxcb.cn/news/detail-406014.html