Comment utiliser Redis pour implémenter une requête de localisation géographique distribuée

Comment utiliser Redis pour implémenter une requête de localisation géographique distribuée

La requête de géolocalisation peut être vue partout dans notre vie quotidienne, comme trouver des restaurants à proximité, localiser des colis express, etc. Dans les bases de données relationnelles traditionnelles, la mise en œuvre de requêtes de localisation géographique nécessite des index spatiaux et des calculs de distance complexes, inefficaces pour des volumes de données à grande échelle. En tant que base de données en mémoire non relationnelle hautes performances, Redis possède d'excellentes caractéristiques de mise en cache et une prise en charge distribuée, et est très approprié pour la mise en œuvre de requêtes de localisation géographique distribuées. Cet article explique comment utiliser Redis pour implémenter cette fonction et fournit des exemples de code spécifiques.

1. Conception de la structure des données

Avant de mettre en œuvre une requête de localisation géographique distribuée, nous devons d'abord concevoir une structure de données appropriée. Redis fournit un ensemble trié pour stocker les informations de localisation géographique. Chaque emplacement géographique peut être représenté par la longitude et la latitude.

Nous pouvons utiliser la longitude et la latitude comme score dans l'ensemble ordonné, et l'identifiant unique de l'emplacement géographique comme membre dans l'ensemble ordonné. De cette façon, vous pouvez utiliser les caractéristiques des ensembles ordonnés pour trier et rechercher rapidement en fonction des scores.

2. Insertion de données

Avant d'insérer des données de localisation géographique, nous devons d'abord nous connecter au serveur Redis. Ceci peut être réalisé en utilisant Jedis, le client Java pour Redis. Voici un exemple de code pour insérer des données de localisation géographique :

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. Requête de données

Lors de l'interrogation de données de localisation géographique à proximité, nous pouvons utiliser la fonction de requête de plage d'un ensemble ordonné. Voici un exemple de code pour interroger des données de localisation géographique à proximité :

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();
    }
}

Dans le code ci-dessus, nous définissons la longitude et la latitude de l'emplacement géographique central, puis utilisons la commande georadius pour interroger le spécifié. plage de distance à partir de l'emplacement géographique central à proximité des données de localisation. Le résultat renvoyé contient l'identifiant unique (membre) et la distance (dist) de l'emplacement géographique à proximité. georadius命令来查询离中心地理位置指定距离范围内的附近地理位置数据。返回结果中包含了附近地理位置的唯一标识(member)和距离(dist)。

需要注意的是，jedis.georadius方法的最后一个参数为GeoRadiusParam.geoRadiusParam().withDist()，表示需要返回距离信息。

四、分布式部署

实现分布式地理位置查询时，我们可以将地理位置数据存储在多个Redis节点上，通过一致性哈希算法将数据均匀分布到各个节点上。这样可以实现负载均衡和高可用性。

下面是利用Redis Cluster实现分布式地理位置查询的代码示例：

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

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!