Elasticsearch-经纬度查询(8.x)

2024-06-11 08:20
文章标签 查询 elasticsearch 经纬度

本文主要是介绍Elasticsearch-经纬度查询(8.x)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一、开发环境

二、pom文件

三、ES配置文件

四、ES相关字段

五、ES半径查询

ES的字段类型:geo_point，可以实现以一个点为中心的半径查询(geo_distance query)

ES地理位置查询:

  • 半径查询(geo_distance query)
  • 查询指定矩形内的数据(geo_bounding_box query)
  • 查询指定多边形内的数据(geo_polygon query)

官方文档：Geo queries | Elasticsearch Guide [8.14] | Elastic

本案例实现以某个点的经纬，查询半径查询，并计算出其他点和中心点的距离

一、开发环境

工具版本
JDK21
SpringBoot3.2.4
ElasticSearch8.13.2

二、pom文件

        <!-- Elasticsearch Java API Client --><dependency><groupId>co.elastic.clients</groupId><artifactId>elasticsearch-java</artifactId><version>8.13.2</version></dependency>

三、ES配置文件

properties:

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;import java.util.List;/*** ES 配置属性** @author meng* @date 2024-05-07*/
@Data
@ConfigurationProperties(prefix = "es")
public class ElasticsearchProperties {/*** es 请求方式*/private String scheme;/*** es 集群host ip 地址*/private List<String> hosts;/*** es 账号*/private String username;/*** es 密码*/private String password;/*** es 连接超时时间*/private Integer connectTimeOut;/*** es socket 连接超时时间*/private Integer socketTimeOut;/*** es 请求超时时间*/private Integer connectionRequestTimeOut;/*** es 最大连接数*/private Integer maxConnectNum;/*** es 每个路由的最大连接数*/private Integer maxConnectNumPerRoute;
}

config:

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.ssl.SSLContextBuilder;
import org.apache.http.ssl.TrustStrategy;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.net.ssl.SSLContext;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.time.Duration;/*** ES 配置类，当 es.enable=true 时自动配置** @author meng* @date 2024-05-07*/
@Slf4j
@Configuration
@EnableConfigurationProperties(value = ElasticsearchProperties.class)
@ConditionalOnProperty(prefix = "es", name = "enable")
public class ElasticsearchConfig {@Bean(name = "ElasticsearchClient")public ElasticsearchClient initClient(ElasticsearchProperties elasticsearchProperties) {HttpHost[] esHosts = elasticsearchProperties.getHosts().stream().filter(StringUtils::isNotBlank).map(it -> {String[] split = it.split(":");return new HttpHost(split[0], Integer.parseInt(split[1]), elasticsearchProperties.getScheme());}).toArray(HttpHost[]::new);final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials(elasticsearchProperties.getUsername(),elasticsearchProperties.getPassword()));RestClientBuilder restClientBuilder = RestClient.builder(esHosts);// 连接延时配置restClientBuilder.setRequestConfigCallback(requestConfigBuilder -> {requestConfigBuilder.setConnectTimeout(elasticsearchProperties.getConnectTimeOut());requestConfigBuilder.setSocketTimeout(elasticsearchProperties.getSocketTimeOut());requestConfigBuilder.setConnectionRequestTimeout(elasticsearchProperties.getConnectionRequestTimeOut());return requestConfigBuilder;});// HttpClient 连接数配置restClientBuilder.setHttpClientConfigCallback(httpClientBuilder -> {httpClientBuilder.setMaxConnTotal(elasticsearchProperties.getMaxConnectNum());httpClientBuilder.setMaxConnPerRoute(elasticsearchProperties.getMaxConnectNumPerRoute());return httpClientBuilder;});// 设置keepalive时间restClientBuilder.setHttpClientConfigCallback(requestConfig ->requestConfig.setKeepAliveStrategy((response, context) -> Duration.ofMinutes(3).toMillis()));// 忽略HTTPS方式链接，SSL证书、主机名验证器restClientBuilder.setHttpClientConfigCallback(httpAsyncClientBuilder -> {httpAsyncClientBuilder.disableAuthCaching();httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider);try {// 创建一个信任所有证书的 TrustStrategy 策略TrustStrategy acceptTrustStrategy = (chain, authType) -> true;// 使用 SSLContextBuilder 创建 SSLContextSSLContext sslContext = SSLContextBuilder.create().loadTrustMaterial(null, acceptTrustStrategy).build();httpAsyncClientBuilder.setSSLContext(sslContext);} catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) {e.printStackTrace();}// 忽略主机名验证httpAsyncClientBuilder.setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE);return httpAsyncClientBuilder;});RestClient restClient = restClientBuilder.build();// 使用Jackson映射器创建传输层ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());ElasticsearchClient client = new ElasticsearchClient(transport);return client;}}

四、ES相关字段

五、ES半径查询

具体查询对象，可自行定义，本方法只提供思路，莫直接粘贴使用

