网站首页 文章专栏 thinkphp中session存放在redis中类的配置

thinkphp中session存放在redis中类的配置

编辑时间:2018-05-11 14:54:11 作者:苹果 浏览量:474







<?php


/**

 *  +----------------------------------------------------------------------

 *  | ThinkPHP [ WE CAN DO IT JUST THINK IT ]

 *  +----------------------------------------------------------------------

 *  | Copyright (c) 2006-2013 http://thinkphp.cn All rights reserved.

 *  +----------------------------------------------------------------------

 *  | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )

 *  +----------------------------------------------------------------------

 *  | @author guizhiming <sd2536888@163.com>

 *  +----------------------------------------------------------------------

 *  | @datetime 2014-4-1 14:11:24

 *  +----------------------------------------------------------------------

 */


namespace Think\Session\Driver;


/**

 * Redis Session驱动

 * 要求安装phpredis扩展:https://github.com/nicolasff/phpredis

 * @category   Think

 * @package  Session

 * @subpackage  Driver

 * @author guizhiming <sd2536888@163.com>

 * @version   TP3.2~TP3.2.1

+------------------------------------------------------------------------------

 */

class Redis {


/**

* Redis句柄

*/

private $handler;

private $get_result;


public function __construct() {

if (!extension_loaded('redis')) {

E(L('_NOT_SUPPERT_') . ':redis');

}

if (empty($options)) {

$options = array(

'host' => C('SESSION_REDIS_HOST') ? C('SESSION_REDIS_HOST') : '127.0.0.1',

'port' => C('SESSION_REDIS_PORT') ? C('SESSION_REDIS_PORT') : 6379,

'timeout' => C('SESSION_CACHE_TIME') ? C('SESSION_CACHE_TIME') : false,

'persistent' => C('SESSION_PERSISTENT') ? C('SESSION_PERSISTENT') : false,

'auth' => C('SESSION_REDIS_AUTH') ? C('SESSION_REDIS_AUTH') : false,

);

}

$options['host'] = explode(',', $options['host']);

$options['port'] = explode(',', $options['port']);

$options['auth'] = explode(',', $options['auth']);

foreach ($options['host'] as $key => $value) {

if (!isset($options['port'][$key])) {

$options['port'][$key] = $options['port'][0];

}

if (!isset($options['auth'][$key])) {

$options['auth'][$key] = $options['auth'][0];

}

}

$this->options = $options;

$expire = C('SESSION_EXPIRE');

$this->options['expire'] = isset($expire) ? (int) $expire : (int) ini_get('session.gc_maxlifetime');

$this->options['prefix'] = isset($options['prefix']) ? $options['prefix'] : C('SESSION_PREFIX');

$this->handler = new \Redis;

}


/**

* 连接Redis服务端

* @access public

* @param bool $is_master : 是否连接主服务器

*/

public function connect($is_master = true) {

if ($is_master) {

$i = 0;

} else {

$count = count($this->options['host']);

if ($count == 1) {

$i = 0;

} else {

$i = rand(1, $count - 1); //多个从服务器随机选择

}

}

$func = $this->options['persistent'] ? 'pconnect' : 'connect';

try {

if ($this->options['timeout'] === false) {

$result = $this->handler->$func($this->options['host'][$i], $this->options['port'][$i]);

if (!$result) {

throw new \Think\Exception('Redis Error', 100);

}


} else {

$result = $this->handler->$func($this->options['host'][$i], $this->options['port'][$i], $this->options['timeout']);

if (!$result) {

throw new \Think\Exception('Redis Error', 101);

}


}

if ($this->options['auth'][$i]) {

$result = $this->handler->auth($this->options['auth'][$i]);

if (!$result) {

throw new \Think\Exception('Redis Error', 102);

}

}

if (intval(C("SESSION_REDIS_DB_NUM"))) {

$this->handler->select(C("SESSION_REDIS_DB_NUM"));

} else {

$this->handler->select(12);

}

} catch (\Exception $e) {

exit('Error Message:' . $e->getMessage() . '<br>Error Code:' . $e->getCode() . '');

}

}


/**

+----------------------------------------------------------

* 打开Session

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

* @param string $savePath

* @param mixed $sessName

+----------------------------------------------------------

*/

public function open($savePath, $sessName) {

return true;

}


/**

+----------------------------------------------------------

* 关闭Session

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

*/

public function close() {

if ($this->options['persistent'] == 'pconnect') {

$this->handler->close();

}

return true;

}


/**

+----------------------------------------------------------

* 读取Session

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

* @param string $sessID

+----------------------------------------------------------

*/

public function read($sessID) {

$this->connect(0);

$this->get_result = $this->handler->get($this->options['prefix'] . $sessID);

return $this->get_result;

}


/**

+----------------------------------------------------------

* 写入Session

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

* @param string $sessID

* @param String $sessData

+----------------------------------------------------------

*/

public function write($sessID, $sessData) {

if ($sessData == $this->get_result) {

return true;

}

$this->connect(1);

$expire = $this->options['expire'];

$sessID = $this->options['prefix'] . $sessID;

if (is_int($expire) && $expire > 0) {

$result = $this->handler->setex($sessID, $expire, $sessData);

$re = $result ? 'true' : 'false';

} else {

$result = $this->handler->set($sessID, $sessData);

$re = $result ? 'true' : 'false';

}

return $result;

}


/**

+----------------------------------------------------------

* 删除Session

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

* @param string $sessID

+----------------------------------------------------------

*/

public function destroy($sessID) {

$this->connect(1);

return $this->handler->delete($this->options['prefix'] . $sessID);

}


/**

+----------------------------------------------------------

* Session 垃圾回收

+----------------------------------------------------------

* @access public

+----------------------------------------------------------

* @param string $sessMaxLifeTime

+----------------------------------------------------------

*/

public function gc($sessMaxLifeTime) {

return true;

}


}



    出自:何冰华个人网站

    地址:http://www.hebinghua.com/

    转载请注明出处


来说两句吧
最新评论