详解Redis中地理位置功能Geospatial的应用

目录

• Geospatial Indexes 的数据结构
• 常用命令
• 实用场景示例
• 1. 找出某一经纬度周围的餐馆
• 2. 按照距离排序查询景点
• 3. 根据经纬度计算两点距离

import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.Jedis;
import java.util.List;
public class RestaurantFinder {
    private final static String HOST = "localhost";
    private final static int PORT = 6379;
    private final static int TIMEOUT = 5000;
    private final static String PASSWORD = "";
    private static final String KEY_RESTAURANT_LOCATION = "restaurant_location";
    private static Jedis jedis = null;
    static {
        try {
            jedis = new Jedis(HOST, PORT, TIMEOUT);
            if (!PASSWORD.isEmpty()) {
                jedis.auth(PASSWORD);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 添加餐馆的经纬度信息
     *
     * @param longitude 经度
     * @param latitude  纬度
     * @param name      餐馆名称
     * @return
     */
    public Long addRestaurant(double longitude, double latitude, String name) {
        return jedis.geoadd(KEY_RESTAURANT_LOCATION, longitude, latitude, name);
    }
    /**
     * 根据给定的坐标和半径查找周围的餐馆
     *
     * @param longitude 经度
     * @param latitude  纬度
     * @param radius    半径，单位为米
     * @return
     */
    public List<GeoRadiusResponse> findNearbyRestaurants(double longitude, double latitude, double radius) {
        return jedis.georadius(KEY_RESTAURANT_LOCATION, longitude, latitude, radius, GeoUnit.M);
    }
    /**
     * 测试
     *
     * @param args
     */
    public static void main(String[] args) {
        RestaurantFinder finder = new RestaurantFinder();
        finder.addRestaurant(121.451087, 31.228591, "麦当劳");
        finder.addRestaurant(121.454987, 31.227568, "星巴克");
        finder.addRestaurant(121.455831, 31.225719, "肯德基");
        List<GeoRadiusResponse> restaurants = finder.findNearbyRestaurants(121.453289, 31.228032, 500);
        for (GeoRadiusResponse restaurant : restaurants) {
            System.out.println(restaurant.getMemberByString() + " " + restaurant.getDistance());
        }
    }
}

import redis.clients.jedis.GeoRadiusParam;
import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.Jedis;
import java.util.List;
public class ScenicSpotFinder {
    private final static String HOST = "localhost";
    private final static int PORT = 6379;
    private final static int TIMEOUT = 5000;
    private final static String PASSWORD = "";
    private static final String KEY_SPOT_LOCATION = "spot_location";
    private static Jedis jedis = null;
    static {
        try {
            jedis = new Jedis(HOST, PORT, TIMEOUT);
            if (!PASSWORD.isEmpty()) {
                jedis.auth(PASSWORD);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 添加景点的经纬度信息
     *
     * @param longitude 经度
     * @param latitude  纬度
     * @param name      景点名称
     * @return
     */
    public Long addScenicSpot(double longitude, double latitude, String name) {
        return jedis.geoadd(KEY_SPOT_LOCATION, longitude, latitude, name);
    }
    /**
     * 根据给定的坐标和半径查找周围的景点，并按照距离排序
     *
     * @param longitude 经度
     * @param latitude  纬度
     * @param radius    半径，单位为米
     * @return
     */
    public List<GeoRadiusResponse> findNearbyScenicSpots(double longitude, double latitude, double radius) {
        GeoRadiusParam geoRadiusParam = GeoRadiusParam.geoRadiusParam().sortAscending();
        return jedis.georadius(KEY_SPOT_LOCATION, longitude, latitude, radius, GeoUnit.M, geoRadiusParam);
    }
    /**
     * 测试
     *
     * @param args
     */
    public static void main(String[] args) {
        ScenicSpotFinder finder = new ScenicSpotFinder();
        finder.addScenicSpot(121.451087, 31.228591, "东方明珠");
        finder.addScenicSpot(121.454987, 31.227568, "外滩");
        finder.addScenicSpot(121.455831, 31.225719, "人民广场");
        List<GeoRadiusResponse> spots = finder.findNearbyScenicSpots(121.453289, 31.228032, 500);
        for (GeoRadiusResponse spot : spots) {
            System.out.println(spot.getMemberByString() + " " + spot.getDistance());
        }
    }
}

import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.Jedis;
public class DistanceCalculator {
    private final static String HOST = "localhost";
    private final static int PORT = 6379;
    private final static int TIMEOUT = 5000;
    private final static String PASSWORD = "";
    private static Jedis jedis = null;
    static {
        try {
            jedis = new Jedis(HOST, PORT, TIMEOUT);
            if (!PASSWORD.isEmpty()) {
                jedis.auth(PASSWORD);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 计算两个经纬度之间的距离
     *
     * @param longitude1 经度1
     * @param latitude1  纬度1
     * @param longitude2 经度2
     * @param latitude2  纬度2
     * @return
     */
    public Double calculateDistance(double longitude1, double latitude1, double longitude2, double latitude2) {
        return jedis.geodist("distance", longitude1, latitude1, longitude2, latitude2, GeoUnit.M);
    }
    /**
     * 测试
     *
     * @param args
     */
    public static void main(String[] args) {
        DistanceCalculator calculator = new DistanceCalculator();
        double distance = calculator.calculateDistance(121.453289, 31.228032, 121.451087, 31.228591);
        System.out.println(distance);
    }
}