Redis を使用して分散地理的位置クエリを実装する方法-Redis-php.cn

Redis を使用して分散地理的位置クエリを実装する方法

PHPz

リリース： 2023-11-07 10:32:08

オリジナル

1276 人が閲覧しました

Redis を使用して分散地理的位置クエリを実装する方法

Redis を使用して分散型地理的位置クエリを実装する方法

地理的位置クエリは、近くのレストランを見つけたり、特急パッケージを見つけたり、日常生活のあらゆる場所で見ることができます。等従来のリレーショナルデータベースでは、地理的位置のクエリを実装するには複雑な空間インデックスと距離の計算が必要ですが、大規模なデータ量に対しては非効率的です。 Redis は、高性能の非リレーショナルインメモリデータベースとして、優れたキャッシュ特性と分散サポートを備えており、分散地理的位置クエリの実装に非常に適しています。この記事では、Redis を使用してこの機能を実装する方法と、具体的なコード例を紹介します。

1. データ構造の設計

分散地理的位置クエリを実装する前に、まず適切なデータ構造を設計する必要があります。 Redis は、地理的位置情報を保存するためのソートセットを提供します。それぞれの地理的位置は経度と緯度で表すことができます。

経度と緯度を順序付きセットのスコアとして使用し、地理的位置の一意の識別子を順序付きセットのメンバーとして使用できます。このように、順序付きセットの特性を利用して、スコアに応じてすばやく並べ替えたり検索したりできます。

2. データの挿入

地理的位置データを挿入する前に、まず Redis サーバーに接続する必要があります。これは、Redis の Java クライアントである Jedis を使用して実現できます。以下は、地理的位置データを挿入するコード例です:

import redis.clients.jedis.Jedis;

public class GeoLocationInsert {

    public static void main(String[] args) {
        // 连接Redis服务器
        Jedis jedis = new Jedis("localhost", 6379);

        // 设置地理位置经纬度
        double longitude = 116.403834;
        double latitude = 39.915216;

        // 添加地理位置数据到有序集合
        jedis.zadd("geo:locations", longitude, latitude, "Beijing");

        // 关闭连接
        jedis.close();
    }
}

ログイン後にコピー

3. データクエリ

近くの地理的位置データをクエリする場合、順序付きコレクションの範囲クエリ関数を使用できます。以下は、近くの地理的位置データをクエリするコード例です。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.GeoRadiusResponse;
import redis.clients.jedis.params.GeoRadiusParam;

public class GeoLocationQuery {
    
    public static void main(String[] args) {
        // 连接Redis服务器
        Jedis jedis = new Jedis("localhost", 6379);

        // 设置中心地理位置经纬度
        double longitude = 116.403834;
        double latitude = 39.915216;

        // 查询附近地理位置数据
        GeoRadiusResponse[] responses = jedis.georadius("geo:locations", longitude, latitude, 10, GeoUnit.KM, GeoRadiusParam.geoRadiusParam().withDist());

        // 打印查询结果
        for (GeoRadiusResponse response : responses) {
            System.out.println(response.getMemberByString() + ", 距离: " + response.getDistance());
        }

        // 关闭连接
        jedis.close();
    }
}

ログイン後にコピー

上記のコードでは、中央の地理的位置の経度と緯度を設定し、georadius コマンドを使用して、中心から離れた指定された地理的位置をクエリします。距離範囲内の近くの位置データ。返される結果には、近くの地理的位置の一意の識別子 (メンバー) と距離 (dist) が含まれます。

jedis.georadius メソッドの最後のパラメータは GeoRadiusParam.geoRadiusParam().withDist() であることに注意してください。これは、距離情報が必要であることを意味します。返される。

4. 分散デプロイメント

分散地理的位置クエリを実装する場合、複数の Redis ノードに地理的位置データを保存し、各ノードにデータを均等に分散できます。これにより、負荷分散と高可用性が可能になります。

次は、Redis クラスターを使用して分散地理的位置クエリを実装するコード例です。

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

public class GeoLocationClusterQuery {

    public static void main(String[] args) {
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();
        jedisClusterNodes.add(new HostAndPort("localhost", 7000));
        jedisClusterNodes.add(new HostAndPort("localhost", 7001));
        jedisClusterNodes.add(new HostAndPort("localhost", 7002));
        jedisClusterNodes.add(new HostAndPort("localhost", 7003));
        jedisClusterNodes.add(new HostAndPort("localhost", 7004));
        jedisClusterNodes.add(new HostAndPort("localhost", 7005));

        // 连接Redis Cluster
        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 设置中心地理位置经纬度
        double longitude = 116.403834;
        double latitude = 39.915216;

        // 查询附近地理位置数据
        GeoRadiusResponse[] responses = jedisCluster.georadius("geo:locations", longitude, latitude, 10, GeoUnit.KM, GeoRadiusParam.geoRadiusParam().withDist());

        // 打印查询结果
        for (GeoRadiusResponse response : responses) {
            System.out.println(response.getMemberByString() + ", 距离: " + response.getDistance());
        }

        // 关闭连接
        jedisCluster.close();
    }
}

ログイン後にコピー

上記のコードでは、JedisCluster クラスを使用して、 Redis Cluster クラスター、次に地理位置情報クエリ。