1、简述
在很多应用场景中，例如社交平台、外卖配送、打车服务等，常常需要基于用户的地理位置查询附近的用户或服务点。为了提高查询效率，可以借助 Redis 的 Geo 功能实现快速的地理位置查询。本文将介绍如何使用 Redis 的 Geo 功能，并结合 Java 来实现查询附近的人。
2、Geo 功能介绍
Redis 提供了一组基于地理空间的命令来存储、查询和处理地理位置信息。主要的几个命令如下：
- GEOADD：将地理位置（经纬度）添加到 Redis 中。
- GEODIST：计算两个地理位置之间的距离。
- GEORADIUS：查询给定地理坐标范围内的元素。
- GEOHASH：返回位置的 GeoHash 值。
这些命令利用 Redis 的有序集合来存储位置信息，查询和计算效率非常高，特别适合用于“附近的人”这样的场景。
3、实现步骤
3.1 环境准备
首先，你需要确保 Redis 支持 Geo 命令，并安装了 Redis。然后在 Java 项目中引入 Redis 的客户端库，例如 Jedis 或 Lettuce。
在 Maven 中引入 Jedis 依赖：
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.0.0</version>
</dependency>
3.2 添加地理位置数据
我们将利用 Redis 的 GEOADD 命令来存储用户的地理位置信息。假设每个用户都有唯一的 ID 和相应的经纬度，存储这些数据的代码如下：
import redis.clients.jedis.Jedis;
public class RedisGeoExample {
public static void main(String[] args) {
// 连接 Redis
Jedis jedis = new Jedis("localhost", 6379);
// 添加用户的地理位置信息 (userId, longitude, latitude)
jedis.geoadd("users", 116.403963, 39.915119, "user1"); // 北京
jedis.geoadd("users", 121.473701, 31.230416, "user2"); // 上海
jedis.geoadd("users", 114.305393, 30.592850, "user3"); // 武汉
System.out.println("Users' locations added to Redis Geo");
}
}
这里我们向 Redis 中的 users 集合添加了三位用户的地理位置。Redis 中 GEOADD 命令会将位置存储为有序集合，利用经纬度的排序来进行快速查询。
3.3 查询附近的人
使用 Redis 的 GEORADIUS 命令，可以根据指定的中心点和半径查询范围内的用户。例如，查询半径 500 公里范围内的用户：
import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.GeoRadiusParam;
import java.util.List;
public class RedisGeoExample {
public static void main(String[] args) {
// 连接 Redis
Jedis jedis = new Jedis("localhost", 6379);
// 查询北京 (116.403963, 39.915119) 附近 500 公里的用户
List<GeoRadiusResponse> nearbyUsers = jedis.georadius(
"users", 116.403963, 39.915119, 500, // 经纬度与半径
GeoRadiusParam.geoRadiusParam().withDist().sortAscending() // 结果按距离升序
);
for (GeoRadiusResponse user : nearbyUsers) {
System.out.println("User: " + user.getMemberByString() + ", Distance: " + user.getDistance());
}
}
}
在上面的代码中，georadius 方法接受经纬度、半径以及其他可选参数（如排序方式和距离单位），并返回附近用户的列表。
输出结果：
User: user1, Distance: 0.0
User: user3, Distance: 1125.62
3.4 计算两点之间的距离
有时我们需要计算两位用户之间的距离，Redis 提供了 GEODIST 命令来进行此操作：
import redis.clients.jedis.Jedis;
public class RedisGeoDistanceExample {
public static void main(String[] args) {
// 连接 Redis
Jedis jedis = new Jedis("localhost", 6379);
// 计算北京 (user1) 和上海 (user2) 之间的距离
Double distance = jedis.geodist("users", "user1", "user2", "km"); // 单位：公里
System.out.println("Distance between user1 and user2: " + distance + " km");
}
}
4、完整的查询附近人实现方案
基于上述基础步骤，我们可以扩展为一个通用的服务类来实现“附近的人”查询服务：
import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.GeoRadiusParam;
import java.util.List;
public class NearbyPeopleService {
private Jedis jedis;
public NearbyPeopleService() {
// 初始化 Redis 连接
jedis = new Jedis("localhost", 6379);
}
// 添加用户位置信息
public void addUserLocation(String userId, double longitude, double latitude) {
jedis.geoadd("users", longitude, latitude, userId);
}
// 查询指定用户附近的其他用户
public List<GeoRadiusResponse> findNearbyUsers(String userId, double radiusInKm) {
// 获取用户的经纬度
List<Object> userPosition = jedis.geopos("users", userId);
if (userPosition.isEmpty()) {
throw new IllegalArgumentException("User not found: " + userId);
}
double longitude = ((List<Double>) userPosition.get(0)).get(0);
double latitude = ((List<Double>) userPosition.get(0)).get(1);
// 查询附近的用户
return jedis.georadius("users", longitude, latitude, radiusInKm,
GeoRadiusParam.geoRadiusParam().withDist().sortAscending());
}
public static void main(String[] args) {
NearbyPeopleService service = new NearbyPeopleService();
// 添加几位用户的位置
service.addUserLocation("user1", 116.403963, 39.915119); // 北京
service.addUserLocation("user2", 121.473701, 31.230416); // 上海
service.addUserLocation("user3", 114.305393, 30.592850); // 武汉
// 查询 user1 附近 1000 公里内的用户
List<GeoRadiusResponse> nearbyUsers = service.findNearbyUsers("user1", 1000);
nearbyUsers.forEach(user ->
System.out.println("User: " + user.getMemberByString() + ", Distance: " + user.getDistance()));
}
}
5、Redis Geo 应用场景
- 社交应用：用户可以根据地理位置发现附近的其他用户，进行好友推荐或匹配。
- 物流配送：根据配送员或车辆的实时位置，找到附近的订单或配送需求。
- 共享服务：共享单车、共享汽车等应用可以通过 Redis Geo 快速定位最近的车辆。
6、总结
Redis 提供的 Geo 功能是一个高效处理地理位置信息的工具，结合 Java 可以轻松实现附近的人或服务的查询。在高并发的场景中，Redis 的性能和查询速度都非常有优势。通过将用户的位置信息存储在 Redis 中，并利用 Redis 的内置 Geo 查询命令，可以大大提升查询效率。
评论区