重学SpringBoot3-集成Redis（十一）之地理位置数据存储

更多SpringBoot3内容请关注我的专栏：《SpringBoot3》
期待您的点赞👍收藏⭐评论✍

重学SpringBoot3-集成Redis（十一）之地理位置数据存储

Redis 是一个强大的内存数据存储工具，不仅可以用来缓存和存储传统数据，还支持存储地理位置信息。通过 Redis 提供的 GEO 命令集，开发者可以方便地进行地理位置的存储、查询和计算操作。本文将介绍如何通过 Spring Boot 3 与 Redis 集成来实现地理位置数据存储功能，并进行相关的操作。

1. GEO 命令简介

Redis 的 GEO 命令主要用于存储经纬度和关联的数据，并支持基于这些数据进行距离计算和范围查询。常用的 GEO 命令有：

• GEOADD：添加地理位置。
• GEOPOS：获取指定成员的地理位置（经纬度）。
• GEODIST：计算两个地理位置之间的距离。
• GEORADIUS：以给定的经纬度为中心，查询某个范围内的地理位置。
• GEORADIUSBYMEMBER：以给定的成员位置为中心，查询某个范围内的地理位置。

2. 项目环境配置

2.1. 依赖引入

首先，在

pom.xml

中引入 Spring Boot 3 和 Redis 的相关依赖，具体参考重学SpringBoot3-集成Redis（一）之基本使用：

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

2.2. Redis 配置

在

application.yml

中配置 Redis 连接：

spring:data:redis:host: localhost
      port:6379# Redis 端口password: redis123456 # 如果有密码可以在这里配置lettuce:pool:max-active:100# 最大并发连接数max-idle:50# 最大空闲连接数min-idle:10# 最小空闲连接数

3. GEO 数据存储和查询实现

3.1. 服务层实现

我们将通过

StringRedisTemplate

来操作 Redis 的 GEO 命令。

packagecom.coderjia.boot310redis.service;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.geo.Distance;importorg.springframework.data.geo.GeoResult;importorg.springframework.data.geo.GeoResults;importorg.springframework.data.geo.Point;importorg.springframework.data.redis.connection.RedisGeoCommands;importorg.springframework.data.redis.core.StringRedisTemplate;importorg.springframework.stereotype.Service;importjava.util.ArrayList;importjava.util.List;/**
 * @author CoderJia
 * @create 2024/10/9 下午 10:10
 * @Description
 **/@ServicepublicclassGeoLocationService{@AutowiredprivateStringRedisTemplate redisTemplate;privatestaticfinalString GEO_KEY ="city_locations";// 添加地理位置publicvoidaddGeoLocation(String cityName,double longitude,double latitude){
        redisTemplate.opsForGeo().add(GEO_KEY,newPoint(longitude, latitude), cityName);}// 获取地理位置publicPointgetGeoLocation(String cityName){List<Point> positions = redisTemplate.opsForGeo().position(GEO_KEY, cityName);return positions !=null&&!positions.isEmpty()? positions.get(0):null;}// 计算两个城市之间的距离publicDistancegetDistance(String city1,String city2){return redisTemplate.opsForGeo().distance(GEO_KEY, city1, city2,RedisGeoCommands.DistanceUnit.KILOMETERS);}// 查找指定范围内的城市publicList<String>getCitiesWithinRadius(String cityName,double radius){GeoResults<RedisGeoCommands.GeoLocation<String>> results = redisTemplate.opsForGeo().radius(GEO_KEY, cityName,newDistance(radius,RedisGeoCommands.DistanceUnit.KILOMETERS));List<String> cities =newArrayList<>();if(results !=null){for(GeoResult<RedisGeoCommands.GeoLocation<String>> result : results){
                cities.add(result.getContent().getName());}}return cities;}}

3.2. 控制层

为了方便测试，我们可以通过简单的控制器来调用这些服务。

packagecom.coderjia.boot310redis.demos.web;importcom.coderjia.boot310redis.service.GeoLocationService;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.geo.Distance;importorg.springframework.data.geo.Point;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.PostMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RequestParam;importorg.springframework.web.bind.annotation.RestController;importjava.util.List;/**
 * @author CoderJia
 * @create 2024/10/9 下午 10:14
 * @Description
 **/@RestController@RequestMapping("/geo")publicclassGeoLocationController{@AutowiredprivateGeoLocationService geoLocationService;// 添加城市位置@PostMapping("/add")publicStringaddCity(@RequestParam("city")String city,@RequestParam("lon")double lon,@RequestParam("lat")double lat){
        geoLocationService.addGeoLocation(city, lon, lat);return"Added "+ city;}// 查询城市位置@GetMapping("/location")publicPointgetCityLocation(@RequestParam("city")String city){return geoLocationService.getGeoLocation(city);}// 计算两个城市之间的距离@GetMapping("/distance")publicDistancegetDistance(@RequestParam("city1")String city1,@RequestParam("city2")String city2){return geoLocationService.getDistance(city1, city2);}// 查找指定城市附近的城市@GetMapping("/nearby")publicList<String>getNearbyCities(@RequestParam("city")String city,@RequestParam("radius")double radius){return geoLocationService.getCitiesWithinRadius(city, radius);}}

4. 使用示例

4.1. 添加城市位置信息

通过

POST

请求添加城市位置信息，城市经纬度查询参考：https://lbs.amap.com/tools/picker

添加北上广深杭五座城市：

POST localhost:8080/geo/add?city=Beijing&lon=116.40&lat=39.90
POST localhost:8080/geo/add?city=Shanghai&lon=121.47&lat=31.23
POST localhost:8080/geo/add?city=GuangZhou&lon=113.26&lat=23.14
POST localhost:8080/geo/add?city=ShenZhen&lon=114.06&lat=22.54
POST localhost:8080/geo/add?city=HangZhou&lon=120.12&lat=30.22

4.2. 查询城市位置信息

查询城市的经纬度信息：

GET localhost:8080/geo/location?city=Beijing

4.3. 计算两城市之间的距离

计算两个城市之间的距离：

GET localhost:8080/geo/distance?city1=Beijing&city2=Shanghai

4.4. 查询指定城市附近的其他城市

查询上海附近的其他城市（比如 200 公里内的城市）：

GET localhost:8080/geo/nearby?city=Shanghai&radius=200

5. 总结

通过 Redis 的 GEO 命令集与 Spring Boot 3 集成，我们可以轻松实现地理位置的存储与查询功能。这种方式不仅方便，而且具有很高的性能，尤其适用于地理位置相关的应用场景，如地图服务、物流系统、附近商家查询等。

使用 Redis 进行地理位置存储的优势在于其操作简单、高效，并且能够借助 Redis 内置的命令进行实时的距离计算和范围查询。如果你的应用涉及地理信息，Redis 提供的 GEO 功能会是一个非常不错的选择。