Redis用GEO实现附近的人功能_Redis

☃️概述

geo就是geolocation的简写形式，代表地理坐标。redis在3.2版本中加入了对geo的支持，允许存储地理坐标信息，帮助我们根据经纬度来检索数据。常见的命令有：

geoadd：添加一个地理空间信息，包含：经度（longitude）、纬度（latitude）、值（member）
geodist：计算指定的两个点之间的距离并返回
geohash：将指定member的坐标转为hash字符串形式并返回
geopos：返回指定member的坐标
georadius：指定圆心、半径，找到该圆内包含的所有member，并按照与圆心之间的距离排序后返回。6.以后已废弃
geosearch：在指定范围内搜索member，并按照与指定点之间的距离排序后返回。范围可以是圆形或矩形。6.2.新功能
geosearchstore：与geosearch功能一致，不过可以把结果存储到一个指定的key。 6.2.新功能

☃️命令演示

我们先来看看 geoadd 命令，它用于添加地理空间信息。

我会以一个简单的例子来演示：

geoadd places 13.361389 38.115556 "palermo" 15.087269 37.502669 "catania"
这个命令将在名为 places 的地理空间集合中添加两个地点，分别是 “palermo” 和 “catania”。它们的经纬度分别是 (13.361389, 38.115556) 和 (15.087269, 37.502669)。

接下来是 geodist 命令，它用于计算两个地点之间的距离。我们可以这样演示：

geodist places "palermo" "catania" km
这个命令将计算 “palermo” 和 “catania” 之间的距离，并以千米为单位返回距离值。

接着是 geohash 命令，它将地点的坐标转换为哈希字符串形式：

geohash places "palermo"
这个命令会返回 “palermo” 的坐标哈希字符串。

下一个是 geopos 命令，它返回指定地点的坐标：

geopos places "palermo"
这个命令会返回 “palermo” 的经纬度坐标。

然后是 georadius 命令，不过请注意这个命令在 redis 6 版本后已经废弃了，我们可以使用 geosearch 来替代：

geosearch places frommember "palermo" byradius 100 km sort asc
这个命令会在以 “palermo” 为圆心、100 千米为半径的范围内搜索，并按照与 “palermo” 之间的距离升序排序。

最后是 geosearchstore 命令，它与 geosearch 功能类似，但可以将结果存储到指定的键中：

geosearchstore places_results places frommember "palermo" byradius 100 km sort asc store myresults
这个命令会将搜索结果存储到名为 myresults 的键中。

☃️api将数据库表中的数据导入到redis中去

将数据库表中的数据导入到redis中去，redis中的geo，geo在redis中就一个menber和一个经纬度，我们把x和y轴传入到redis做的经纬度位置去，但我们不能把所有的数据都放入到menber中去，毕竟作为redis是一个内存级数据库，如果存海量数据，redis还是力不从心，所以我们在这个地方存储他的id即可。

但是这个时候还有一个问题，就是在redis中并没有存储type，所以我们无法根据type来对数据进行筛选，所以我们可以按照商户类型做分组，类型相同的商户作为同一组，以typeid为key存入同一个geo集合中即可

@test
void loadshopdata() {
    // 1.查询店铺信息
    list<shop> list = shopservice.list();
    // 2.把店铺分组，按照typeid分组，typeid一致的放到一个集合
    map<long, list<shop>> map = list.stream().collect(collectors.groupingby(shop::gettypeid));
    // 3.分批完成写入redis
    for (map.entry<long, list<shop>> entry : map.entryset()) {
        // 3.1.获取类型id
        long typeid = entry.getkey();
        string key = shop_geo_key + typeid;
        // 3.2.获取同类型的店铺的集合
        list<shop> value = entry.getvalue();
        list<redisgeocommands.geolocation<string>> locations = new arraylist<>(value.size());
        // 3.3.写入redis geoadd key 经度 纬度 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);
    }
}

☃️实现附近功能

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>

实现

@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.判断是否需要根据坐标查询
        if (x == null || y == null) {
            // 不需要坐标查询，按数据库查询
            page<shop> page = query()
                    .eq("type_id", typeid)
                    .page(new page<>(current, systemconstants.default_page_size));
            // 返回数据
            return result.ok(page.getrecords());
        }
        // 2.计算分页参数
        int from = (current - 1) * systemconstants.default_page_size;
        int end = current * systemconstants.default_page_size;
        // 3.查询redis、按照距离排序、分页。结果：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) {
            // 没有下一页了，结束
            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.根据id查询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);
    }

到此这篇关于redis用geo实现附近的人功能的文章就介绍到这了,更多相关redis geo附近的人内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！