目录
引言
Redis GEO命令概述
什么是GEO命令？
主要命令详解
命令应用示例
添加地点信息
查询两地距离
查询附近的城市
实现"查找附近的人"功能
功能需求与实现思路
基本需求
实现思路
命令实现方案
存储用户位置
查询附近的用户
Java代码实现详解
使用Redis GEO的优势与注意事项
优势
注意事项
引言
在移动互联网时代，基于地理位置的服务已成为众多应用的标配功能。无论是打车软件、外卖平台还是社交应用，"附近的XX"功能几乎无处不在。这类功能的核心技术挑战在于：如何高效存储地理位置数据并进行快速检索？Redis 3.2版本引入的GEO（地理空间）命令集完美解决了这一问题，为开发者提供了简单高效的地理位置数据处理方案。
本文将深入浅出地介绍Redis GEO命令及其工作原理，通过实际案例和代码示例，帮助你轻松实现"查找附近的人"等地理位置相关功能。无论你是Redis新手还是有经验的开发者，都能从中获取有价值的信息。
Redis GEO命令概述
什么是GEO命令？
GEO是"Geolocation"（地理定位）的简写，Redis GEO是Redis专门为地理位置信息存储和检索设计的命令集。它允许我们将经纬度坐标存储到Redis数据库中，并支持按距离查询、计算两点间距离等多种地理空间操作。
底层实现上，Redis GEO使用了地理空间索引算法（Geohash），将二维的经纬度转换为一维的字符串，并通过Redis的有序集合(Sorted Set)来存储，这使得地理位置的存取和计算变得非常高效。
主要命令详解
Redis GEO主要提供了以下几个核心命令：
- GEOADD: 添加地理空间信息
# 将指定的地理空间位置（经度、纬度、名称）添加到指定的key中
# 可以一次添加多个位置
GEOADD key longitude latitude member [longitude latitude member ...]- GEODIST: 计算两点间距离
# 返回两个给定位置之间的距离
# unit参数指定返回值的单位，可以是m（米）、km（千米）、mi（英里）或ft（英尺）
GEODIST key member1 member2 [unit]- GEOHASH: 获取经纬度的Geohash表示
# 返回一个或多个位置元素的Geohash表示
# Geohash是一种将经纬度编码为字符串的方法
GEOHASH key member [member ...]- GEOHASH: 获取经纬度的Geohash表示
# 返回一个或多个位置元素的Geohash表示
# Geohash是一种将经纬度编码为字符串的方法
GEOHASH key member [member ...]- GEOPOS: 获取位置的经纬度
# 返回指定名称位置的经纬度坐标
GEOPOS key member [member ...]- GEORADIUS: 查找指定半径内的成员
# 以给定的经纬度为中心，返回键中包含的位置元素当中，与中心的距离不超过给定半径的所有位置元素
GEORADIUS key longitude latitude radius unit [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count] [ASC|DESC] [STORE key] [STOREDIST key]WITHDIST: 在返回位置元素的同时，将位置元素与中心之间的距离也一并返回
WITHCOORD: 将位置元素的经度和纬度也一并返回
WITHHASH: 以52位无符号整数的形式返回位置元素的geohash值（主要用于调试）
COUNT n: 限定返回的记录数量
ASC|DESC: 根据中心的位置，按照从近到远（ASC）或从远到近（DESC）的顺序返回位置元素
- GEOSEARCH: 在指定范围内搜索
# 在指定范围内搜索，范围可以是圆形或矩形
GEOSEARCH key [FROMMEMBER member] [FROMLONLAT longitude latitude] [BYRADIUS radius unit] [BYBOX width height unit] [WITHDIST] [WITHCOORD] [WITHHASH] [COUNT count] [ASC|DESC]- GEOSEARCHSTORE: 在指定范围内搜索并将结果存储
# 与GEOSEARCH功能相同，但可以将结果存储到指定的key中
GEOSEARCHSTORE destination key [FROMMEMBER member] [FROMLONLAT longitude latitude] [BYRADIUS radius unit] [BYBOX width height unit] [WITHDIST] [WITHCOORD] [WITHHASH] [COUNT count] [ASC|DESC]这些命令共同构成了一个完整的地理空间数据处理工具集，能够满足大多数基于位置的服务需求。
命令应用示例
让我们通过一个具体的例子来理解GEO命令的使用：
添加地点信息
# 上述命令将"东京"和"吉隆坡"两个城市的经纬度信息添加到名为"locations"的地理空间集合中。
GEOADD locations 139.781210 35.774426 "东京" 101.653962 5.205122 "吉隆坡"查询两地距离
# 这个命令会返回东京和吉隆坡之间的距离（单位：公里）。
GEODIST locations "东京" "吉隆坡" km查询附近的城市
# 这个命令会查找距离指定坐标点（经度139.0，纬度35.0）1000公里范围内的所有城市，并同时返回它们与中心点的距离。
GEORADIUS locations 139.0 35.0 1000 km WITHDIST实现"查找附近的人"功能
"查找附近的人"是移动应用中的常见功能，下面我们将详细讲解如何使用Redis GEO命令来实现。
功能需求与实现思路
基本需求
- 存储每个用户的地理位置信息（经纬度）
- 能够查询指定用户周围一定范围内的其他用户
- 返回的用户列表按照距离排序
实现思路
- 使用GEOADD命令将用户ID及其经纬度信息存储在Redis中
- 当需要查询"附近的人"时，使用GEORADIUS命令，以查询用户的位置为中心，指定半径范围进行搜索
命令实现方案
假设我们正在开发一个社交应用，需要实现广州市用户查找1000公里范围内其他用户的功能：
存储用户位置
GEOADD user_location 113.267548 23.142979 "user1"
GEOADD user_location 113.300000 23.150000 "user2"
GEOADD user_location 114.057868 22.543099 "user3"查询附近的用户
# 命令会返回距离广州市指定坐标1000公里范围内的所有用户，并显示他们与查询点的具体距离。
GEORADIUS user_location 113.254325 23.144043 1000 km WITHDISTJava代码实现详解
下面是使用Java语言和Jedis客户端实现"查找附近的人"功能的代码示例：
import redis.clients.jedis.GeoCoordinate;
import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.GeoRadiusParam;
import java.util.List;
import java.util.Map;
import java.util.HashMap;
import java.util.stream.Collectors;
/**
* Redis GEO功能示例：实现"附近的人"功能
*
* @author Muller
*/
public class RedisGeoDemo {
private static final String USER_LOCATION_KEY = "user_location";
/**
* 存储用户地理位置信息
*
* @param userId 用户ID
* @param longitude 经度
* @param latitude 纬度
* @param jedis Redis连接
* @return 添加成功的数量
*/
public static Long saveUserLocation(String userId, double longitude, double latitude, Jedis jedis) {
try {
return jedis.geoadd(USER_LOCATION_KEY, longitude, latitude, userId);
} catch (Exception e) {
System.err.println("保存用户位置信息失败: " + e.getMessage());
return 0L;
}
}
/**
* 批量存储多个用户的地理位置信息
*
* @param userLocations 用户位置Map，key为用户ID，value为经纬度坐标
* @param jedis Redis连接
* @return 添加成功的数量
*/
public static Long saveUserLocations(Map<String, double[]> userLocations, Jedis jedis) {
try {
Map<String, GeoCoordinate> memberCoordinateMap = new HashMap<>();
for (Map.Entry<String, double[]> entry : userLocations.entrySet()) {
String userId = entry.getKey();
double[] coordinates = entry.getValue();
memberCoordinateMap.put(userId, new GeoCoordinate(coordinates[0], coordinates[1]));
}
return jedis.geoadd(USER_LOCATION_KEY, memberCoordinateMap);
} catch (Exception e) {
System.err.println("批量保存用户位置信息失败: " + e.getMessage());
return 0L;
}
}
/**
* 查询附近的人
*
* @param longitude 经度
* @param latitude 纬度
* @param radius 半径
* @param jedis Redis连接
* @return 附近用户ID列表
*/
public static List<String> getNearbyUsers(double longitude, double latitude, double radius, Jedis jedis) {
try {
List<GeoRadiusResponse> responses = jedis.georadius(
USER_LOCATION_KEY,
longitude,
latitude,
radius,
GeoUnit.KM,
GeoRadiusParam.geoRadiusParam().withDist().sortAscending()
);
return responses.stream()
.map(GeoRadiusResponse::getMemberByString)
.collect(Collectors.toList());
} catch (Exception e) {
System.err.println("查询附近用户失败: " + e.getMessage());
return List.of();
}
}
/**
* 获取用户详细地理信息（包含距离）
*
* @param longitude 经度
* @param latitude 纬度
* @param radius 半径
* @param jedis Redis连接
* @return 附近用户详细信息列表
*/
public static List<UserGeoInfo> getNearbyUsersWithDistance(double longitude, double latitude, double radius, Jedis jedis) {
try {
List<GeoRadiusResponse> responses = jedis.georadius(
USER_LOCATION_KEY,
longitude,
latitude,
radius,
GeoUnit.KM,
GeoRadiusParam.geoRadiusParam().withDist().withCoord().sortAscending()
);
return responses.stream()
.map(response -> new UserGeoInfo(
response.getMemberByString(),
response.getDistance(),
response.getCoordinate().getLongitude(),
response.getCoordinate().getLatitude()
))
.collect(Collectors.toList());
} catch (Exception e) {
System.err.println("查询附近用户详细信息失败: " + e.getMessage());
return List.of();
}
}
/**
* 计算两个用户之间的距离
*
* @param userId1 用户1的ID
* @param userId2 用户2的ID
* @param jedis Redis连接
* @return 两用户间距离（单位：公里），如果计算失败返回-1
*/
public static double getDistanceBetweenUsers(String userId1, String userId2, Jedis jedis) {
try {
Double distance = jedis.geodist(USER_LOCATION_KEY, userId1, userId2, GeoUnit.KM);
return distance != null ? distance : -1;
} catch (Exception e) {
System.err.println("计算用户距离失败: " + e.getMessage());
return -1;
}
}
/**
* 获取用户的地理坐标
*
* @param userId 用户ID
* @param jedis Redis连接
* @return 用户坐标[经度,纬度]，如果不存在返回null
*/
public static double[] getUserPosition(String userId, Jedis jedis) {
try {
List<GeoCoordinate> positions = jedis.geopos(USER_LOCATION_KEY, userId);
if (positions != null && !positions.isEmpty() && positions.get(0) != null) {
GeoCoordinate pos = positions.get(0);
return new double[] { pos.getLongitude(), pos.getLatitude() };
}
return null;
} catch (Exception e) {
System.err.println("获取用户坐标失败: " + e.getMessage());
return null;
}
}
/**
* 用户地理信息包装类
*/
public static class UserGeoInfo {
private String userId;
private double distance;
private double longitude;
private double latitude;
public UserGeoInfo(String userId, double distance, double longitude, double latitude) {
this.userId = userId;
this.distance = distance;
this.longitude = longitude;
this.latitude = latitude;
}
public String getUserId() {
return userId;
}
public double getDistance() {
return distance;
}
public double getLongitude() {
return longitude;
}
public double getLatitude() {
return latitude;
}
@Override
public String toString() {
return "用户ID: " + userId +
", 距离: " + String.format("%.2f", distance) + "公里" +
", 坐标: [" + longitude + ", " + latitude + "]";
}
}
/**
* 示例用法
*/
public static void main(String[] args) {
// 这里仅用于演示，实际使用应通过连接池获取Jedis实例
try (Jedis jedis = new Jedis("localhost", 6379)) {
// 清除之前可能存在的测试数据
jedis.del(USER_LOCATION_KEY);
// 存储几个测试用户的位置（广州及周边城市的坐标）
saveUserLocation("user1", 113.267548, 23.142979, jedis); // 广州
saveUserLocation("user2", 114.057868, 22.543099, jedis); // 深圳
saveUserLocation("user3", 113.030396, 22.938259, jedis); // 佛山
saveUserLocation("user4", 116.397128, 39.916527, jedis); // 北京
System.out.println("===== 查询广州周边1000公里范围内的用户 =====");
List<String> nearbyUsers = getNearbyUsers(113.267548, 23.142979, 1000, jedis);
System.out.println("附近的用户: " + nearbyUsers);
System.out.println("\n===== 查询广州周边1000公里范围内的用户（包含距离信息） =====");
List<UserGeoInfo> nearbyUsersWithDist = getNearbyUsersWithDistance(113.267548, 23.142979, 1000, jedis);
nearbyUsersWithDist.forEach(System.out::println);
System.out.println("\n===== 计算用户间距离 =====");
double distance = getDistanceBetweenUsers("user1", "user2", jedis);
System.out.println("广州(user1)到深圳(user2)的距离: " + String.format("%.2f", distance) + "公里");
distance = getDistanceBetweenUsers("user1", "user4", jedis);
System.out.println("广州(user1)到北京(user4)的距离: " + String.format("%.2f", distance) + "公里");
System.out.println("\n===== 获取用户坐标 =====");
double[] pos = getUserPosition("user1", jedis);
if (pos != null) {
System.out.println("用户user1的坐标: [" + pos[0] + ", " + pos[1] + "]");
}
}
}
}使用Redis GEO的优势与注意事项
优势
- 性能高效：Redis基于内存操作，地理位置查询性能极高
- 使用简单：GEO命令集设计直观，容易上手
- 功能完善：提供了从添加、查询到计算距离的完整功能集
- 可扩展性好：可以轻松处理百万级别的POI（兴趣点）数据
- 与Redis其他功能协同：可以结合Redis的缓存、事务等功能
注意事项
- 精度限制：GEO命令的精度受到Geohash算法的限制，对于需要极高精度的应用场景（如军事）可能不适用
- 内存消耗：大量GEO数据会占用较多内存，需要合理规划Redis服务器资源
- 经纬度范围：Redis GEO只接受有效的经纬度范围（经度：-180到180，纬度：-85.05112878到85.05112878）
- 数据持久化：使用AOF持久化模式可能会导致重启时间延长，需权衡数据安全性和重启速度
- 适用场景：最适合"附近的XX"这类不需要复杂地理形状计算的场景，如需多边形区域计算等高级地理信息功能，可能需要专业GIS系统
