当前位置：首页 > news >正文

Redis根据中心点坐标和半径筛选符合的数据

news 2025/7/15 11:11:34

1.启动Redis编辑

2.导入maven依赖

3.添加redis配置

4.编写RedisService

5.使用

6.验证

1.启动Redis

2.导入maven依赖

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

3.添加redis配置

spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=6379
#Redis服务器连接密码（默认为空）
spring.redis.password=
#连接超时时间（毫秒）
spring.redis.timeout=30000

4.编写RedisService

package com.zsp.quartz.service.impl;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.geo.Circle;
import org.springframework.data.geo.Distance;
import org.springframework.data.geo.GeoResults;
import org.springframework.data.geo.Point;
import org.springframework.data.redis.connection.RedisGeoCommands;
import org.springframework.data.redis.core.GeoOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;@Service
public class RedisService {@Autowiredprivate RedisTemplate<String, String> redisTemplate;// 存入redispublic void setValue(String key, String value) {ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();valueOperations.set(key, value);}// 从redis取值public String getValue(String key) {ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();return valueOperations.get(key);}// 存入redis带过期时间public void setValue(String key, String value, long expirationTimeInSeconds) {ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();valueOperations.set(key, value, expirationTimeInSeconds, TimeUnit.SECONDS);}/*** 添加地理位置信息,附加名字* @param key 存入redis的key* @param longitude 经度* @param latitude  纬度* @param member   附加值 这里附加了名字*/ public void addLocation(String key, double longitude, double latitude, String member) {Point point = new Point(longitude, latitude);GeoOperations<String, String> geoOps = redisTemplate.opsForGeo();geoOps.add(key, point, member);}/*** 获取地理位置信息* @param key 存入redis的key* @param longitude 中心点经度* @param latitude  中心点纬度* @param radius 筛选半径* @return*/public GeoResults<RedisGeoCommands.GeoLocation<String>> getLocationsInRadius(String key, double longitude, double latitude, double radius) {Point point = new Point(longitude, latitude);Distance distance = new Distance(radius);Circle circle = new Circle(point, distance);GeoOperations<String, String> geoOps = redisTemplate.opsForGeo();return geoOps.radius(key, circle);}
}

5.使用

 @AutowiredRedisService redisService;@Testvoid testForGeo(){redisService.addLocation("locations", 13.361389, 38.115556, "Paris");redisService.addLocation("locations", 13.4125, 39.523333, "Berlin");redisService.addLocation("locations", -0.127758, 51.507351, "London");GeoResults<RedisGeoCommands.GeoLocation<String>> locations = redisService.getLocationsInRadius("locations", 13.361389, 38.115556, 500000);for (GeoResult<RedisGeoCommands.GeoLocation<String>> location : locations) {System.out.println(location.getContent().getName());}}