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

2025-05-10 02:50

本文主要是介绍基于Redis实现附近商铺查询功能,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《基于Redis实现附近商铺查询功能》:本文主要介绍基于Redis实现-附近商铺查询功能,这个功能将使用到Redis中的GEO这种数据结构来实现,需要的朋友可以参考下...

基于Redis实现-附近查询

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

1.GEO相关命令

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

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

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

添加下面几条数据:

  • 编程China编程京南站(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 "北京西站"

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

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

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

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

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

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

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

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

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")
dNvQtryB

如下为完整示例:

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附近商铺查询内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持China编程(www.chinasem.cn)!

这篇关于基于Redis实现附近商铺查询功能的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1154554

相关文章

MySQL中查找重复值的实现

《MySQL中查找重复值的实现》查找重复值是一项常见需求,比如在数据清理、数据分析、数据质量检查等场景下,我们常常需要找出表中某列或多列的重复值,具有一定的参考价值,感兴趣的可以了解一下... 目录技术背景实现步骤方法一:使用GROUP BY和HAVING子句方法二:仅返回重复值方法三:返回完整记录方法四:

IDEA中新建/切换Git分支的实现步骤

《IDEA中新建/切换Git分支的实现步骤》本文主要介绍了IDEA中新建/切换Git分支的实现步骤,通过菜单创建新分支并选择是否切换,创建后在Git详情或右键Checkout中切换分支,感兴趣的可以了... 前提:项目已被Git托管1、点击上方栏Git->NewBrancjsh...2、输入新的分支的

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》:本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os

MySQL查询JSON数组字段包含特定字符串的方法

《MySQL查询JSON数组字段包含特定字符串的方法》在MySQL数据库中,当某个字段存储的是JSON数组,需要查询数组中包含特定字符串的记录时传统的LIKE语句无法直接使用,下面小编就为大家介绍两种... 目录问题背景解决方案对比1. 精确匹配方案(推荐)2. 模糊匹配方案参数化查询示例使用场景建议性能优

关于集合与数组转换实现方法

《关于集合与数组转换实现方法》:本文主要介绍关于集合与数组转换实现方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、Arrays.asList()1.1、方法作用1.2、内部实现1.3、修改元素的影响1.4、注意事项2、list.toArray()2.1、方

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传:从崩溃边缘抢救进度二、多线程加速:榨干网络带宽三、速度控制:做网络的好邻居四、终端交互

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE

java实现docker镜像上传到harbor仓库的方式

《java实现docker镜像上传到harbor仓库的方式》:本文主要介绍java实现docker镜像上传到harbor仓库的方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 前 言2. 编写工具类2.1 引入依赖包2.2 使用当前服务器的docker环境推送镜像2.2

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结