OpenPNE 3

#   name の値には、 file, database, memcache, redis の他、任意のセッションストレージクラス名が使用できます

#   ("file", "database", "memcached", "redis" and any class names of session storage class as value of "name")

    elseif ('redis' === $name)

    {

      sfConfig::set('sf_factory_storage', 'opRedisSessionStorage');

      sfConfig::set('sf_factory_storage_parameters', array_merge((array)$options, $params));

    }

<?php

/**

 * This file is part of the OpenPNE package.

 * (c) OpenPNE Project (http://www.openpne.jp/)

 *

 * For the full copyright and license information, please view the LICENSE

 * file and the NOTICE file that were distributed with this source code.

 */

/**

 * opRedisSessionStorage

 *

 * @package    OpenPNE

 * @subpackage user

 * @author     Shinichi Urabe <urabe@tejimaya.com>

 */

class opRedisSessionStorage extends sfSessionStorage

{

  protected $redis = null;

  protected $defaults = array(

    'persistent' => true,

    'host'       => 'localhost',

    'port'       => 6379,

    'database'   => 0,

    'timeout'    => 60,

  );

  /**

   * Available options:

   *

   * - host:       The default host (default to localhost)

   * - port:       The port for the default server (default to 6379)

   * - database:   The default database (default to 0)

   * - persistent: true if the connection must be persistent, false otherwise (true by default)

   *

   * @param  array $options  An associative array of options

   *

   * @see sfSessionStorage

   */

  public function initialize($options = array())

  {

    $isAutoStart = true;

    if (isset($options['auto_start']))

    {

      $isAutoStart = $options['auto_start'];

    }

    // disable auto_start

    $options['auto_start'] = false;

    // initialize the parent

    parent::initialize($options);

    if (!class_exists('Redis'))

    {

      throw new sfInitializationException('You must have redis installed.');

    }

    $this->redis = new Redis;

    // use this object as the session handler

    session_set_save_handler(

      array($this, 'sessionOpen'),

      array($this, 'sessionClose'),

      array($this, 'sessionRead'),

      array($this, 'sessionWrite'),

      array($this, 'sessionDestroy'),

      array($this, 'sessionGC')

    );

    if ($isAutoStart && !parent::$sessionStarted)

    {

      // start our session

      session_start();

      parent::$sessionStarted = true;

    }

  }

  /**

   * Closes a session.

   *

   * @return boolean true, if the session was closed, otherwise false

   */

  public function sessionClose()

  {

    // do nothing

    return true;

  }

  /**

   * Opens a session.

   *

   * @param  string $path  (ignored)

   * @param  string $name  (ignored)

   * @throws sfInitializationException If unable to connect to the redis server or select to redis database.

   *

   * @return boolean true, if the session was opened, otherwise an exception is thrown

   */

  public function sessionOpen($path = null, $name = null)

  {

    $options = array_merge($this->defaults, $this->options);

    $method = $options['persistent'] ? 'pconnect' : 'connect';

    $host = $options['host'];

    $port = (int) $options['port'];

    $database = (int) $options['database'];

    $timeout = (int) $options['timeout'];

    if (!$this->redis->$method($host, $port, $timeout))

    {

      throw new sfInitializationException(sprintf('Unable to connect to the redis server (%s:%s).', $host, $port));

    }

    if (!$this->redis->select($database))

    {

      throw new sfInitializationException(sprintf('Unable to select to the redis database (number:%d).', $database));

    }

    return true;

  }

  /**

   * Destroys a session.

   *

   * @param  string $id  A session ID

   *

   * @return bool true, if the session was destroyed, otherwise an exception is thrown

   */

  public function sessionDestroy($id)

  {

    return $this->redis->delete($id);

  }

  /**

   * Cleans up old sessions.

   *

   * @param  int $lifetime  The lifetime of a session

   *

   * @return bool true, if old sessions have been cleaned, otherwise an exception is thrown

   */

  public function sessionGC($lifetime)

  {

    // do nothing

    return true;

  }

  /**

   * Reads a session.

   *

   * @param  string $id  A session ID

   *

   * @return string The session data if the session was read or created

   */

  public function sessionRead($id)

  {

    return (string)$this->redis->get($id);

  }

  /**

   * Writes session data.

   *

   * @param  string $id    A session ID

   * @param  string $data  A serialized chunk of session data

   *

   * @return bool true, if the session was written, otherwise an exception is thrown

   */

  public function sessionWrite($id, $data)

  {

    if (!$id || !$data)

    {

      return false;

    }

    $lifetime = ini_get('session.gc_maxlifetime');

    return $this->redis->setex($id, (int) $lifetime, $data);

  }

  /**

   * Regenerates id that represents this storage.

   *

   * @param  boolean $destroy Destroy session when regenerating?

   */

  public function regenerate($destroy = true)

  {

    if (self::$sessionIdRegenerated)

    {

      return false;

    }

    $currentId = session_id();

    parent::regenerate($destroy);

    $newId = session_id();

    $this->sessionRead($newId);

    return $this->sessionWrite($newId, $this->sessionRead($currentId));

  }

  /**

   * Executes the shutdown procedure.

   */

  public function shutdown()

  {

    parent::shutdown();

  }

}