怎么样使用 Redis 来存储和查询 ip 数据

摘要：今天我的朋友佛手给我打了个电话，他们网站的业务要根据客户的地址快速定位客户的地理位置。其中是我们要查询的结果，当然你也可以把和包括进去。我这里就用来特指查询结果了。这样我们的查询就很简单了，只需要用查询出离最近对应的两个即可。

今天我的朋友佛手给我打了个电话，他们网站的业务要根据客户的 ip 地址快速定位客户的地理位置。网上已经有一大堆类似的 ip 地址库可以用，但问题是这些地址库的数据表结构大多如下所示

+--------------+------------------+------+-----+---------+----------------+
| Field        | Type             | Null | Key | Default | Extra          |
+--------------+------------------+------+-----+---------+----------------+
| ip_id        | int(11) unsigned | NO   | PRI | NULL    | auto_increment |
| ip_country   | varchar(50)      | NO   |     | NULL    |                |
| ip_startip   | bigint(11)       | NO   | MUL | NULL    |                |
| ip_endip     | bigint(11)       | NO   | MUL | NULL    |                |
| country_code | varchar(2)       | NO   |     | NULL    |                |
| zone_id      | int(11)          | NO   |     | 0       |                |
+--------------+------------------+------+-----+---------+----------------+

最核心的部分是三个：ip_startip、ip_endip 以及 ip_id。其中 ip_id 是我们要查询的结果，当然你也可以把 zone_id 和 ip_country 包括进去。我这里就用 ip_id 来特指查询结果了。

面对这个表，没什么其它办法，你的查询语句只能是

sqlSELECT * FROM who_ip WHERE ip_startip <= {ip} AND ip_endip >= {ip}

188.88.77.22 - 188.88.77.255
188.89.0.0 - 188.89.255.255
188.90.0.0 - 189.90.78.10

phpconnect(REDIS_HOST, REDIS_PORT);
        $redis->select(REDIS_DB);
    }

    $key = "ip:" . $page;
    $redis->zAdd($key, $offset, $value);
}

$page = 0;
do {
    $offset = $page * MYSQL_PAGESIZE;
    $count = 0;

    $res = mysql_query("SELECT * FROM " . MYSQL_TABLE . " LIMIT " . MYSQL_PAGESIZE . " OFFSET {$offset}");

    while ($ip = mysql_fetch_assoc($res)) {
        $start = $ip[MYSQL_COLUMN_START];
        $end = $ip[MYSQL_COLUMN_END];
        $value = $ip[MYSQL_COLUMN_ID];

        $startOffset = $start % 65536;
        $endOffset = $end % 65536;

        $start -= $startOffset;
        $end -= $endOffset;

        $startPage = $start / 65536;
        $endPage = $end / 65536;

        for ($i = $startPage; $i <= $endPage; $i ++) {
            if ($i == $startPage) {
                add_ip($i, $startOffset, "s:" . $value);

                if ($i != $endPage) {
                    add_ip($i, 65535, "e:" . $value);
                }
            }

            if ($i == $endPage) {
                add_ip($i, $endOffset, "e:" . $value);

                if ($i != $startPage) {
                    add_ip($i, 0, "s:" . $value);
                }
            }

            if ($i != $endPage && $i != $startPage) {
                add_ip($i, 0, "s:" . $value);
                add_ip($i, 65535, "e:" . $value);
            }
        }

        echo ($page * MYSQL_PAGESIZE + $count) . "
";
        $count ++;
    }

    $page ++;
} while ($count = MYSQL_PAGESIZE);

phpconnect(REDIS_HOST, REDIS_PORT);
$redis->select(REDIS_DB);

$ip = ip2long("173.255.218.70");
$offset = $ip % 65536;
$page = ($ip - $offset) / 65536;


// 取出小于等于它的最接近值
$start = $redis->zRevRangeByScore("ip:" . $page, 0, $offset, array(
    "limit" => array(0, 1)
));

// 取出大于等于它的最接近值
$end = $redis->zRangeByScore("ip:" . $page, $offset, 65535, array(
    "limit" => array(0, 1)
));

if (empty($start) || empty($end)) {
    echo "unknown";
    exit;
}

$start = $start[0];
$end = $end[0];

list ($startOp, $startId) = explode(":", $start);
list ($endOp, $endId) = explode(":", $end);

if ($startId != $endId) {
    echo "unknown";
    exit;
}

echo $startId;