Memcached 笔记与总结（9）Memcached 与 Session

一、Memcached 存储 Session

由于 Memcached 是分布式的内存对象缓存系统，因此可以用来实现 Session 同步：把 Web 服务器中的内存组合起来，成为一个“内存池”，不管是哪个服务器产生的 Sessoin 都可以放到这个“内存池”中，其他的 Web 服务器都可以使用。使用 Memcached 来同步 Session 的优点是：不会加大数据库的负担，并且安全性比 Cookie 高，把 Session 放到内存里面，读取速度比其他处理方式要快很多。

自定义使用 Memcached 处理 Session 信息，要使用到用户自定义会话存储函数 session_set_save_handler() ，自定义的 Session 类可以参考 ThinkPHP 3.2.3 full 版中的 Session 类（\ThinkPHP\Library\Think\Session\Driver\Memcache.class.php）

注：使用的 php 扩展为 memcache 1.4.24，服务器环境为 Windows7 + PHP 5.3.10 + Apache 2.2.21

memcached.class.php

<?php

class MemcacheSession {

    protected static $lifeTime     = 3600;
    protected static $handle       = null;

    public function start(Memcache $mem) {
        self::$handle = $mem;
        self::$lifeTime = ini_get(‘session.gc_maxlifetime‘);
        session_set_save_handler(
            array(__CLASS__, ‘open‘),
            array(__CLASS__, ‘close‘),
            array(__CLASS__, ‘read‘),
            array(__CLASS__, ‘write‘),
            array(__CLASS__, ‘destroy‘),
            array(__CLASS__, ‘gc‘)
        );
        session_start();
    }

    /**
     * 打开Session
     * @access private
     * @param string $savePath
     * @param mixed $sessName
     */
    private static function open($savePath, $sessName) {
        return true;
    }

    /**
     * 关闭Session
     * @access public
     */
    public static function close() {
        self::gc(self::$lifeTime);
        self::$handle->close();
        self::$handle = null;
        return true;
    }

    /**
     * 读取Session
     * @access private
     * @param string $sessID
     */
    private static function read($sessID) {
        return self::$handle->get($sessID);
    }

    /**
     * 写入Session
     * @access public
     * @param string $sessID
     * @param String $sessData
     */
    public static function write($sessID, $sessData) {
        return self::$handle->set($sessID, $sessData, 0, self::$lifeTime);
    }

    /**
     * 删除Session
     * @access private
     * @param string $sessID
     */
    private static function destroy($sessID) {
        return self::$handle->delete($sessID);
    }

    /**
     * Session 垃圾回收
     * @access private
     * @param string $sessMaxLifeTime
     */
    private static function gc($sessMaxLifeTime) {
        return true;
    }
}

使用 memcached.class.php

session.php

<?php
header(‘Content-type:text/html; charset=utf-8‘);

require ‘memcache.class.php‘;

$mem = new Memcache();
$mem->connect(‘127.0.0.1‘, 11211);

$memclass = new MemcacheSession();
$memclass->start($mem);

$_SESSION[‘username‘] = ‘dee‘;

echo ‘<a href="get.php" target="_blank">跳转</a>‘;

echo ‘<pre>‘;
print_r($_SESSION);
echo session_id(),‘<br />‘;

get.php

<?php

require ‘memcache.class.php‘;

$mem = new Memcache();
$mem->connect(‘127.0.0.1‘, 11211);

$memclass = new MemcacheSession();
$memclass->start($mem);

echo ‘<pre>‘;
print_r($_SESSION);
echo session_id();

二、Memcached 集群实现 Session 共享

模拟开启两台 Memcached 服务器（127.0.0.1：11211 和 127.0.0.1：11212），引入 Memcached 的 Session 类，同时修改 php.ini 中的配置

ini_set(‘memcache.hash_strategy‘, ‘consistent‘);//使用一致性hash算法
ini_set(‘session.save_path‘, ‘tcp://127.0.0.1:11211?weight=10,tcp://127.0.0.1:11212‘);

此时查看 phpinfo 的信息：

设置 Session

cluster_session_set.php

<?php
header(‘Content-type:text/html; charset=utf-8‘);

require ‘memcache.class.php‘;

ini_set(‘memcache.hash_strategy‘, ‘consistent‘);
ini_set(‘session.save_path‘, ‘tcp://127.0.0.1:11211?weight=10,tcp://127.0.0.1:11212‘);

$mem = new Memcache();
$mem->addServer("127.0.0.1",11211) or die ("Could not add server 11211");
$mem->addServer("127.0.0.1",11212) or die ("Could not add server 11212");  

$memclass = new MemcacheSession();
$memclass->start($mem);

$_SESSION[‘username‘] = "deathmask";  

echo session_id();
echo ‘<pre>‘;
print_r($_SESSION);
echo ‘<a href="cluster_session_get.php" target="_blank">跳转</a>‘;

输出：

打印 Session

cluster_session_get.php

<?php

require ‘memcache.class.php‘;

ini_set(‘memcache.hash_strategy‘, ‘consistent‘);
ini_set(‘session.save_path‘, ‘tcp://127.0.0.1:11211?weight=10,tcp://127.0.0.1:11212‘);

$mem = new Memcache();
$mem->addServer("127.0.0.1",11211) or die ("Could not add server 11211");
$mem->addServer("127.0.0.1",11212) or die ("Could not add server 11212");  

$memclass = new MemcacheSession();
$memclass->start($mem);

echo session_id(); 

echo ‘<pre>‘;
print_r($_SESSION);

输出：