	@Resourceprivate ElasticsearchClient esClient;/*** 功能描述: 根据经纬度判断十米内是否有poi数据** @Param: [request]* @Author: meng* @Date: 2024/6/6 19:57*/private PoiDTO getPoiNear(PoiRequest request) {if (Objects.isNull(request.getLongitude()) && Objects.isNull(request.getLatitude())) {return null;}// 中心点查询GeoLocation geoLocation = new GeoLocation.Builder().latlon(l -> l.lon(request.getLongitude().doubleValue()).lat(request.getLatitude().doubleValue())).build();GeoDistanceQuery geoDistanceQuery = GeoDistanceQuery.of(geoDis -> geoDis.field(PoiIndexConstant.LOCATION).location(geoLocation).distance(PoiIndexConstant.DISTANCE).distanceType(GeoDistanceType.Arc));// 排序List<SortOptions> sorts = new ArrayList<>();// 距离排序 米GeoDistanceSort geoDistanceSort = GeoDistanceSort.of(geoDis -> geoDis.field(PoiIndexConstant.LOCATION).location(geoLocation).order(SortOrder.Asc).unit(DistanceUnit.Meters));SortOptions sortOptions = SortOptions.of(sort -> sort.geoDistance(geoDistanceSort));sorts.add(sortOptions);SearchRequest.Builder searchRequestBuilder = new SearchRequest.Builder();searchRequestBuilder.index(PoiIndexConstant.INDEX_READ).query(query -> query.bool(builder -> builder.filter(f -> f.geoDistance(geoDistanceQuery)))).sort(sorts).size(CommonConstant.DEFAULT_NUM);// ES查询SearchRequest searchRequest = searchRequestBuilder.build();log.info("getPoiNear query:{}", searchRequest.toString());try {SearchResponse<PoiIndex> searchResponse = esClient.search(searchRequest, PoiIndex.class);// 未查到数据if (Objects.nonNull(searchResponse.hits().total()) && searchResponse.hits().total().value() == 0) {return null;}for (Hit<PoiIndex> hit : searchResponse.hits().hits()) {if (ObjectUtil.isNotNull(hit.source())) {PoiIndex poiIndex = BeanUtil.copyProperties(hit.source(), PoiIndex.class);return BeanUtil.copyProperties(poiIndex, PoiDTO.class);}}} catch (Exception e) {log.error("es searchRequest Exception:", e);throw new ServiceException("searchRequest Exception");}return null;}

这篇关于Elasticsearch-经纬度查询(8.x)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1050639。

相关文章

Java操作ElasticSearch的实例详解

Java操作ElasticSearch的实例详解

《Java操作ElasticSearch的实例详解》Elasticsearch是一个分布式的搜索和分析引擎,广泛用于全文搜索、日志分析等场景,本文将介绍如何在Java应用中使用Elastics... 目录简介环境准备1. 安装 Elasticsearch2. 添加依赖连接 Elasticsearch1. 创
阅读更多...
MySQL不使用子查询的原因及优化案例

MySQL不使用子查询的原因及优化案例

《MySQL不使用子查询的原因及优化案例》对于mysql,不推荐使用子查询,效率太差,执行子查询时,MYSQL需要创建临时表,查询完毕后再删除这些临时表,所以,子查询的速度会受到一定的影响,本文给大家... 目录不推荐使用子查询和JOIN的原因解决方案优化案例案例1：查询所有有库存的商品信息案例2：使用EX
阅读更多...
SpringBoot基于MyBatis-Plus实现Lambda Query查询的示例代码

SpringBoot基于MyBatis-Plus实现Lambda Query查询的示例代码

《SpringBoot基于MyBatis-Plus实现LambdaQuery查询的示例代码》MyBatis-Plus是MyBatis的增强工具,简化了数据库操作,并提高了开发效率,它提供了多种查询方... 目录引言基础环境配置依赖配置（Maven）application.yml 配置表结构设计demo_st
阅读更多...
如何用Java结合经纬度位置计算目标点的日出日落时间详解

如何用Java结合经纬度位置计算目标点的日出日落时间详解

《如何用Java结合经纬度位置计算目标点的日出日落时间详解》这篇文章主详细讲解了如何基于目标点的经纬度计算日出日落时间,提供了在线API和Java库两种计算方法,并通过实际案例展示了其应用,需要的朋友... 目录前言一、应用示例1、天安门升旗时间2、湖南省日出日落信息二、Java日出日落计算1、在线API2
阅读更多...
Redis KEYS查询大批量数据替代方案

Redis KEYS查询大批量数据替代方案

《RedisKEYS查询大批量数据替代方案》在使用Redis时,KEYS命令虽然简单直接,但其全表扫描的特性在处理大规模数据时会导致性能问题,甚至可能阻塞Redis服务,本文将介绍SCAN命令、有序... 目录前言KEYS命令问题背景替代方案1.使用 SCAN 命令2. 使用有序集合（Sorted Set）
阅读更多...
MyBatis框架实现一个简单的数据查询操作

MyBatis框架实现一个简单的数据查询操作

《MyBatis框架实现一个简单的数据查询操作》本文介绍了MyBatis框架下进行数据查询操作的详细步骤,括创建实体类、编写SQL标签、配置Mapper、开启驼峰命名映射以及执行SQL语句等,感兴趣的... 基于在前面几章我们已经学习了对MyBATis进行环境配置，并利用SqlSessionFactory核
阅读更多...
PostgreSQL如何查询表结构和索引信息

PostgreSQL如何查询表结构和索引信息

《PostgreSQL如何查询表结构和索引信息》文章介绍了在PostgreSQL中查询表结构和索引信息的几种方法,包括使用`d`元命令、系统数据字典查询以及使用可视化工具DBeaver... 目录前言使用\d元命令查看表字段信息和索引信息通过系统数据字典查询表结构通过系统数据字典查询索引信息查询所有的表名可
阅读更多...
基于MySQL Binlog的Elasticsearch数据同步实践

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展，我们的业务数据越来越多，单纯使用 MySQL 已经不能满足我们的数据查询需求，例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后，随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步，我们目前的解决方案是建立数据中间表。把需要检索的业务数据，统一放到一张M
阅读更多...
活用c4d官方开发文档查询代码

活用c4d官方开发文档查询代码

当你问AI助手比如豆包，如何用python禁止掉xpresso标签时候，它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来
阅读更多...
ural 1026. Questions and Answers 查询

ural 1026. Questions and Answers 查询

1026. Questions and Answers Time limit: 2.0 second Memory limit: 64 MB Background The database of the Pentagon contains a top-secret information. We don’t know what the information is — you
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2