附近的人？你zao吗？

程序员文章站 2022-06-17 22:43:26

前几天收到一个新的需求，需要实现类似“附近的人”的功能：根据自己当前的定位，获取距离范围内的所有任务地点。刚看到这个需求时有点懵逼，第一想到的就是要利用地球的半径公式去计算距离，也就是把地球想成一个球体，去计算球上两点之间的距离。可想而知，这样的方法效率会比较低，每条数据都要来与本人的坐标做计算，太 ......

实战演习

以下是给大家准备的sql脚本

set names utf8mb4;
set foreign_key_checks = 0;

-- ----------------------------
-- table structure for job_base_info
-- ----------------------------
drop table if exists `job_base_info`;
create table `job_base_info`  (
  `job_id` bigint(20) not null auto_increment comment '任务id',
  `job_name` varchar(50) character set utf8 collate utf8_general_ci not null comment '任务名称',
  `job_location` varchar(50) character set utf8 collate utf8_general_ci null default '' comment '任务地点位置经纬度-逗号隔开',
  `job_detail_address` varchar(255) character set utf8 collate utf8_general_ci not null comment '任务详细地点位置',
  primary key (`job_id`) using btree
) engine = innodb auto_increment = 24 character set = utf8 collate = utf8_general_ci comment = '工作任务详情基础信息表' row_format = dynamic;

-- ----------------------------
-- records of job_base_info
-- ----------------------------
insert into `job_base_info` values (1, '软件开发', '120.433576,36.139697', '青岛市崂山区海尔路1号');
insert into `job_base_info` values (2, '儿童摄影', '120.420297,36.156589', '山东省青岛市李沧区书院路188号');
insert into `job_base_info` values (3, '清洁家用电器', '120.025706,36.281478', '山东省青岛市胶州市福州支路232号东60米');
insert into `job_base_info` values (4, '辩论学习', '120.505042,36.171247', '松岭路238号中国海洋大学内');

set foreign_key_checks = 1;

废话不多说，让我们来看看具体的实现

（1）我们要在程序启动时，将数据库中的任务数据的坐标信息初始化到redis中（此处暂且忽略任务的增删改查对redis中数据的影响）

@postconstruct
public void init(){
    //首先要删除该key的所有值
    redistemplate.delete("company-task");
    list<jobbaseinfo> jobbaseinfolist = jobbaseinfomapper.selectlist(wrappers.emptywrapper());
    jobbaseinfolist.stream().foreach(item->{
        string joblocation = item.getjoblocation();
        if(strutil.isnotempty(joblocation)){
            string[] split = joblocation.split(",");comp
            if(split.length==2){
                //point(经度, 纬度) 
                point point = new point(double.parsedouble(split[0]),double.parsedouble(split[1]));
                //将经纬度数据及其id存到key为“company-task”中
                redistemplate.opsforgeo().add("company-task",point,item.getjobid());
            }
        }
    });
}

（2）查询当前坐标下3km范围内的任务地点（外加根据任务名搜索的联合查询）

@override
public list<jobbaseinfo> selectjoblist(jobbaseinfodto jobbaseinfodto) {
    string joblocation = jobbaseinfodto.getjoblocation();
    //距离
    double distance = jobbaseinfodto.getdistance();
    list<integer> idlist = new arraylist<>();
    if(stringutils.isnotnull(joblocation) && stringutils.isnotnull(distance)){
        string[] split = joblocation.split(",");
        if(split.length==2){
            //point(经度, 纬度) distance(距离量, 距离单位)
            circle circle = new circle(new point(double.parsedouble(split[0]),double.parsedouble(split[1])),
                                       new distance(distance, metrics.kilometers));
            //params: key, circle 获取存储到redis中的distance范围内的所有任务地点数据
            georesults radius = redistemplate.opsforgeo().radius("company-task", circle);
            list<georesult> contentlist = radius.getcontent();
            if(contentlist.size()>0){
                contentlist.stream().foreach(item->{
                    redisgeocommands.geolocation content = (redisgeocommands.geolocation) item.getcontent();
                    idlist.add((integer) content.getname());
                });
            }
        }
    }
    jobbaseinfodto.setidlist(idlist);
    return jobbaseinfomapper.selectjoblist(jobbaseinfodto);
}

selectjoblist(jobbaseinfodto)方法的sql如下

<select id="selectjoblist" resulttype="com.itzyq.redislikes.model.entity.jobbaseinfo">
	select
	<include refid="base_column_list"></include>
	from job_base_info
	<where>
		<if test="jobname!=null and jobname!=''">
			and job_name like concat("%",#{jobname},"%")
		</if>

		<if test="idlist!=null and idlist.size > 0 ">
			and job_id in
			<foreach collection="idlist" item="id" open="(" close=")" separator=",">
				#{id}
			</foreach>
		</if>
	</where>
</select>

到这儿我们就已经实现了“附近的人”的功能了，接下来就让我们具体的了解一下redis中的geo都有哪些骚操作吧。gzh回复“psearch”获取源码呦！

geo操作

redis geo 主要用于存储地理位置信息，并对存储的信息进行操作，该功能在 redis 3.2 版本新增，geo 是基于zset的一种扩展数据格式。redis geo 操作方法有：

geoadd：添加地理位置的坐标。
geopos：获取地理位置的坐标。
geodist：计算两个位置之间的距离。
georadius：根据用户给定的经纬度坐标来获取指定范围内的地理位置集合。
georadiusbymember：根据储存在位置集合里面的某个地点获取指定范围内的地理位置集合。
geohash：返回一个或多个位置对象的 geohash 值。

1、geoadd

geoadd 用于存储指定的地理空间位置，可以将一个或多个经度(longitude)、纬度(latitude)、位置名称(member)添加到指定的 key 中。

geoadd 语法格式如下：