使用redis实现附近的人功能

目录
  • 前言
  • 工具
  • 百度经纬度拾取器
  • 一、测试数据
  • 二、基本命令
  • 三、javaApi

前言

Redis自3.2版本开始提供了GEO(geograph)功能,支持地理位置相关操作,以实现诸如附近的人这类依赖于地理位置信息的功能。

工具

百度经纬度拾取器

拾取坐标系统

一、测试数据

120.70012 28.00135 温州
120.207686 30.253359 杭州
121.482537 31.238034 上海
118.793117 32.068407 南京

二、基本命令

1. geoadd

为了进行地理位置相关操作,我们首先需要将具体的地理位置记录起来,可以通过执行geoadd 命令来完成 命令格式如下

GEOADD 集合名称 经度 纬度 名称 [longitude latitude name...]
//添加集合
geoadd citys 120.70012 28.00135 wenzhou 120.207686 30.253359 hanghzou

查看已添加集合

2.geopos

此命令根据输入的位置名称获取位置的信息坐标,语法如下

GEOPOS 集合名称 位置 [name...]
geopos address wuyue

查看坐标信息

3.geodist

此命令用于计算两个位置之间的距离,语法如下

geodist 集合名称 位置1 位置2 [unit]
//计算杭州到南京之间的距离
geodist citys hanghzredis:0>ou nanjing km

可选参数:unit用于指定计算距离时的单位,他的值可以是以下单位的其中一个

m :表示米

km:表示千米

mi:表示英里

ft:表示英尺。

4.georadius

georadius使用用户给定的经纬度作为计算范围时的中心点,

georadius 集合名称 精度 纬度 radius m|km|ft|mi| [WITHCOORD] [WITHDIST] [ASC|DESC] [COUNT count]
//查询据我100km之内的城市
georadius citys 120.754274 27.983296 100 km

radius:距离

WITHCOORD:返回坐标

由于版本原因可能为空

WITHDIST:同时返回距离

ASC|DESC:排序

count:取多少长度

5. georadiusbymember

georadiusbymember使用存储在位置集合里的某个地点作为中心点

georadiusbymember 地址集合 地点名称 距离 单位
//查询距离wuyue五公里之内的地点
georadiusbymember address wuyue 5 km

三、javaApi

实体类

package com.jiale.web.controller.pojo;

import lombok.Data;

import java.io.Serializable;

/**
 * @Author: Hello World
 * @Date: 2021/9/16 16:12
 * @Description:
 */
@Data
public class AddressInfo implements Serializable {

    /**网点名称*/
    private String title;
    /**网点地址*/
    private String address;
    /**网点联系方式*/
    private String phone;
    /**网点坐标-精度*/
    private double x;
    /**网点坐标-纬度*/
    private double y;
}
package com.jiale;

import com.jiale.common.config.JialeGlobal;
import com.jiale.web.controller.pojo.AddressInfo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.geo.*;
import org.springframework.data.redis.connection.RedisGeoCommands;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;

import java.math.BigDecimal;
import java.util.List;

/**
 * @Author: Hello World
 * @Date: 2021/9/15 17:47
 * @Description:
 */
@SpringBootTest
public class JialeTests {

    @Autowired
    RedisTemplate redisTemplate;

   @Test
    public void test1(){
        System.out.println(JialeGlobal.getUploadPath());
    }

    /**
     * 一.向redis中添加位置信息
     * 1.网店位置信息-geo
     * 2.网点详细信息
     */
    @Test
    public void geoAdd(){
        //1.网点位置信息存储120.653208,28.032606
        Point point = new Point(120.653208, 28.032606);
        redisTemplate.boundGeoOps("outlets").add(point,"江心屿");
        //2.网点详细信息
        AddressInfo addressInfo = new AddressInfo();
        addressInfo.setTitle("江心屿");
        addressInfo.setAddress("浙江省温州市鹿城区江心屿景区内");
        addressInfo.setPhone("(0577)88201281");
        addressInfo.setX(120.653208);
        addressInfo.setY(28.032606);
        redisTemplate.boundHashOps("outletsInfo").put("江心屿",addressInfo);
    }

    /**
     * 二.获取位置坐标信息
     */
    @Test
    public  void geoPos(){
        //传入位置名称查询位置信息
        List<Point> position = redisTemplate.boundGeoOps("outlets").position("南塘五组团");
        for (Point point : position) {
            System.out.println(point);
        }
    }

