Redis存儲(chǔ)經(jīng)緯度信息的實(shí)現(xiàn)
適應(yīng)場(chǎng)景
在一些向用戶提供天氣信息的業(yè)務(wù)場(chǎng)景中,我們通常會(huì)通過前端獲取用戶經(jīng)緯度信息,傳遞給后端作為參數(shù)進(jìn)行外部天氣接口調(diào)用,從而獲取用戶所在位置的天氣信息。
但是一旦用戶量級(jí)上來了或者該功能被頻繁觸發(fā)時(shí),調(diào)用外部天氣接口的成本會(huì)變得非常高昂。但是對(duì)于天氣信息來說,并不需要每次都實(shí)時(shí)調(diào)用外部接口獲取最新的天氣信息,因?yàn)樘鞖庑畔⒌淖兓l率并不是特別高,甚至相近位置的天氣信息也會(huì)非常相似。
因此我們可以通過在Redis中存儲(chǔ)經(jīng)緯度信息和對(duì)應(yīng)的天氣信息,在每次請(qǐng)求時(shí),先查詢Redis中是否存在相近位置的天氣信息,如果存在則直接返回緩存的天氣信息,如果不存在則調(diào)用外部天氣接口獲取最新的天氣信息,并將其存儲(chǔ)在Redis中以備下次使用。
設(shè)計(jì)思路
- 經(jīng)緯度信息存儲(chǔ):使用Redis的地理位置(GEO)數(shù)據(jù)結(jié)構(gòu)來存儲(chǔ)用戶的經(jīng)緯度信息。通過
GEOADD命令將經(jīng)緯度信息添加到Redis中。 - 天氣信息存儲(chǔ):將天氣信息存儲(chǔ)在Redis的字符串(STRING)數(shù)據(jù)結(jié)構(gòu)中,使用經(jīng)緯度信息作為鍵,天氣信息作為值。
- 查詢邏輯:
- 當(dāng)用戶請(qǐng)求天氣信息時(shí),首先使用
GEORADIUS命令查詢Redis中是否存在相近位置的經(jīng)緯度信息。 - 如果存在,則使用
GET命令獲取對(duì)應(yīng)的天氣信息。- 若天氣信息存在且未過期,則直接返回該信息。
- 若天氣信息不存在或已過期,則調(diào)用外部天氣接口獲取最新的天氣信息,并刪除舊的經(jīng)緯度信息,然后重新存儲(chǔ)新的經(jīng)緯度和天氣信息。
- 如果不存在,則調(diào)用外部天氣接口獲取最新的天氣信息,并使用
SET命令將其存儲(chǔ)在Redis中,同時(shí)使用GEOADD命令將經(jīng)緯度信息添加到Redis中。
- 當(dāng)用戶請(qǐng)求天氣信息時(shí),首先使用
- 過期策略:為了確保天氣信息的時(shí)效性,可以為存儲(chǔ)的天氣信息設(shè)置過期時(shí)間(TTL),例如30分鐘或1小時(shí),超過該時(shí)間后需要重新調(diào)用外部接口獲取最新的天氣信息。由于Redis的GEO數(shù)據(jù)結(jié)構(gòu)不支持直接設(shè)置過期時(shí)間,可以在發(fā)現(xiàn)天氣信息過期時(shí),刪除對(duì)應(yīng)的經(jīng)緯度信息。
代碼實(shí)現(xiàn)
示例代碼選用Java語(yǔ)言實(shí)現(xiàn),使用Spring Boot框架。
<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
引入Spring Data Redis依賴,并在application.yml中配置Redis連接信息。
@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; // 天氣信息過期時(shí)間,單位秒
public String getWeather(String latitude, String longitude) {
// 查詢8公里內(nèi)最近的經(jīng)緯度信息
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();
// 獲取對(duì)應(yīng)的天氣信息
String weatherKey = WEATHER_KEY_PREFIX + locationKey;
String cachedWeather = redisTemplate.opsForValue().get(weatherKey);
if (cachedWeather != null) {
return cachedWeather; // 返回緩存的天氣信息
} else {
// 天氣信息過期,刪除舊的經(jīng)緯度信息
redisTemplate.opsForGeo().remove(WEATHER_GEO_KEY, locationKey);
}
}
// 調(diào)用外部天氣接口獲取最新的天氣信息
String newWeatherInfo = fetchWeatherFromExternalApi(latitude, longitude);
// 存儲(chǔ)新的經(jīng)緯度和天氣信息
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) {
// 這里實(shí)現(xiàn)調(diào)用外部天氣接口的邏輯
}
}
在上述代碼中,我們定義了一個(gè)WeatherService類,包含了獲取天氣信息的邏輯。首先通過GEORADIUS命令查詢8公里內(nèi)最近的經(jīng)緯度信息,如果找到則嘗試獲取對(duì)應(yīng)的天氣信息;如果天氣信息不存在或已過期,則調(diào)用外部天氣接口獲取最新的天氣信息,并將其存儲(chǔ)在Redis中,同時(shí)更新經(jīng)緯度信息。
通過這種方式,我們可以有效地減少對(duì)外部天氣接口的調(diào)用頻率,提高系統(tǒng)的響應(yīng)速度和穩(wěn)定性。
到此這篇關(guān)于Redis存儲(chǔ)經(jīng)緯度信息的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Redis存儲(chǔ)經(jīng)緯度信息內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Redis客戶端連接遠(yuǎn)程Redis服務(wù)器方式
這篇文章主要介紹了Redis客戶端連接遠(yuǎn)程Redis服務(wù)器方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-06-06
redis命令行查看中文不亂碼的方法(十六進(jìn)制字符串處理)
這篇文章主要給大家介紹了關(guān)于redis命令行查看中文不亂碼的方法,其中詳細(xì)介紹了十六進(jìn)制字符串處理的相關(guān)資料,文中給出了詳細(xì)的示例代碼,供大家參考學(xué)習(xí),下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2017-10-10
詳解Redis如何優(yōu)雅地實(shí)現(xiàn)接口防刷
這篇文章主要為大家詳細(xì)介紹了Redis優(yōu)雅地實(shí)現(xiàn)接口防刷的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03
淺談redis的maxmemory設(shè)置以及淘汰策略
下面小編就為大家?guī)硪黄獪\談redis的maxmemory設(shè)置以及淘汰策略。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-03-03

