旧有的MongodbClient类已经被废弃了，现在PHP 连接mongo的时候使用新的MongoDB\Driver\Manager 来创建，下面是随便简单的封装了一个类，用来增删改查，只是实现了简单了，复杂的还是看文档比较靠谱Php_Mongodb - 图1
    Php_Mongodb - 图2

    1. <?php
    2. /**
    3.  * Created by PhpStorm.
    4.  * User: raye
    5.  * Date: 17/11/30
    6.  * Time: 19:00
    7.  */
    8. use MongoDB\Driver\Manager;
    9. use MongoDB\Driver\Query;
    10. use MongoDB\Driver\BulkWrite;
    11. use MongoDB\Driver\ReadPreference;
    12. class MongodbManage {
    13.     /** @var  Manager  $instance*/
    14.     private static $instance;
    15.     private static $_dbname;
    16.     private $manager;
    17.     private $_host = '192.168.1.83';
    18.     private $_port = 27017;
    19.     private $_bulk;
    21.     private function __construct($dbname)
    22.     {
    23.         self::$_dbname = $dbname;
    24.         $this->_bulk = new BulkWrite();
    25.         $this->manager = new Manager('mongodb://' . $this->_host .':'. $this->_port . '/' . self::$_dbname);
    26.     }
    28.     public static function instance($dbname){
    29.         if (self::$_dbname == $dbname && self::$instance instanceof self) {
    30.             return self::$instance;
    31.         }
    32.         self::$instance = new self($dbname);
    33.         return self::$instance;
    34.     }
    36.     public function insert($collection, array $data){
    37.         if (empty($collection) || empty($data)) {
    38.             throw new Exception('collection or insert data can not be null');
    39.         }
    41.         try{
    42.             $this->_bulk->insert($data);
    43.             return $this->manager->executeBulkWrite(self::$_dbname .'.'. $collection, $this->_bulk);
    44.         }catch (Exception $e) {
    45.             new Exception($e->getLine() . '--' . $e->getMessage());
    46.         }
    47.     }
    49.     public function find($collection, array $filter = [], $returnArr = false, array $options = [], $readPreference = 'primary'){
    50.         if (empty($collection)) {
    51.             throw new Exception('collection can not be null');
    52.         }
    54.         $query = new Query($filter, $options);
    55.         $res = $this->manager->executeQuery(self::$_dbname .'.'. $collection, $query, new ReadPreference($readPreference))->toArray();
    57.         if (!$returnArr){
    58.             return $res;
    59.         }
    61.         array_walk($res,function (&$value){
    62.             $value = (array)$value;
    63.         });
    64.         return $res;
    65.     }
    67.     public function multiInsert($collection, array $data){
    68.         if (empty($collection) || empty($data)) {
    69.             throw new Exception('collection and data can not be empty');
    70.         }
    71.         foreach ($data as $value) {
    72.             $this->_bulk->insert($value);
    73.         }
    74.         $res = $this->manager->executeBulkWrite(self::$_dbname .'.'. $collection, $this->_bulk);
    75.         return $res and $res->getInsertedCount() > 0 ? true : false;
    76.     }
    77.     public function update($collection, $filter, array $data) {
    78.         if (empty($collection) || empty($filter)) {
    79.             throw new Exception('collection and filter can not be null');
    80.         }
    81.         $this->_bulk->update($filter, $data);
    82.         $res = $this->manager->executeBulkWrite(self::$_dbname .'.'. $collection,$this->_bulk);
    84.         return $res->getModifiedCount() > 0 ? true : false;
    85.     }
    87.     public function delete($collection, $filter, $options = []){
    88.         if (empty($collection) || empty($filter)) {
    89.             throw new Exception('collection and filter can not be null');
    90.         }
    91.         $this->_bulk->delete($filter, $options);
    92.         $res = $this->manager->executeBulkWrite(self::$_dbname .'.'. $collection, $this->_bulk);
    94.         return $res->getDeletedCount() > 0 ? true : false;
    95.     }
    97. }