    /**
     * 三.计算两个位置信息
     */
    @Test
    public void geoDist(){
        /**
        Distance distance = redisTemplate.boundGeoOps("outlets").distance("江心屿", "温州乐园");
        //距离
        double value = distance.getValue();
        //单位
        String unit = distance.getUnit();
        System.out.println("两点相距:"+value+unit);
         */
        //以km展示
        /**
        Distance distance = redisTemplate.boundGeoOps("outlets").distance("江心屿", "温州乐园", Metrics.KILOMETERS);
        //距离
        double value = distance.getValue();
        //单位
        String unit = distance.getUnit();
        System.out.println("两点相距:"+value+unit);*/

        //保留两位小数
        Distance distance = redisTemplate.boundGeoOps("outlets").distance("江心屿", "温州乐园", Metrics.KILOMETERS);
        //距离
        double value = distance.getValue();
        //单位
        String unit = distance.getUnit();
        System.out.println("两点相距:"+new BigDecimal(value).setScale(2,BigDecimal.ROUND_HALF_UP) +unit);
    }

    /**
     * 四.按照给定的经纬度查找指定范围的位置
     */
    @Test
    public  void geoRadius(){
        //指定位置
        Point point = new Point(120.754274,  27.983296);
        //构建条件-10km
        Distance distance = new Distance(10, Metrics.KILOMETERS);
        Circle circle = new Circle(point,distance);
        //RedisGeoCommands
        RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs();
         //包含位置信息
        args.includeDistance();

        //存放的是查询到的网址位置信息
        GeoResults<RedisGeoCommands.GeoLocation<String>> outlets = redisTemplate.boundGeoOps("outlets").radius(circle, args);
        for (GeoResult<RedisGeoCommands.GeoLocation<String>> outlet : outlets) {
            //获取距离信息
            Distance outletDistance = outlet.getDistance();
            //距离
            double value = outletDistance.getValue();
            //单位
            String unit = outletDistance.getUnit();
            System.out.println("当前坐标距离:"+outlet.getContent().getName()+value+unit);
        }
    }

    /**
     * 五.按照指定元素(必须在集合中存在)查找指定范围位置
     */
    @Test
    public void geoRadiusByMember(){
        //构建条件
        Distance distance = new Distance(10, Metrics.KILOMETERS);
        //构建条件-包含位置信息
        RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs();
        args.includeDistance();
        //参数  key   构建的条件  其他条件
        GeoResults<RedisGeoCommands.GeoLocation<String>> outlets = redisTemplate.boundGeoOps("outlets").radius("江心屿", distance,args);
        for (GeoResult<RedisGeoCommands.GeoLocation<String>> outlet : outlets) {
            //获取距离信息
            Distance outletDistance = outlet.getDistance();
            //距离
            double value = outletDistance.getValue();
            //单位
            String unit = outletDistance.getUnit();
            System.out.println("江心屿距离:"+outlet.getContent().getName()+value+unit);
        }
    }
}

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

(0)

