欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Redis用GEO實(shí)現(xiàn)附近的人功能

 更新時(shí)間:2024年08月07日 14:37:28   作者:時(shí)間瑾  
GEO就是Geolocation的簡(jiǎn)寫(xiě)形式,代表地理坐標(biāo),這篇文章主要介紹了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)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Redis集群節(jié)點(diǎn)通信過(guò)程/原理流程分析

    Redis集群節(jié)點(diǎn)通信過(guò)程/原理流程分析

    這篇文章主要介紹了Redis集群節(jié)點(diǎn)通信過(guò)程/原理,詳細(xì)介紹了Cluster(集群)的節(jié)點(diǎn)通信的流程,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-03-03
  • windows環(huán)境下Redis+Spring緩存實(shí)例講解

    windows環(huán)境下Redis+Spring緩存實(shí)例講解

    這篇文章主要為大家詳細(xì)介紹了windows環(huán)境下Redis+Spring緩存實(shí)例教程,感興趣的小伙伴們可以參考一下
    2016-04-04
  • Redis主從實(shí)現(xiàn)讀寫(xiě)分離

    Redis主從實(shí)現(xiàn)讀寫(xiě)分離

    這篇文章主要為大家詳細(xì)介紹了Redis主從實(shí)現(xiàn)讀寫(xiě)分離的相關(guān)資料 ,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2016-10-10
  • Redis實(shí)現(xiàn)和數(shù)據(jù)庫(kù)的數(shù)據(jù)同步

    Redis實(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)分布式速率限制的方法

    這篇文章主要介紹了在Redis數(shù)據(jù)庫(kù)中實(shí)現(xiàn)分布式速率限制的方法,文中展示了一個(gè)用Python編寫(xiě)的應(yīng)用示例,需要的朋友可以參考下
    2015-06-06
  • 壓縮列表犧牲速度來(lái)節(jié)省內(nèi)存,Redis是膨脹了嗎

    壓縮列表犧牲速度來(lái)節(jié)省內(nèi)存,Redis是膨脹了嗎

    這篇文章主要給大家解釋了Redis 當(dāng)中的 ziplist(壓縮列表)犧牲速度來(lái)節(jié)省內(nèi)存的原因,希望大家能夠喜歡
    2021-02-02
  • Linux下redis的安裝與使用圖文教程

    Linux下redis的安裝與使用圖文教程

    這篇文章主要介紹了Linux下redis的安裝與使用,結(jié)合圖文形式分析了Linux環(huán)境下redis的下載、編譯、安裝、部署、訪(fǎng)問(wèn)等相關(guān)操作技巧,需要的朋友可以參考下
    2019-08-08
  • 基于Redis過(guò)期事件實(shí)現(xiàn)訂單超時(shí)取消

    基于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-05
  • 徹底弄懂Redis的LRU淘汰策略

    徹底弄懂Redis的LRU淘汰策略

    本文主要介紹了LRU淘汰策略以及實(shí)現(xiàn)一個(gè)LRU算法,文章會(huì)結(jié)合圖解循序漸進(jìn)的講解,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-01-01
  • Redis優(yōu)雅地實(shí)現(xiàn)延遲隊(duì)列的方法分享

    Redis優(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

最新評(píng)論