mongodb探索2

三里屯摇滚

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的类

1. <?php
   
2. 
   
3. class DBConnection
   
4. {
   
5.     const HOST   = 'localhost';
   
6.     const PORT   = 27017;
   
7.     const DBNAME = 'myblogsite';
   
8.    
   
9.     private static $instance;
   
10.    
    
11.     public $connection;   
    
12.     public $database;
    
13.    
    
14.     private function __construct()
    
15.     {
    
16.         $connectionString = sprintf('mongodb://%s:%d', DBConnection::HOST, DBConnection::PORT);
    
17. 
    
18.         try {
    
19.             
    
20.             $this->connection = new Mongo($connectionString);
    
21.             $this->database = $this->connection->selectDB(DBConnection::DBNAME);
    
22.          
    
23.         } catch (MongoConnectionException $e) {
    
24.             throw $e;
    
25.         }
    
26.     }
    
27.    
    
28.     static public function instantiate()
    
29.     {
    
30.         if (!isset(self::$instance)) {
    
31.             $class = __CLASS__;
    
32.             self::$instance = new $class;
    
33.         }
    
34.         
    
35.         return self::$instance;
    
36.     }
    
37.    
    
38.     public function getCollection($name)
    
39.     {
    
40.         return $this->database->selectCollection($name);
    
41.     }
    
42. }
    
43. ?>

复制代码

3 一个处理session的类，sessionmanager:

1. <?php
   
2. 
   
3. require_once('dbconnection.php');
   
4. 
   
5. class SessionManager{
   
6.         
   
7.     const COLLECTION = 'sessions'; //name of collection where sessions will be stored
   
8.      
   
9.     const SESSION_TIMEOUT = 600;    //Expire session after 10 mins in inactivity
   
10.      const SESSION_LIFESPAN = 3600;  //1 hour
    
11.     const SESSION_NAME = 'mongosessid'; //name of the session cookie
    
12.    
    
13.     const SESSION_COOKIE_PATH = '/';
    
14.     const SESSION_COOKIE_DOMAIN = ''; //should domain name of you web app, for example .mywebapp.com
    
15.      
    
16.     private $_mongo;
    
17.     private $_collection;
    
18.    
    
19.     private $_currentSession;
    
20.    
    
21.     public function __construct()
    
22.     {
    
23.         $this->_mongo = DBConnection::instantiate();
    
24.         $this->_collection = $this->_mongo->getCollection(SessionManager::COLLECTION);
    
25.          
    
26.         session_set_save_handler(
    
27.             array(&$this, 'open'),
    
28.             array(&$this, 'close'),
    
29.             array(&$this, 'read'),
    
30.             array(&$this, 'write'),
    
31.             array(&$this, 'destroy'),
    
32.             array(&$this, 'gc')            
    
33.         );
    
34.         
    
35.         // set session garbage collection period
    
36.         ini_set('session.gc_maxlifetime', SessionManager::SESSION_LIFESPAN);
    
37. 
    
38.         session_set_cookie_params(  SessionManager::SESSION_LIFESPAN,
    
39.                                     SessionManager::SESSION_COOKIE_PATH,
    
40.                                     SessionManager::SESSION_COOKIE_DOMAIN
    
41.         );
    
42.         
    
43.         
    
44.         session_name(SessionManager::SESSION_NAME);
    
45.         session_cache_limiter('nocache');
    
46.         session_start();
    
47.     }
    
48.    
    
49.     public function open($path, $name)
    
50.     {
    
51.         return true;
    
52.     }
    
53.    
    
54.     public function close()
    
55.     {
    
56.         return true;
    
57.     }
    
58.    
    
59.     public function read($sessionId)
    
60.     {
    
61.         $query = array(
    
62.                         'session_id' => $sessionId,
    
63.                         'timedout_at' => array('$gte' => time()),
    
64.                         'expired_at' => array('$gte' => time())
    
65.                       );
    
66.                      
    
67.         $result = $this->_collection->findOne($query);
    
68.         
    
69.         $this->_currentSession = $result;
    
70.         
    
71.         if(!isset($result['data'])){
    
72.             return '';
    
73.         }
    
74.         
    
75.         return $result['data'];
    
76.     }
    
77.    
    
78.     public function write($sessionId, $data)
    
79.     {
    
80.         $new_obj = array(
    
81.                           'data' => $data,
    
82.                           'timedout_at' => time() + self::SESSION_TIMEOUT,
    
83.                           'expired_at' => (empty($this->_currentSession)) ? time() + SessionManager::SESSION_LIFESPAN
    
84.                                                                            : $this->_currentSession['expired_at']
    
85.                          );
    
86. 
    
87.         $query = array('session_id' => $sessionId);
    
88.         
    
89.         $this->_collection->update(
    
90.                                     $query,
    
91.                                     array('$set' => $new_obj),
    
92.                                     array('upsert' => True)
    
93.                                   );
    
94.         return True;
    
95.     }
    
96.    
    
97.     public function destroy($sessionId)
    
98.     {
    
99.         $this->_collection->remove(array('session_id' => $sessionId));
    
100.         
     
101.         return True;
     
102.     }
     
103.    
     
104.     public function gc()
     
105.     {
     
106.         $query = array('expired_at' => array( '$lt' => time()));
     
107.         
     
108.         $this->_collection->remove($query);
     
109.         
     
110.         return True;
     
111.     }
     
112.    
     
113.     public function __destruct()
     
114.     {
     
115.         session_write_close();
     
116.     }
     
117. }
     
118. 
     
119. $session = new SessionManager();

复制代码

如果有一天21

谢谢分享