相关推荐

  • Redis 实现“附近的人”功能

    针对"附近的人"这一位置服务领域的应用场景,常见的可使用PG.MySQL和MongoDB等多种DB的空间索引进行实现.而Redis另辟蹊径,结合其有序队列zset以及geohash编码,实现了空间搜索功能,且拥有极高的运行效率.本文将从源码角度对其算法原理进行解析,并推算查询时间复杂度. 操作命令 自Redis 3.2开始,Redis基于geohash和有序集合提供了地理位置相关功能. Redis Geo模块包含了以下6个命令: GEOADD: 将给定的位置对象(纬度.经度.名字)添加

  • 使用redis实现附近的人功能

    目录 前言 工具 百度经纬度拾取器 一.测试数据 二.基本命令 三.javaApi 前言 Redis自3.2版本开始提供了GEO(geograph)功能,支持地理位置相关操作,以实现诸如附近的人这类依赖于地理位置信息的功能. 工具 百度经纬度拾取器 拾取坐标系统 一.测试数据 120.70012 28.00135 温州 120.207686 30.253359 杭州 121.482537 31.238034 上海 118.793117 32.068407 南京 二.基本命令 1. geoadd

  • PHP实现的redis主从数据库状态检测功能示例

    本文实例讲述了PHP实现的redis主从数据库状态检测功能.分享给大家供大家参考,具体如下: 实例: <?php /** * 检测多个主从redis数据库是否挂掉 * 建立从数据库$redis_db的二维数组,内容包含每个从服务器的配置数据 */ header("Content-Type: text/html; charset=utf-8"); set_time_limit(0); $redis_db = array( 'db1'=>array( 'hostname' =&

  • Java操作redis实现增删查改功能的方法示例

    本文实例讲述了Java操作redis实现增删查改功能的方法.分享给大家供大家参考,具体如下: 首先,我们需要在windows下配置一个redis环境,具体配置教程请看:http://www.jb51.net/article/96230.htm 然后需要导入:jedis-2.7.3.jar这个包,看如下代码: package redis.main; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; imp

  • PHP使用redis位图bitMap 实现签到功能

    一.需求 记录用户签到,查询用户签到 二.技术方案 1.使用mysql(max_time字段为连续签到天数) 思路: (1)用户签到,插入一条记录,根据create_time查询昨日是否签到,有签到则max_time在原基础+1,否则,max_time=0 (2)检测签到,根据user_id.create_time查询记录是否存在,不存在则表示未签到 2.使用redis位图功能 思路: (1)每个用户每个月单独一条redis记录,如00101010101010,从左往右代表01-31天(每月有几

  • java 使用ElasticSearch完成百万级数据查询附近的人功能

    上一篇文章介绍了ElasticSearch使用Repository和ElasticSearchTemplate完成构建复杂查询条件,简单介绍了ElasticSearch使用地理位置的功能. 这一篇我们来看一下使用ElasticSearch完成大数据量查询附近的人功能,搜索N米范围的内的数据. 准备环境 本机测试使用了ElasticSearch最新版5.5.1,SpringBoot1.5.4,spring-data-ElasticSearch2.1.4. 新建Springboot项目,勾选Elas

  • Redis实战之商城购物车功能的实现代码

    目标 利用Redis实现商城购物车功能. 功能 根据用户编号查询购物车列表,且各个商品需要跟在对应的店铺下:统计购物车中的商品总数:新增或删减购物车商品:增加或减少购物车中的商品数量. 分析 Hash数据类型:值为多组映射,相当于JAVA中的Map.适合存储对象数据类型.因为用户ID作为唯一的身份标识,所以可以把模块名称+用户ID作为Redis的键:商品ID作为商品的唯一标识,可以把店铺编号+商品ID作为Hash元素的键,商品数量为元素的值. 代码实现 控制层 package com.shopp

  • Redis实现订单自动过期功能的示例代码

    前言 用户下单后,规定XX分钟后自动设置为"已过期",不能再发起支付.项目类似此类"过期"的需求,笔者提供一种使用Redis的解决思路,结合Redis的订阅.发布和键空间通知机制(Keyspace Notifications)进行实现. 配置redis.confg notify-keyspace-events选项默认是不启用,改为notify-keyspace-events "Ex".重启生效,索引位i的库,每当有过期的元素被删除时,向**key

  • 基于Redis位图实现用户签到功能

    场景需求 适用场景如签到送积分.签到领取奖励等,大致需求如下: 签到1天送1积分,连续签到2天送2积分,3天送3积分,3天以上均送3积分等. 如果连续签到中断,则重置计数,每月初重置计数. 当月签到满3天领取奖励1,满5天领取奖励2,满7天领取奖励3--等等. 显示用户某个月的签到次数和首次签到时间. 在日历控件上展示用户每月签到情况,可以切换年月显示--等等. 设计思路 对于用户签到数据,如果每条数据都用K/V的方式存储,当用户量大的时候内存开销是非常大的.而位图(BitMap)是由一组bit

  • 你真的了解redis为什么要提供pipeline功能

    Redis本身是一个cs模式的tcp server, client可以通过一个socket连续发起多个请求命令. 每个请求命令发出后client通常会阻塞并等待redis服务端处理,redis服务端处理完后将结果返回给client. redis的pipeline(管道)功能在命令行中没有,但redis是支持pipeline的,而且在各个语言版的client中都有相应的实现. 由于网络开销延迟,即算redis server端有很强的处理能力,也由于收到的client消息少,而造成吞吐量小.当cli

随机推荐