mongodb 地理位置搜寻

本文主要是介绍mongodb 地理位置搜寻，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

LBS，存储每个地点的经纬度坐标，搜寻附近的地点，建立地理位置索引可提高查询效率。

MongoDB地理位置索引，2d和2dsphere，对应平面和球面。

1.创建lbs集合存放地点坐标

[plain]  view plain copy  
 use lbs;  
   
 db.lbs.insert(  
     {  
         loc:{  
             type: "Point",  
             coordinates: [113.332264, 23.156206]  
         },  
         name: "广州东站"  
     }  
 )  
   
 db.lbs.insert(  
     {  
         loc:{  
             type: "Point",  
             coordinates: [113.330611, 23.147234]  
         },  
         name: "林和西"  
     }  
 )  
   
 db.lbs.insert(  
     {  
         loc:{  
             type: "Point",  
             coordinates: [113.328095, 23.165376]  
         },  
         name: "天平架"  
     }  
 )  

2.创建地理位置索引

[plain]  view plain copy  
 db.lbs.ensureIndex(  
     {  
         loc: "2dsphere"  
     }  
 )  

3.查询附近的坐标

当前位置为：时代广场，

坐标：113.323568, 23.146436

搜寻附近一公里内的点，由近到远排序

[plain]  view plain copy  
 db.lbs.find(  
     {  
         loc: {  
             $near:{  
                 $geometry:{  
                     type: "Point",  
                     coordinates: [113.323568, 23.146436]  
                 },  
                 $maxDistance: 1000  
             }  
         }  
     }  
 )  

搜寻结果：

[plain]  view plain copy  
 { "_id" : ObjectId("556a651996f1ac2add8928fa"), "loc" : { "type" : "Point", "coordinates" : [ 113.330611, 23.147234 ] }, "name" : "林和西" }  

php代码如下：

[php]  view plain copy  
 <?php  
 // 连接mongodb  
 function conn($dbhost, $dbname, $dbuser, $dbpasswd){  
     $server = 'mongodb://'.$dbuser.':'.$dbpasswd.'@'.$dbhost.'/'.$dbname;  
     try{  
         $conn = new MongoClient($server);  
         $db = $conn->selectDB($dbname);  
     } catch (MongoException $e){  
         throw new ErrorException('Unable to connect to db server. Error:' . $e->getMessage(), 31);  
     }  
     return $db;  
 }  
   
 // 插入坐标到mongodb  
 function add($dbconn, $tablename, $longitude, $latitude, $name){  
     $index = array('loc'=>'2dsphere');  
     $data = array(  
             'loc' => array(  
                     'type' => 'Point',  
                     'coordinates' => array(doubleval($longitude), doubleval($latitude))  
             ),  
             'name' => $name  
     );  
     $coll = $dbconn->selectCollection($tablename);  
     $coll->ensureIndex($index);  
     $result = $coll->insert($data, array('w' => true));  
     return (isset($result['ok']) && !empty($result['ok'])) ? true : false;  
 }  
   
 // 搜寻附近的坐标  
 function query($dbconn, $tablename, $longitude, $latitude, $maxdistance, $limit=10){  
     $param = array(  
         'loc' => array(  
             '$nearSphere' => array(  
                 '$geometry' => array(  
                     'type' => 'Point',  
                     'coordinates' => array(doubleval($longitude), doubleval($latitude)),   
                 ),  
                 '$maxDistance' => $maxdistance*1000  
             )  
         )  
     );  
   
     $coll = $dbconn->selectCollection($tablename);  
     $cursor = $coll->find($param);  
     $cursor = $cursor->limit($limit);  
       
     $result = array();  
     foreach($cursor as $v){  
         $result[] = $v;  
     }    
   
     return $result;  
 }  
   
 $db = conn('localhost','lbs','root','123456');  
   
 // 随机插入100条坐标纪录  
 for($i=0; $i<100; $i++){  
     $longitude = '113.3'.mt_rand(10000, 99999);  
     $latitude = '23.15'.mt_rand(1000, 9999);  
     $name = 'name'.mt_rand(10000,99999);  
     add($db, 'lbs', $longitude, $latitude, $name);  
 }  
   
 // 搜寻一公里内的点  
 $longitude = 113.323568;  
 $latitude = 23.146436;  
 $maxdistance = 1;  
 $result = query($db, 'lbs', $longitude, $latitude, $maxdistance);  
 print_r($result);  
 ?>  

演示PHP代码，首先需要在mongodb的lbs中创建用户和执行auth。方法如下：

[plain]  view plain copy  
 use lbs;  
 db.createUser(  
     {  
         "user":"root",  
         "pwd":"123456",  
         "roles":[]  
     }  
 )  
   
 db.auth(  
     {  
         "user":"root",  
         "pwd":"123456"  
     }  
 )  