mongodb探索2

1  mongodb处理session:

    cookie只是session绑定客户端的一种途径，其它的还有比如url等 session_set_save_handler仅仅是对服务器端，session的存储方式，默认为文件存储，可更改为任何其它存储，比如数据库，memcache等
  可以使用 session_set_save_handler的函数：
  bool session_set_save_handler(callback $open, callback $close,
callback $read, callback $write,
callback $destroy, callback $gc)
    注意： 使用本函数前，先要配置php.ini文件，session.save_hadler=user ，否则，session_set_save_handler()不会生效。

   第一个参数是打开会话时调用的处理器，接受两个参数 save_path 和 session_name，分别是会话保存路径 (要记得 PHP 默认机制是文件方式的，因此有文件路径) 和 COOKIE 中用于保存 SESSION ID 的键名，其中键名可以通过 session_name 来获取和修改

第二个参数是关闭会话时的处理器，没有参数

第三个参数是读取会话时的处理器，接受一个参数 session_id，代表 COOKIE 中保存的会话 ID

第四个参数是保存会话时的处理器，接受两个参数 session_id 和 session_data。官方手册中提及到，PHP 5.0.5 以后，close 和 write 处理器将会在类析构之后调用，因此处理器内不能使用类和抛出异常 (Exception 也是一个类) 而在析构函数内可以使用 SESSION，因此我们需要在程序中 (比如在 open 或者 read 处理器内) 声明一下保证让 session_write_close 在析构前完成

register_shutdown_function('session_write_close');

第五个参数是删除会话时的处理器，接受一个参数 session_id，代表 COOKIE 中保存的会话 ID

最后一个参数是会话过期时的处理器，接受一个参数 maxlifetime，代表超时秒数

2 一个PHP连接MONGODB的类
   <?php

class DBConnection
{
    const HOST   = 'localhost';
    const PORT   = 27017;
    const DBNAME = 'myblogsite';
   
    private static $instance;
   
    public $connection;   
    public $database;
   
    private function __construct()
    {
        $connectionString = sprintf('mongodb://%s:%d', DBConnection::HOST, DBConnection::PORT);

        try {
           
            $this->connection = new Mongo($connectionString);
            $this->database = $this->connection->selectDB(DBConnection::DBNAME);
       
        } catch (MongoConnectionException $e) {
            throw $e;
        }
    }
   
    static public function instantiate()
    {
        if (!isset(self::$instance)) {
            $class = __CLASS__;
            self::$instance = new $class;
        }
       
        return self::$instance;
    }
   
    public function getCollection($name)
    {
        return $this->database->selectCollection($name);
    }
}
?>

3 一个处理session的类，sessionmanager:
   <?php

require_once('dbconnection.php');

class SessionManager{
       
    const COLLECTION = 'sessions'; //name of collection where sessions will be stored
   
    const SESSION_TIMEOUT = 600;    //Expire session after 10 mins in inactivity
    const SESSION_LIFESPAN = 3600;  //1 hour
    const SESSION_NAME = 'mongosessid'; //name of the session cookie
   
    const SESSION_COOKIE_PATH = '/';
    const SESSION_COOKIE_DOMAIN = ''; //should domain name of you web app, for example .mywebapp.com
   
    private $_mongo;
    private $_collection;
   
    private $_currentSession;
   
    public function __construct()
    {
        $this->_mongo = DBConnection::instantiate();
        $this->_collection = $this->_mongo->getCollection(SessionManager::COLLECTION);
       
        session_set_save_handler(
            array(&$this, 'open'),
            array(&$this, 'close'),
            array(&$this, 'read'),
            array(&$this, 'write'),
            array(&$this, 'destroy'),
            array(&$this, 'gc')           
        );
       
        // set session garbage collection period
        ini_set('session.gc_maxlifetime', SessionManager::SESSION_LIFESPAN);

        session_set_cookie_params(  SessionManager::SESSION_LIFESPAN,
                                    SessionManager::SESSION_COOKIE_PATH,
                                    SessionManager::SESSION_COOKIE_DOMAIN
        );
       
       
        session_name(SessionManager::SESSION_NAME);
        session_cache_limiter('nocache');
        session_start();
    }
   
    public function open($path, $name)
    {
        return true;
    }
   
    public function close()
    {
        return true;
    }
   
    public function read($sessionId)
    {
        $query = array(
                        'session_id' => $sessionId,
                        'timedout_at' => array('$gte' => time()),
                        'expired_at' => array('$gte' => time())
                      );
                     
        $result = $this->_collection->findOne($query);
       
        $this->_currentSession = $result;
       
        if(!isset($result['data'])){
            return '';
        }
       
        return $result['data'];
    }
   
    public function write($sessionId, $data)
    {
        $new_obj = array(
                          'data' => $data,
                          'timedout_at' => time() + self::SESSION_TIMEOUT,
                          'expired_at' => (empty($this->_currentSession)) ? time() + SessionManager::SESSION_LIFESPAN
                                                                          : $this->_currentSession['expired_at']
                        );

        $query = array('session_id' => $sessionId);
       
        $this->_collection->update(
                                    $query,
                                    array('$set' => $new_obj),
                                    array('upsert' => True)
                                  );
        return True;
    }
   
    public function destroy($sessionId)
    {
        $this->_collection->remove(array('session_id' => $sessionId));
       
        return True;
    }
   
    public function gc()
    {
        $query = array('expired_at' => array( '$lt' => time()));
       
        $this->_collection->remove($query);
       
        return True;
    }
   
    public function __destruct()
    {
        session_write_close();
    }
}

$session = new SessionManager();