基于Redis实现附近商铺查询功能

 更新时间:2025年05月09日 14:21:48   作者:编程学委  
这篇文章主要介绍了基于Redis实现-附近商铺查询功能,这个功能将使用到Redis中的GEO这种数据结构来实现,需要的朋友可以参考下

基于Redis实现-附近查询

这个功能将使用到Redis中的GEO这种数据结构来实现。

1.GEO相关命令

GEO就是Geolocation的简写形式,代表地理坐标。Redis在3.2版本中加入到了对GEO的支持,允许存储地理坐标信息,帮助我们根据经纬度来检索数据,常见命令如下:

  • GEOADD: 添加一个地理空间信息,包含:经度(longitude)、纬度(latitude)、值(member)
  • GEODIST: 计算指定的两个点之间的距离并返回
  • GEOHASH: 将指定member的坐标转为hash字符串形式并返回
  • GEOPOS: 返回指定member的坐标
  • GEORADIUS: 指定圆心、半径,找到该圆内包含的所有member,并按照与圆心之间的距离排序后返回。6.2以后已废弃
  • GEOSEARCH: 在指定范围内搜索member,并按照与指定点之间的距离排序后返回。范围可以是圆形或矩形。6.2.新功能
  • GEOSEARCHSTORE: 与GEOSEARCH功能一致,不过可以把结果存储到一个指定的key。6.2.新功能

2.使用GEO来实现以下功能

添加下面几条数据:

  • 北京南站(116.378248 39.865275)
  • 北京站(116.42803 39.903738)
  • 北京西站(116.322287 39.893729)
# 1. 添加地理空间数据
GEOADD stations 116.378248 39.865275 "北京南站" 116.42803 39.903738 "北京站" 116.322287 39.893729 "北京西站"

计算北京西站到北京站的距离

# 2. 计算北京西站到北京站的距离
GEODIST stations "北京西站" "北京站" km

搜索天安门(116.397904 39.909005)附近10km内的所有火车站,并按照距离升序排序

# 3. 搜索天安门附近10km内的火车站并按距离排序
GEOSEARCH stations FROMLONLAT 116.397904 39.909005 BYRADIUS 10 km ASC

3.使用Java实现简单的附近商铺查询

//在ServiceImpl中(简单演示)
@Autowired
    private StringRedisTemplate stringRedisTemplate;
@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中查询附近店铺ID(GEO查询)
    String key = "shop:geo:" + typeId;  // GEO数据存储的key
    // 执行GEO搜索:以(x,y)为中心,5000米半径范围内,查询end数量的店铺
    GeoResults<RedisGeoCommands.GeoLocation<String>> results = stringRedisTemplate.opsForGeo().search(
            key,
            GeoReference.fromCoordinate(x, y),  // 中心点坐标
            new Distance(5000),                // 搜索半径(5公里)
            RedisGeoCommands.GeoSearchCommandArgs.newGeoSearchArgs()
                    .includeDistance()         // 包含距离信息
                    .limit(end)                // 限制返回数量
    );
    // 4. 处理查询结果并获取店铺详情
    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());  // 结果不足时分页返回空
    }
    // 收集店铺ID和距离信息
    List<Long> ids = new ArrayList<>(list.size());
    Map<String, Distance> distanceMap = new HashMap<>(list.size());
    // 跳过前from条记录(分页处理),然后处理剩余记录
    list.stream().skip(from).forEach(result -> {
        String id = result.getContent().getName();  // 获取店铺ID
        ids.add(Long.valueOf(id));
        distanceMap.put(id, result.getDistance()); // 存储店铺距离
    });
    // 根据ID批量查询店铺详情(保持ID顺序)
    String strIds = StrUtil.join(",", ids);
    List<Shop> shops = query()
            .in("id", ids)  // 按ID列表查询
            .last("ORDER BY FIELD(id," + strIds + ")")  // 保持Redis返回的顺序
            .list();
    // 为每个店铺设置距离信息
    for (Shop shop : shops) {
        shop.setDistance(distanceMap.get(shop.getId().toString()).getValue());
    }
    // 5. 返回带距离信息的店铺列表
    return Result.ok(shops);
}

4.Redis GEO search 方法的参数

排序方式

.sortAscending()    // 按距离升序排序(从近到远)
.sortDescending()  // 按距离降序排序(从远到近)

返回内容控制

.includeDistance()  // 在结果中包含距离信息
.includeCoordinates() // 在结果中包含坐标信息
.includeName()     // 在结果中包含成员名称(默认包含)

结果限制

.limit(50)         // 限制返回结果数量(可用于简单分页)

单位设置

.includeDistance().withDistance(Metrics.KILOMETERS) // 指定距离单位
//支持的单位:
//Metrics.KILOMETERS(千米)
//Metrics.MILES(英里)
//Metrics.FEET(英尺)
//Metrics.METERS(米)

