RedisSessionHandler

Protocols/Http/Session/FileSessionHandler.php

@@ -55,11 +55,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Nothing.
-     *
-     * @param string $save_path
-     * @param string $name
-     * @return bool
+     * {@inheritdoc}
      */
     public function open($save_path, $name)
     {
@@ -67,10 +63,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Reads the session data from the session storage.
-     *
-     * @param string $session_id
-     * @return string
+     * {@inheritdoc}
      */
     public function read($session_id)
     {
@@ -84,11 +77,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Writes the session data to the session storage.
-     *
-     * @param string $session_id
-     * @param string $session_data
-     * @return bool
+     * {@inheritdoc}
      */
     public function write($session_id, $session_data)
     {
@@ -100,9 +89,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Nothing.
-     *
-     * @return bool
+     * {@inheritdoc}
      */
     public function close()
     {
@@ -110,10 +97,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Destroys a session.
-     *
-     * @param string $session_id
-     * @return bool
+     * {@inheritdoc}
      */
     public function destroy($session_id)
     {
@@ -125,10 +109,7 @@ class FileSessionHandler implements \SessionHandlerInterface
     }
 
     /**
-     * Cleanup old sessions.
-     *
-     * @param int $maxlifetime
-     * @return void
+     * {@inheritdoc}
      */
     public function gc($maxlifetime) {
         $time_now = \time();

Protocols/Http/Session/RedisSessionHandler.php

@@ -0,0 +1,119 @@
+<?php
+/**
+ * This file is part of workerman.
+ *
+ * Licensed under The MIT License
+ * For full copyright and license information, please see the MIT-LICENSE.txt
+ * Redistributions of files must retain the above copyright notice.
+ *
+ * @author    walkor<walkor@workerman.net>
+ * @copyright walkor<walkor@workerman.net>
+ * @link      http://www.workerman.net/
+ * @license   http://www.opensource.org/licenses/mit-license.php MIT License
+ */
+namespace Workerman\Protocols\Http\Session;
+
+/**
+ * Class RedisSessionHandler
+ * @package Workerman\Protocols\Http\Session
+ */
+class RedisSessionHandler extends \SessionHandler
+{
+
+    /**
+     * @var \Redis
+     */
+    protected $_redis;
+
+    /**
+     * @var int
+     */
+    protected $_maxLifeTime;
+
+    /**
+     * RedisSessionHandler constructor.
+     * @param $config = [
+     *  'host'     => '127.0.0.1',
+     *  'port'     => 6379,
+     *  'timeout'  => 2,
+     *  'auth'     => '******',
+     *  'database' => 2,
+     *  'prefix'   => 'redis_session_',
+     * ]
+     */
+    public function __construct($config)
+    {
+        if (false === extension_loaded('redis')) {
+            throw new \RuntimeException('Please install redis extension.');
+        }
+        $this->_maxLifeTime = (int)ini_get('session.gc_maxlifetime');
+
+        if (!isset($config['timeout'])) {
+            $config['timeout'] = 2;
+        }
+
+        $this->_redis = new \Redis();
+        if (false === $this->_redis->connect($config['host'], $config['port'], $config['timeout'])) {
+            throw new \RuntimeException("Redis connect {$config['host']}:{$config['port']} fail.");
+        }
+        if (!empty($config['auth'])) {
+            $this->_redis->auth($config['auth']);
+        }
+        if (!empty($config['database'])) {
+            $this->_redis->select($config['database']);
+        }
+        if (empty($config['prefix'])) {
+            $config['prefix'] = 'redis_session_';
+        }
+        $this->_redis->setOption(\Redis::OPT_PREFIX, $config['prefix']);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function open($save_path, $name)
+    {
+        return true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function read($session_id)
+    {
+        return $this->_redis->get($session_id);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function write($session_id, $session_data)
+    {
+        return true === $this->_redis->setex($session_id, $this->_maxLifeTime, $session_data);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function destroy($session_id)
+    {
+        $this->_redis->del($session_id);
+        return true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function close()
+    {
+        return true;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function gc($maxlifetime)
+    {
+        return true;
+    }
+}