Redis用GEO實(shí)現(xiàn)附近的人功能
??概述
GEO
就是Geolocation
的簡(jiǎn)寫(xiě)形式,代表地理坐標(biāo)。Redis在3.2版本中加入了對(duì)GEO的支持,允許存儲(chǔ)地理坐標(biāo)信息,幫助我們根據(jù)經(jīng)緯度來(lái)檢索數(shù)據(jù)。常見(jiàn)的命令有:
- GEOADD:添加一個(gè)地理空間信息,包含:經(jīng)度(longitude)、緯度(latitude)、值(member)
- GEODIST:計(jì)算指定的兩個(gè)點(diǎn)之間的距離并返回
- GEOHASH:將指定member的坐標(biāo)轉(zhuǎn)為hash字符串形式并返回
- GEOPOS:返回指定member的坐標(biāo)
- GEORADIUS:指定圓心、半徑,找到該圓內(nèi)包含的所有member,并按照與圓心之間的距離排序后返回。6.以后已廢棄
- GEOSEARCH:在指定范圍內(nèi)搜索member,并按照與指定點(diǎn)之間的距離排序后返回。范圍可以是圓形或矩形。6.2.新功能
- GEOSEARCHSTORE:與GEOSEARCH功能一致,不過(guò)可以把結(jié)果存儲(chǔ)到一個(gè)指定的key。 6.2.新功能
??命令演示
- 我們先來(lái)看看
GEOADD
命令,它用于添加地理空間信息。
我會(huì)以一個(gè)簡(jiǎn)單的例子來(lái)演示:
GEOADD places 13.361389 38.115556 "Palermo" 15.087269 37.502669 "Catania"
這個(gè)命令將在名為 places 的地理空間集合中添加兩個(gè)地點(diǎn),分別是 “Palermo” 和 “Catania”。它們的經(jīng)緯度分別是 (13.361389, 38.115556) 和 (15.087269, 37.502669)。
- 接下來(lái)是
GEODIST
命令,它用于計(jì)算兩個(gè)地點(diǎn)之間的距離。我們可以這樣演示:
GEODIST places "Palermo" "Catania" km
這個(gè)命令將計(jì)算 “Palermo” 和 “Catania” 之間的距離,并以千米為單位返回距離值。
- 接著是
GEOHASH
命令,它將地點(diǎn)的坐標(biāo)轉(zhuǎn)換為哈希字符串形式:
GEOHASH places "Palermo"
這個(gè)命令會(huì)返回 “Palermo” 的坐標(biāo)哈希字符串。
- 下一個(gè)是
GEOPOS
命令,它返回指定地點(diǎn)的坐標(biāo):
GEOPOS places "Palermo"
這個(gè)命令會(huì)返回 “Palermo” 的經(jīng)緯度坐標(biāo)。
- 然后是
GEORADIUS
命令,不過(guò)請(qǐng)注意這個(gè)命令在 Redis 6 版本后已經(jīng)廢棄了,我們可以使用 GEOSEARCH 來(lái)替代:
GEOSEARCH places FROMMEMBER "Palermo" BYRADIUS 100 km SORT ASC
這個(gè)命令會(huì)在以 “Palermo” 為圓心、100 千米為半徑的范圍內(nèi)搜索,并按照與 “Palermo” 之間的距離升序排序。
- 最后是
GEOSEARCHSTORE
命令,它與 GEOSEARCH 功能類(lèi)似,但可以將結(jié)果存儲(chǔ)到指定的鍵中:
GEOSEARCHSTORE places_results places FROMMEMBER "Palermo" BYRADIUS 100 km SORT ASC STORE myresults
這個(gè)命令會(huì)將搜索結(jié)果存儲(chǔ)到名為 myresults 的鍵中。
??API將數(shù)據(jù)庫(kù)表中的數(shù)據(jù)導(dǎo)入到redis中去
將數(shù)據(jù)庫(kù)表中的數(shù)據(jù)導(dǎo)入到redis中去,redis中的GEO,GEO在redis中就一個(gè)menber和一個(gè)經(jīng)緯度,我們把x和y軸傳入到redis做的經(jīng)緯度位置去,但我們不能把所有的數(shù)據(jù)都放入到menber中去,畢竟作為redis是一個(gè)內(nèi)存級(jí)數(shù)據(jù)庫(kù),如果存海量數(shù)據(jù),redis還是力不從心,所以我們?cè)谶@個(gè)地方存儲(chǔ)他的id即可。
但是這個(gè)時(shí)候還有一個(gè)問(wèn)題,就是在redis中并沒(méi)有存儲(chǔ)type,所以我們無(wú)法根據(jù)type來(lái)對(duì)數(shù)據(jù)進(jìn)行篩選,所以我們可以按照商戶(hù)類(lèi)型做分組,類(lèi)型相同的商戶(hù)作為同一組,以typeId為key存入同一個(gè)GEO集合中即可
@Test void loadShopData() { // 1.查詢(xún)店鋪信息 List<Shop> list = shopService.list(); // 2.把店鋪分組,按照typeId分組,typeId一致的放到一個(gè)集合 Map<Long, List<Shop>> map = list.stream().collect(Collectors.groupingBy(Shop::getTypeId)); // 3.分批完成寫(xiě)入Redis for (Map.Entry<Long, List<Shop>> entry : map.entrySet()) { // 3.1.獲取類(lèi)型id Long typeId = entry.getKey(); String key = SHOP_GEO_KEY + typeId; // 3.2.獲取同類(lèi)型的店鋪的集合 List<Shop> value = entry.getValue(); List<RedisGeoCommands.GeoLocation<String>> locations = new ArrayList<>(value.size()); // 3.3.寫(xiě)入redis GEOADD key 經(jīng)度 緯度 member for (Shop shop : value) { // stringRedisTemplate.opsForGeo().add(key, new Point(shop.getX(), shop.getY()), shop.getId().toString()); locations.add(new RedisGeoCommands.GeoLocation<>( shop.getId().toString(), new Point(shop.getX(), shop.getY()) )); } stringRedisTemplate.opsForGeo().add(key, locations); } }
??實(shí)現(xiàn)附近功能
SpringDataRedis的2.3.9版本并不支持Redis 6.2提供的GEOSEARCH命令,因此我們需要提示其版本,修改自己的POM
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <exclusions> <exclusion> <artifactId>spring-data-redis</artifactId> <groupId>org.springframework.data</groupId> </exclusion> <exclusion> <artifactId>lettuce-core</artifactId> <groupId>io.lettuce</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>2.6.2</version> </dependency> <dependency> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> <version>6.1.6.RELEASE</version> </dependency>
實(shí)現(xiàn)
@GetMapping("/of/type") public Result queryShopByType( @RequestParam("typeId") Integer typeId, @RequestParam(value = "current", defaultValue = "1") Integer current, @RequestParam(value = "x", required = false) Double x, @RequestParam(value = "y", required = false) Double y ) { return shopService.queryShopByType(typeId, current, x, y); }
@Override public Result queryShopByType(Integer typeId, Integer current, Double x, Double y) { // 1.判斷是否需要根據(jù)坐標(biāo)查詢(xún) if (x == null || y == null) { // 不需要坐標(biāo)查詢(xún),按數(shù)據(jù)庫(kù)查詢(xún) Page<Shop> page = query() .eq("type_id", typeId) .page(new Page<>(current, SystemConstants.DEFAULT_PAGE_SIZE)); // 返回?cái)?shù)據(jù) return Result.ok(page.getRecords()); } // 2.計(jì)算分頁(yè)參數(shù) int from = (current - 1) * SystemConstants.DEFAULT_PAGE_SIZE; int end = current * SystemConstants.DEFAULT_PAGE_SIZE; // 3.查詢(xún)r(jià)edis、按照距離排序、分頁(yè)。結(jié)果:shopId、distance String key = SHOP_GEO_KEY + typeId; GeoResults<RedisGeoCommands.GeoLocation<String>> results = stringRedisTemplate.opsForGeo() // GEOSEARCH key BYLONLAT x y BYRADIUS 10 WITHDISTANCE .search( key, GeoReference.fromCoordinate(x, y), new Distance(5000), RedisGeoCommands.GeoSearchCommandArgs.newGeoSearchArgs().includeDistance().limit(end) ); // 4.解析出id if (results == null) { return Result.ok(Collections.emptyList()); } List<GeoResult<RedisGeoCommands.GeoLocation<String>>> list = results.getContent(); if (list.size() <= from) { // 沒(méi)有下一頁(yè)了,結(jié)束 return Result.ok(Collections.emptyList()); } // 4.1.截取 from ~ end的部分 List<Long> ids = new ArrayList<>(list.size()); Map<String, Distance> distanceMap = new HashMap<>(list.size()); list.stream().skip(from).forEach(result -> { // 4.2.獲取店鋪id String shopIdStr = result.getContent().getName(); ids.add(Long.valueOf(shopIdStr)); // 4.3.獲取距離 Distance distance = result.getDistance(); distanceMap.put(shopIdStr, distance); }); // 5.根據(jù)id查詢(xún)Shop String idStr = StrUtil.join(",", ids); List<Shop> shops = query().in("id", ids).last("ORDER BY FIELD(id," + idStr + ")").list(); for (Shop shop : shops) { shop.setDistance(distanceMap.get(shop.getId().toString()).getValue()); } // 6.返回 return Result.ok(shops); }
到此這篇關(guān)于Redis用GEO實(shí)現(xiàn)附近的人功能的文章就介紹到這了,更多相關(guān)redis geo附近的人內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- Redis GEO實(shí)現(xiàn)搜索附近用戶(hù)的項(xiàng)目實(shí)踐
- Redis GEO地理信息定位功能
- Java中如何使用Redis GEO測(cè)算經(jīng)緯度距離
- 詳解Redis中地理位置功能Geospatial的應(yīng)用
- Redis特殊數(shù)據(jù)類(lèi)型Geospatial地理空間
- Redis之GEO存儲(chǔ)地理位置信息的使用
- Redis 的 GeoHash詳解
- Redis中3種特殊的數(shù)據(jù)類(lèi)型(BitMap、Geo和HyperLogLog)
- 使用redis實(shí)現(xiàn)附近的人功能
- Redis 實(shí)現(xiàn)“附近的人”功能
相關(guān)文章
Redis集群節(jié)點(diǎn)通信過(guò)程/原理流程分析
這篇文章主要介紹了Redis集群節(jié)點(diǎn)通信過(guò)程/原理,詳細(xì)介紹了Cluster(集群)的節(jié)點(diǎn)通信的流程,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-03-03windows環(huán)境下Redis+Spring緩存實(shí)例講解
這篇文章主要為大家詳細(xì)介紹了windows環(huán)境下Redis+Spring緩存實(shí)例教程,感興趣的小伙伴們可以參考一下2016-04-04Redis實(shí)現(xiàn)和數(shù)據(jù)庫(kù)的數(shù)據(jù)同步
本文介紹了Redis與傳統(tǒng)數(shù)據(jù)庫(kù)數(shù)據(jù)同步的幾種常見(jiàn)方法,包括CacheAside、WriteThrough、WriteBehind,以及如何通過(guò)分布式事務(wù)、樂(lè)觀鎖、數(shù)據(jù)過(guò)期策略和消息隊(duì)列來(lái)解決數(shù)據(jù)一致性問(wèn)題,每種方法都有其適用場(chǎng)景和優(yōu)缺點(diǎn),需要根據(jù)具體需求進(jìn)行選擇2025-01-01在Redis數(shù)據(jù)庫(kù)中實(shí)現(xiàn)分布式速率限制的方法
這篇文章主要介紹了在Redis數(shù)據(jù)庫(kù)中實(shí)現(xiàn)分布式速率限制的方法,文中展示了一個(gè)用Python編寫(xiě)的應(yīng)用示例,需要的朋友可以參考下2015-06-06壓縮列表犧牲速度來(lái)節(jié)省內(nèi)存,Redis是膨脹了嗎
這篇文章主要給大家解釋了Redis 當(dāng)中的 ziplist(壓縮列表)犧牲速度來(lái)節(jié)省內(nèi)存的原因,希望大家能夠喜歡2021-02-02基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消
這篇文章主要介紹了基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05Redis優(yōu)雅地實(shí)現(xiàn)延遲隊(duì)列的方法分享
Redisson是Redis服務(wù)器上的分布式可伸縮Java數(shù)據(jù)結(jié)構(gòu),這篇文中主要為大家介紹了Redisson實(shí)現(xiàn)的優(yōu)雅的延遲隊(duì)列的方法,需要的可以參考一下2023-02-02