GeoReference 的三种主要形式

//1.fromCoordinate(x, y)
//作用:通过经纬度坐标指定中心点
//示例:
GeoReference.fromCoordinate(116.404, 39.915)  // 北京天安门坐标
//2.fromMember(memberName)
//作用:通过 Redis中已存储的GEO成员名称指定中心点
//示例:
GeoReference.fromMember("北京站")  // 以已存储的"北京站"坐标为中心
//3.fromString("x,y")
//作用:通过字符串格式的坐标指定中心点
//示例:
GeoReference.fromString("116.404,39.915")

如下为完整示例:

GeoResults<RedisGeoCommands.GeoLocation<String>> results = stringRedisTemplate.opsForGeo().search(
    "shop:geo:1",
    GeoReference.fromCoordinate(116.397904, 39.909005),
    new Distance(5, Metrics.KILOMETERS),
    RedisGeoCommands.GeoSearchCommandArgs.newGeoSearchArgs()
        .includeDistance()      // 包含距离
        .includeCoordinates()   // 包含坐标
        .sortAscending()        // 按距离升序
        .limit(100)             // 最多返回100条
        .withDistance(Metrics.KILOMETERS) // 距离单位为千米
);

对于 Redis 6.2 及以上版本,还可以使用:

矩形范围搜索

.byBox(width, height, Metrics.KILOMETERS) // 矩形范围搜索

存储搜索结果

.store("result-key")  // 将结果存储到指定key
.storeDist("result-key") // 存储带距离的结果

到此这篇关于基于Redis实现-附近商铺查询的文章就介绍到这了,更多相关Redis附近商铺查询内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 详解如何使用Redis作为高效缓存

    详解如何使用Redis作为高效缓存

    Redis是一个高性能的 内存存储系统,通常被用作 缓存 来加速数据访问,提高应用的吞吐量和响应速度,本文详细讲解如何使用 Redis 作为高效缓存,包括基本原理、常见模式、最佳实践以及优化技巧,需要的朋友可以参考下
    2025-01-01
  • redis的key出现的\xac\xed\x00\x05t\x00乱码问题及解决

    redis的key出现的\xac\xed\x00\x05t\x00乱码问题及解决

    这篇文章主要介绍了redis的key出现的\xac\xed\x00\x05t\x00乱码问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • 如何使用注解方式实现 Redis 分布式锁

    如何使用注解方式实现 Redis 分布式锁

    这篇文章主要介绍了如何使用注解方式实现Redis分布式锁,文章围绕主题展开详细的内容介绍,教大家如何优雅的使用Redis分布式锁,感兴趣的小伙伴可以参考一下
    2022-07-07
  • Redis实现客户端缓存的4种方式

    Redis实现客户端缓存的4种方式

    客户端缓存是指在应用程序内存中维护一份Redis数据的本地副本,以减少网络请求次数,降低延迟,并减轻Redis服务器负担,本文将分享Redis客户端缓存的四种实现方式,大家可以参考一下
    2025-05-05
  • Redis上实现分布式锁以提高性能的方案研究

    Redis上实现分布式锁以提高性能的方案研究

    这篇文章主要介绍了Redis上实现分布式锁以提高性能的方案研究,其中重点需要理解异步算法与锁的自动释放,需要的朋友可以参考下
    2015-12-12
  • Redis的Bitmap(位图)详解和命令演示

    Redis的Bitmap(位图)详解和命令演示

    Redis的位图是由多个二进制位组成的数组,数组中的每个二进制位都有与之对应的偏移量,用户通过这些偏移量可以对位图中指定的一个或多个二进制位进行操作,这篇文章主要给大家介绍了关于Redis的Bitmap(位图)详解和命令演示的相关资料,需要的朋友可以参考下
    2024-08-08
  • Redis使用布隆过滤器解决缓存雪崩的问题

    Redis使用布隆过滤器解决缓存雪崩的问题

    布隆过滤器可以帮助我们解决Redis缓存雪崩的问题,那什么是布隆过滤器、布隆过滤器又是如何使用如何解决缓存雪崩的问题的,让我们带着这一系列的问题去详细了解布隆过滤器,感兴趣的小伙伴跟着小编一起来看看吧
    2024-02-02
  • 一文快速搞懂Redis的几种数据类型方式

    一文快速搞懂Redis的几种数据类型方式

    这篇文章主要介绍了一文快速搞懂Redis的几种数据类型方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-10-10
  • Redis中如何设置日志

    Redis中如何设置日志

    这篇文章主要介绍了Redis中如何设置日志问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-12-12
  • Redis中三种特殊数据类型命令详解

    Redis中三种特殊数据类型命令详解

    Geospatial是地理位置类型,我们可以用来查询附近的人、计算两人之间的距离等,这篇文章主要介绍了Redis中三种特殊数据类型命令详解,需要的朋友可以参考下
    2024-05-05

最新评论