Java整合Redis實(shí)現(xiàn)坐標(biāo)附近查詢功能

更新時間：2023年11月15日 10:56:49 作者：于京京9909

這篇文章主要介紹了Java整合Redis實(shí)現(xiàn)坐標(biāo)附近查詢,我們可以在redis服務(wù)器使用命令 help xxx 查看指令的具體用法,本文給大家介紹的非常詳細(xì),感興趣的朋友一起看看吧

一、GEO用法引入

GEO，全稱Geolocation，代表地理坐標(biāo)?？梢栽谄渲写鎯Φ乩碜鴺?biāo)信息，幫助我們根據(jù)經(jīng)緯度來檢索數(shù)據(jù)。常見的命令有：
GEOADD：添加一個或多個地理空間信息，包含：經(jīng)度（longitude）、緯度（latitude）、值（member）
GEODIST：計算指定的兩個點(diǎn)之間的距離并返回
GEOHASH：將指定member的坐標(biāo)轉(zhuǎn)為hash字符串形式并返回
GEOPOS：返回指定member的坐標(biāo)
GEORADIUS：指定圓心、半徑，找到該圓內(nèi)包含的所有member，并按照與圓心之間的距離排序后返回。（6.2以后已廢棄）
GEOSEARCH：在指定范圍內(nèi)搜索member，并按照與指定點(diǎn)之間的距離排序后返回。范圍可以是圓形或矩形。（6.2以后新命令）
GEOSEARCHSTORE：與GEOSEARCH功能一致，不過可以把結(jié)果存儲到一個指定的key。（6.2以后新命令）

我們可以在redis服務(wù)器使用命令 help xxx 查看指令的具體用法~

二、引入依賴

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

三、實(shí)體類

1.返回實(shí)體

@Data
public class Geo<T> {
    private T object;
    private double distance;
}

2.添加的商戶信息

 
@Data
@ApiModel("商戶信息DO")
public class CommercialDO implements Serializable {
    private static final long serialVersionUID = 1L;
    @TableId(type = IdType.AUTO)
    /**
     * id
     */
    private Integer id;
    /**
     * 商戶名稱
     */
    private String name;
    /**
     * 商戶類型
     */
    private String commercialType;
    /**
     * 門店名稱
     */
    private String storeName;
    /**
     * 商戶地址
     */
    private String address;
    /**
     * 項(xiàng)目code
     */
    private String itemCode;
    /**
     * 經(jīng)度
     */
    private String longitude;
    /**
     * 緯度
     */
    private String latitude;
}

四、添加位置信息

    @ApiOperation("geo測試添加位置信息")
    @GetMapping("/geo/add")
    public String geoAdd(String key, double longitude, double latitude, CommercialDO commercialDO) throws Exception {
        redisUtils.geoAdd(key, longitude, latitude, commercialDO);
        return "添加成功";
    }

    public void geoAdd(String key, double longitude, double latitude, Object object) {
        redisTemplate.boundGeoOps(key).add(new Point(longitude, latitude),object);
    }

五、查詢位置信息

    /**
     * 根據(jù)經(jīng)緯度獲取指定距離范圍內(nèi)的地理位置信息
     *
     * @param key           Redis中Geo操作的key
     * @param longitude     經(jīng)度
     * @param latitude      緯度
     * @param distance      距離范圍（單位：米）
     * @param limit         限制返回結(jié)果的數(shù)量
     * @param searchName    地點(diǎn)名稱（可選）
     * @return              返回地理位置信息的列表
     */
    public List<Geo<T>> getNearbyByGeo(String key, double longitude, double latitude, int distance, int limit, String searchName) {
        List<Geo<T>> geos = new ArrayList<>();
        BoundGeoOperations boundGeoOperations = redisTemplate.boundGeoOps(key);
        Point point = new Point(longitude, latitude);
        Circle within = new Circle(point, distance);
        RedisGeoCommands.GeoRadiusCommandArgs geoRadiusArgs = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs();
        geoRadiusArgs = geoRadiusArgs.includeDistance();
        geoRadiusArgs.limit(limit);
        geoRadiusArgs.sortAscending();
        GeoResults<RedisGeoCommands.GeoLocation<Object>> geoResults = boundGeoOperations.radius(within, geoRadiusArgs);
        List<GeoResult<RedisGeoCommands.GeoLocation<Object>>> geoResultList = geoResults.getContent();
        if (StringUtils.isNotBlank(searchName)) {
            geoResultList = geoResults.getContent()
                    .stream()
                    .filter(result -> result.getContent().getName().toString().contains(searchName))
                    .collect(Collectors.toList());
        }
        Geo geo;
        for (GeoResult<RedisGeoCommands.GeoLocation<Object>> geoResult : geoResultList) {
            geo = new Geo();
            geo.setObject(geoResult.getContent());
            geo.setDistance(geoResult.getDistance().getValue());
            geos.add(geo);
        }
        return geos;
    }

結(jié)果：會根據(jù)距離自動排序，傳遞名稱則模糊查詢