概述
Geo就是Geolocation的简写形式,代表地理坐标。在Redis中,构造了能够存储地址坐标信息的一种数据结构,帮助我们根据经纬度来检索数据。
命令行操作方法
GEOADD
可以用来添加一个或者多个地理坐标。
GEODIST
返回一个key中两个成员之间的距离。
GEOHASH
将指定member的坐标转为哈希字符串形式返回。
GEOPOS
返回指定member的坐标。
GEORADIUS
指定圆心、半径,找到该圆内包含的member。
GEOSEARCH
在指定范围内搜索member。最新的一个命令,可以指定中心点的经纬度,也可以使用member;并且还可以指定搜索范围是圆形还是正方形。
StringRedisTemplate操作方法
add
用于添加地理坐标。
@Resource
private StringRedisTemplate stringRedisTemplate;
@Test
public void test(){
Point point = new Point(112.653652,37.809874);
Long add = this.stringRedisTemplate.opsForGeo().add("ShanXi", point, "SXU");
System.out.println(add);
}
radius
用来查找坐标
@Resource
private StringRedisTemplate stringRedisTemplate;
@Test void test() {
// 中心点
Point point = new Point(112.617734,37.797128);
// 半径
Distance radius = new Distance(100, RedisGeoCommands.DistanceUnit.KILOMETERS);
// 由中心点和半径组成的圆圈
Circle circle = new Circle(point, radius);
// 获取值之后要带回来的参数
RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs()
.includeDistance() // 包含距离
.includeCoordinates() // 包含坐标
.sortAscending(); // 升序
// 进行查询
GeoResults<RedisGeoCommands.GeoLocation<String>> search =
this.stringRedisTemplate.opsForGeo().radius("ShanXi", circle, args);
List<GeoResult<RedisGeoCommands.GeoLocation<String>>> content = search.getContent();
if(content == null || content.isEmpty()) {
System.out.println("没有数据");
}
for (GeoResult<RedisGeoCommands.GeoLocation<String>> geoLocationGeoResult : content) {
// 输出距离
System.out.println("距离:" + geoLocationGeoResult.getDistance());
RedisGeoCommands.GeoLocation<String> locationGeoResultContent = geoLocationGeoResult.getContent();
// 输出名称
System.out.println("member:" + locationGeoResultContent.getName());
// 输出坐标
System.out.println("坐标" + locationGeoResultContent.getPoint());
}
}
search
和radius方法类似,只不过search还可以查找矩形范围之内的坐标。
remove
删除操作
@Resource
private StringRedisTemplate stringRedisTemplate;
@Test void test() {
Long remove = this.stringRedisTemplate.opsForGeo().remove("ShanXi", "TaiYuanXueYuan");
System.out.println(remove);
}
distance
查看两个地理位置之间的直线距离
@Resource
private StringRedisTemplate stringRedisTemplate;
@Test void test() {
Distance distance = this.stringRedisTemplate.opsForGeo()
.distance("ShanXi", "SXU", "ZonBei");
System.out.println(distance);
}
代码示例
需求:山西所有高校建立之后,都会把自己的位置上传到某信息平台,并且还会查询距离自己学校30公里之内的其他学校。当学校换位置之后,就会删除当前信息。
基础配置
@RestController
@RequestMapping("/school")
public class SchoolController {
@Resource
private SchoolService schoolService;
}
@Service
public class SchoolService extends ServiceImpl<SchoolMapper, School> {
@Resource
private StringRedisTemplate stringRedisTemplate;
}
public interface SchoolMapper extends BaseMapper<School> {
}
@Data
public class School {
// 学校id
private Integer id;
// 学校名
private String name;
// 经度
private BigDecimal longitude;
// 纬度
private BigDecimal latitude;
}
上传位置信息
public String add(School school) {
// TODO 更新信息到数据库
boolean save = this.save(school);
// TODO 判断是否更新成功
if(save) {
// TODO 封装位置信息
Point point = new Point(school.getLongitude().doubleValue(),
school.getLatitude().doubleValue());
// TODO 存入数据库
this.stringRedisTemplate
.opsForGeo().add("GEO:SCHOOL", point, school.getName());
}
return "成功";
}
查询附近学校
public void queryMessage() {
// 距离
Distance distance = new Distance(30, RedisGeoCommands.DistanceUnit.KILOMETERS);
// 参数
RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs()
.includeDistance() // 包含距离
.includeCoordinates() // 包含坐标
.sortDescending(); // 降序
// 开始查找
GeoResults<RedisGeoCommands.GeoLocation<String>> results = this.stringRedisTemplate
.opsForGeo()
.radius("GEO:SCHOOL", "SXU", distance, args);
List<GeoResult<RedisGeoCommands.GeoLocation<String>>> content = results.getContent();
// 输出结果
for (GeoResult<RedisGeoCommands.GeoLocation<String>> geoLocationGeoResult : content) {
System.out.println("距离山西大学30公里之内大学的名称:" + geoLocationGeoResult.getContent().getName());
System.out.println("距离山西大学30公里之内大学的坐标:" + geoLocationGeoResult.getContent().getPoint());
System.out.println("距离山西大学30公里之内大学的距离:" + geoLocationGeoResult.getDistance());
}
}
删除位置信息
public boolean remove(String name) {
LambdaQueryWrapper<School> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(School::getName, name);
boolean subtract = this.remove(lambdaQueryWrapper);
if(!subtract) {
return false;
}
Long remove = this.stringRedisTemplate.opsForGeo()
.remove("GEO:SCHOOL", name);
return remove != null && remove == 1;
}