Redis存储经纬度信息的实现

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

spring:
  redis:
    host: localhost
    port: 6379

@Service
public class WeatherService {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    private static final String WEATHER_GEO_KEY = "weather:locations";
    private static final String WEATHER_KEY_PREFIX = "weather:";
    private static final long WEATHER_TTL = 3600; // 天气信息过期时间，单位秒

    public String getWeather(String latitude, String longitude) {
        // 查询8公里内最近的经纬度信息
        double lon = Double.parseDouble(longitude);
        double lat = Double.parseDouble(latitude);
        Point point = new Point(lon, lat);
        Distance distance = new Distance(8, Metrics.KILOMETERS);
        Circle circle = new Circle(point, distance);

        var geoResults = redisTemplate.opsForGeo().radius(WEATHER_GEO_KEY, circle,
                RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs().includeDistance().sortAscending().limit(1));

        if (geoResults != null && !geoResults.getContent().isEmpty()) {
            var nearestLocation = geoResults.getContent().get(0);
            String locationKey = nearestLocation.getContent().getName();

            // 获取对应的天气信息
            String weatherKey = WEATHER_KEY_PREFIX + locationKey;
            String cachedWeather = redisTemplate.opsForValue().get(weatherKey);
            if (cachedWeather != null) {
                return cachedWeather; // 返回缓存的天气信息
            } else {
                // 天气信息过期，删除旧的经纬度信息
                redisTemplate.opsForGeo().remove(WEATHER_GEO_KEY, locationKey);
            }
        }

        // 调用外部天气接口获取最新的天气信息
        String newWeatherInfo = fetchWeatherFromExternalApi(latitude, longitude);

        // 存储新的经纬度和天气信息
        String locationKey = latitude + ":" + longitude;
        redisTemplate.opsForGeo().add(WEATHER_GEO_KEY, new Point(lon, lat), locationKey);
        String weatherKey = WEATHER_KEY_PREFIX + locationKey;
        redisTemplate.opsForValue().set(weatherKey, newWeatherInfo, Duration.ofSeconds(WEATHER_TTL));

        return newWeatherInfo;
    }

    private String fetchWeatherFromExternalApi(String latitude, String longitude) {
        // 这里实现调用外部天气接口的逻辑
    }

}