快捷導(dǎo)航

SpringBoot整合Redis實現(xiàn)附近位置查找(LBS)功能

更新時間：2025年03月20日 08:36:58 作者：neoooo

Redis 提供了 GEO 數(shù)據(jù)結(jié)構(gòu),可以高效地存儲和查詢地理位置數(shù)據(jù),本文將介紹如何使用 Spring Boot + Redis 來實現(xiàn)附近位置查找,需要的可以了解下

1. 引言

在很多場景中，如外賣、快遞、打車等應(yīng)用，我們需要實現(xiàn)“查找附近”的功能，以便根據(jù)用戶的地理位置推薦附近的商家或服務(wù)。Redis 提供了 GEO 數(shù)據(jù)結(jié)構(gòu)，可以高效地存儲和查詢地理位置數(shù)據(jù)。本文將介紹如何使用 Spring Boot + Redis 來實現(xiàn)附近位置查找。

Redis GEO 的核心優(yōu)勢

高效存儲：Redis 將地理空間數(shù)據(jù)存儲為有序集合，優(yōu)化了查詢性能。
靈活查詢：GEORADIUS 等命令支持基于半徑的搜索，并提供豐富的選項。
高性能：內(nèi)存存儲確保低延遲，適合實時應(yīng)用。

2. 技術(shù)選型

本項目主要使用的技術(shù)棧如下：

Spring Boot 3.0+ - 簡化開發(fā)，提高效率
Spring Data Redis - 方便地操作 Redis
Redis GEO - 存儲和查詢地理位置數(shù)據(jù)
JUnit 5 - 進(jìn)行單元測試

3. 環(huán)境準(zhǔn)備

Redis 安裝

確保你的 Redis 版本 >= 3.2，因為 GEO 命令是在 3.2 版本之后新增的。

# 使用 Docker 啟動 Redis
$ docker run -d --name redis -p 6379:6379 redis:latest

4. Spring Boot 配置 Redis

4.1 引入依賴

在 pom.xml 中添加 Redis 依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

4.2 配置 Redis 連接

在 application.yml 中配置 Redis 連接信息：

spring:
  redis:
    host: localhost
    port: 6379
    lettuce:
      pool:
        max-active: 8
        max-idle: 8
        min-idle: 0
        max-wait: -1ms

注意：

host 指定 Redis 服務(wù)器的地址，默認(rèn)是 localhost
port 指定 Redis 的端口，默認(rèn) 6379
lettuce 是 Redis 連接池配置，建議調(diào)整 max-active 來優(yōu)化性能

5. 編寫業(yè)務(wù)代碼

5.1 定義 Store 門店實體

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Store {
    private Long id;
    private String name;
    private double longitude;
    private double latitude;
    private String address;
}

說明：

longitude 和 latitude 存儲經(jīng)緯度
id 作為門店的唯一標(biāo)識

5.2 編寫 Redis GEO 相關(guān)操作

1. 添加門店數(shù)據(jù)到 Redis

@Autowired
private RedisTemplate<String, String> redisTemplate;

private static final String GEO_KEY = "stores:geo";

public void addStore(Store store) {
    redisTemplate.opsForGeo().add(
        GEO_KEY,
        new Point(store.getLongitude(), store.getLatitude()),
        store.getId().toString()
    );
}

注意事項：

opsForGeo().add() 方法將門店數(shù)據(jù)存入 Redis
store.getLongitude() 和 store.getLatitude() 確保正確傳入
store.getId().toString() 作為 key，保證唯一性

2. 查詢附近門店

public List<Store> findNearbyStores(double longitude, double latitude, double radiusKm) {
		// 創(chuàng)建該坐標(biāo)需要查找的半徑
    Circle circle = new Circle(new Point(longitude, latitude), new Distance(radiusKm, Metrics.KILOMETERS));

   // 創(chuàng)建所需結(jié)果集參數(shù)
    RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs()
            .includeDistance() //包含距離
            .includeCoordinates() //包含坐標(biāo)
            .sortAscending() //升序排列
            .limit(10);  //結(jié)果集數(shù)量

    GeoResults<RedisGeoCommands.GeoLocation<String>> results = redisTemplate.opsForGeo().radius(GEO_KEY, circle, args);

    List<Store> stores = new ArrayList<>();
    if (results != null) {
        for (GeoResult<RedisGeoCommands.GeoLocation<String>> result : results) {
            String storeId = result.getContent().getName();
            Point point = result.getContent().getPoint();
            Distance distance = result.getDistance();
            stores.add(new Store(Long.parseLong(storeId), "", point.getX(), point.getY(), ""));
            System.out.println("Store ID: " + storeId + ", Distance: " + distance.getValue() + " km");
        }
    }
    return stores;
}

說明：

Circle 定義查詢范圍
includeDistance() 返回距離
includeCoordinates() 返回坐標(biāo)
sortAscending() 按距離排序
limit(10) 限制返回 10 條數(shù)據(jù)

6. 編寫單元測試

@SpringBootTest
class CharmingApplicationTests {

    @Autowired
    private RedisTemplate redisTemplate;

    private static final String GEO_KEY = "stores:geo";

    @Test
    void testFindNearbyStores() {
        redisTemplate.delete(GEO_KEY);

        List<Store> testStores = List.of(
            new Store(100L, "Store A", 116.404, 39.915, "北京天安門"),
            new Store(200L, "Store B", 116.461, 39.923, "北京三里屯"),
            new Store(300L, "Store C", 116.355, 39.901, "北京西單")
        );

        for (Store store : testStores) {
            redisTemplate.opsForGeo().add(GEO_KEY, new Point(store.getLongitude(), store.getLatitude()), store.getId().toString());
        }

        findNearbyStores(116.40, 39.90, 5.0);
    }
}

測試要點：