前言
会话是临时存储数据信息的一种机制。但是如果项目需要使用一些高复用的服务器架构(如下图)，就需要实现session数据同步或者统一存储，不然就有可能出现会话状态丢失的问题。所以如何共享Session信息就是一个需要解决的问题。下面本文讲述的是，如何使用Thinkphp搭配Redis存储Session信息(单应用服务器，单redis版本)，以达到Session共享的目的。
base lbs
环境
- 操作系统 Linux ubuntu 16.04
- PHP环境 PHP 7.0.28-0ubuntu0.16.04.1 ( NTS )
- redis版本 4.0.8
介绍
Redis是一个使用ANSI C编写的开源、支持网络、基于内存、可选持久性的键值对存储数据库。根据月度排行网站DB-Engines.com的数据显示，Redis是最流行的键值对存储数据库
安装Redis
源码包安装
根据redis官网的教程
1, Download, extract and compile Redis with:
wget http://download.redis.io/releases/redis-4.0.8.tar.gz
tar xzf redis-4.0.8.tar.gz
cd redis-4.0.8
make
2, The binaries that are now compiled are available in the src directory. Run Redis with:
src/redis-server
3, You can interact with Redis using the built-in client:
src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"
一切顺利的话，源码包Redis就安装完毕了。另外我们也可以使用Docker安装Redis。
Docker仓库安装
这里是Redis的仓库 ，提供了 Redis 3.x ~ 4.x 各个版本的镜像。
1, 查看docker-hub上的远程仓库
docker search redis
image
2, 执行下面命令，大意是首先docker会本地搜索docker images中理出来的镜像，如果没有则从docker hub(国内镜像)拉取redis的docker镜像，然后启动一个名为some-redis容器，-p是把本地的9736端口和容器中的6379端口映射起来，-d (daemon)并让容器运行在后台,--requirepass客户端链接需要认证。
docker run --name my-redis -p 9736:6379 -d redis --requirepass "11110000"
##查看docker已经启动的容器
docker ps
##安装redis客户端
sudo apt install reids-tools
##尝试从外部主机范围docker中的redis
redis-cli -h 127.0.0.1 -p 9736 -a 11110000
test-redis
Docker仓库安装的程序，拓展迁徙相对简单，和其他系统的耦合性很小。接下来我们安装拓展。
安装php-redis 拓展
拓展我们选择phpredis，这个比较通用，更新比较及时。github地址在这里
git clone https://github.com/phpredis/phpredis.git
##切换到phpredis所在的文件夹
phpize
./configure
make && make install
##重启php服务
systemctl restart php7.0-fpm.service
这时候就可以去phpinfo页面看到redis拓展已经成功出现了。
phpinfo-redis.png
这时候，我们就可以在php程序中操作redis数据库了。新建一个文件vim phpredis.php，内容如下。
<?php
if( !extension_loaded('redis')){
echo "not support redis";
exit();
}
$redis = new Redis();
$redis->connect('127.0.0.1',9736);
$redis->auth("11110000");
var_dump($redis->info());
##执行上面的测试文件，如果成功了，就出现类似下面的结果。
php phpredis.php
redis-out.png
到这，php-redis拓展已经安装成功，我们也可以在php程序总操作redis数据库了。接下来我们就在项目中使用redis存储session。
Redis存储Session
如果是使用原生的php来实现这个功能，就需要调整配置文件php.ini，配置phpredis使用文档编写代码。
session.save_handler = redis
session.save_path = "tcp://host1:6379?weight=1"
如果是使用php框架的话，一般框架已经集成了对应的模块操作驱动。我们可以到thinkphp官网找到Session的Redis存储驱动类。我们需要在相对应的位置(./ThinkPHP/Library/Think/Session/Driver/
)新建一个Redis.class.php文件，内容如下。
<?php
namespace Think\Session\Driver;
/**
* Redis Session驱动
*/
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('REDIS_HOST') ? C('REDIS_HOST') : '127.0.0.1',
'port' => C('REDIS_PORT') ? C('REDIS_PORT') : 6379,
'timeout' => C('REDIS_TIMEOUT') ? C('REDIS_TIMEOUT') : false,
'persistent' => C('REDIS_PERSISTENT') ? C('REDIS_PERSISTENT'):false,
'auth' => C('REDIS_AUTH') ? C('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);
}
}
} catch ( \Exception $e ) {
exit('Error:'.$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);
//延长有效期
$this->handler->expire($this->options['prefix']
.$sessID,C('SESSION_EXPIRE'));
return $this->get_result;
}
/**
+----------------------------------------------------------
* 写入Session
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $sessID
* @param String $sessData
+----------------------------------------------------------
*/
public function write($sessID, $sessData) {
if (!$sessData || $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;
}
/**
+----------------------------------------------------------
* 打开Session
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $savePath
* @param mixed $sessName
+----------------------------------------------------------
*/
public function execute() {
session_set_save_handler(
array(&$this, "open"),
array(&$this, "close"),
array(&$this, "read"),
array(&$this, "write"),
array(&$this, "destroy"),
array(&$this, "gc")
);
}
public function __destruct() {
if ($this->options['persistent'] == 'pconnect') {
$this->handler->close();
}
session_write_close();
}
}
接着在配置文件中配置如下配置项，不需要改动php.ini配置项了。
//SESSION 配置
'SESSION_AUTO_START' => true, //是否开启session
'SESSION_TYPE' => 'Redis', //session 驱动
'SESSION_PREFIX' => '', //session前缀
'SESSION_EXPIRE' => '7200', //session有效期(单位:秒) 0表示永久缓存。
//Redis 配置
'REDIS_HOST' =>'127.0.0.1', //redis服务器ip，多台用逗号隔开；
'REDIS_PORT' =>'9736',//端口号
'REDIS_TIMEOUT' =>'30',//超时时间(秒)
'REDIS_PERSISTENT' =>false,//是否长连接 false=短连接
'REDIS_AUTH' =>'11110000',//AUTH认证密码
其他层面的代码不需要改动，因为框架已经将Session类的操作方面封装起来了。业务存储Session时候，底层会根据配置项来实例化对应的存储驱动类。从而就实现了session存储在对应的redis数据库中了。
如无意外，至此，我们就完成了这次的小目标了。
结语
本文简单地实现了单机版的Redis存储php程序的Session数据。下一步，计划利用Docker技术搭建Redis基础的高可用分布式集群，就本文的基础上进行项目架构拓展。如有兴趣，敬请关注！
网友评论