redis 使用案例

1.使用redis消息列队发布信息

在一些用户创造用户的应用中（如SNS,微博），可能出现1秒有上千万个用户同时发布消息的情况，此时如果使用mysql可能出现‘too many connections’ 错误，当然，把mysql的max_connections 参数设置为更大数，不过这是一个治标不治本的方法，这是可以考虑使用redis。

使用redis的list类型作为消息列队，把用户发布的消息暂时存储在消息列队中，接着使用一个cron程序把消息列队中的消息插入mysql，这样有效率降低mysql的并发量。

例如发布一条微博使用一下接口：

<?php
$uid = get_uid();
$content = get_content();

$timestamp = time();
$weibo = new weibo();
$weibo->pot($uid,$contnet,$timestamp);
?>

weibo对象的post方法就是发布微博的接口，它直接把微博写入mysql。参数$uid是用户的UID，$content是微博的内容，$timestamp是发布的时间戳。

为了降低mysql的并发数，先把用户发布的微博存在redis中，代码如下：

<?php
$redis = new redis('127.0.0.1',6379);
$redis -> connect();
$weibo_info = [
'uid' => get_uid(),
'content' => get_cntent(),
'timestamp' => time()
];

$redis->lpush('weibo_list',json_encode($weibo_info));
$redis -> close();
?>

 先把微博信息使用json_encode编码成JSON格式。然后使用redis对象的lpush方法把微博信息插入到weibo_list列队。

把微博存到redis以后，编写一个cron程序吧redis中的微博信息插入到mysql中代码如下：

<?php
$redis = new redis('127.0.0.1',6379);
$redis->connect();
$weibo = new weibo();
while(true){
    if($redis->lsize('weibo_list') > 0){
         $info = $redis->rpop('weibo_list');
        $info = json_decode($info);
       $weibo -> post($info->uid,$info->content,$info->timestamp);
    }else{
       sleep(1);
    }

}
$redis ->close();
?>        

在cron程序中，先使用redis对象的rpop()方法从weibo_list列表中取得一条微博信息，然后使用json_decode ()函数解码，最后调用weibo对象的post方法把微博信息插入mysql。

使用消息列队有一个缺点，就是‘延时’。为了把延时降低，运行多个cron程序同时把消息列队中的数据插入mysql。使用消息列队的好处是扩展性好，当一台redis服务器不能应付大量并发时，使用‘一致性Hash算法’把并发分发到redis服务器。

2.使用redis代替文件存储session

PHP默认使用文件存储session，如果并发量大，效率非常低。而redis对高并发的支持非常好，所以，可以使用redis替代文件存储session。

在讲解实例之前，先了解php的session_set_save_handler函数的作用和使用方法。该函数定义设置用户自定义会话存储函数（如打开、关闭、写入等）。原型如下：

bool session_set_save_handler(callback open,callback close,callback read,callback write,callback destroy,callback gc，callable create_sid)

sesson_set_save_handler 函数各参数作用如下：

open 回调函数类似于类的构造函数， 在会话打开的时候会被调用。 这是自动开始会话或者通过调用 session_start() 手动开始会话 之后第一个被调用的回调函数。 此回调函数操作成功返回 TRUE，反之返回 FALSE。

close 回调函数类似于类的析构函数。 在 write 回调函数调用之后调用。 当调用 session_write_close() 函数之后，也会调用 close 回调函数。 此回调函数操作成功返回 TRUE，反之返回 FALSE。

read 如果会话中有数据，read 回调函数必须返回将会话数据编码（序列化）后的字符串。 如果会话中没有数据，read 回调函数返回空字符串。

在自动开始会话或者通过调用 session_start() 函数手动开始会话之后，PHP 内部调用 read 回调函数来获取会话数据。 在调用 read 之前，PHP 会调用 open 回调函数。

read 回调返回的序列化之后的字符串格式必须与 write 回调函数保存数据时的格式完全一致。 PHP 会自动反序列化返回的字符串并填充 $_SESSION 超级全局变量。 虽然数据看起来和 serialize() 函数很相似， 但是需要提醒的是，它们是不同的。 请参考： session.serialize_handler。

write在会话保存数据时会调用 write 回调函数。 此回调函数接收当前会话 ID 以及 $_SESSION 中数据序列化之后的字符串作为参数。 序列化会话数据的过程由 PHP 根据 session.serialize_handler 设定值来完成。

序列化后的数据将和会话 ID 关联在一起进行保存。 当调用 read 回调函数获取数据时，所返回的数据必须要和 传入 write 回调函数的数据完全保持一致。

PHP 会在脚本执行完毕或调用 session_write_close() 函数之后调用此回调函数。 注意，在调用完此回调函数之后，PHP 内部会调用 close回调函数。

destroy当调用 session_destroy() 函数， 或者调用 session_regenerate_id() 函数并且设置 destroy 参数为 TRUE 时， 会调用此回调函数。此回调函数操作成功返回 TRUE，反之返回 FALSE。

gc为了清理会话中的旧数据，PHP 会不时的调用垃圾收集回调函数。 调用周期由 session.gc_probability 和 session.gc_divisor 参数控制。 传入到此回调函数的 lifetime 参数由 session.gc_maxlifetime 设置。 此回调函数操作成功返回 TRUE，反之返回 FALSE。

create_sid当需要新的会话 ID 时被调用的回调函数。 回调函数被调用时无传入参数， 其返回值应该是一个字符串格式的、有效的会话 ID。

在使用该函数前，先把php.ini配置文件的session.save_handler选项设置为user，否则session_set_save_handler 不会生效。

编写一个session管理sessionManager，代码如下：

<?php
class SessionManager{
    private $redis;
    private $sessionSavePath;
    private $sessionName;
    private $sessionExpireTime = 30;
    public function __construct(){
        $this->redis = new redis();
        $this->redis->connect('127.0.0.1',6379);
        $retval = session_set_save_handler (
        [$this,'open'],
        [$this,'close'],
        [$this,'read'],
        [$this,'write'],
        [$this,'destroy'],
        [$this,'gc']
        );
        session_start();
        
    }
    public function open($path,$name){
        return true;
    }
    public function close(){
        return true;
    }
    public function read($id){
        $value = $this->redis->get($id);
        if($value){
            return $value;
        }else{
            return '';
        }
    }
    public function write($id,$data){
        if($this->redis->set($id,$data)){
            $this->redis->expire($id,$this->sessionExpireTime);
            return true;
        }
        return false;
    }
    public function destroy($id){
        if($this->redis->delete($id)){
            return false;
        }
        return false;
    }
    public function gc($maxlifetime){
        return true;
    }
    
    public function __destruct(){
        session_write_close();
    }
    
}

 

SessionManager构造函数主要用来连接redis服务器，使用session_set_save_handler函数设置session函数回调，并调用session_start函数开始session功能。因为本例中open、close和gc回调的作用不大，所以直接返回true。

在write回调函数中，以SessionID作为key，把session的数据作为value存储到redis服务器，设置session的过期时间为30秒。在read回调函数中，以SessionID作为key从redis服务器中读取数据，并返回数据。而在destroy回调函数中，则以sessionID 作为key从redis服务器中删除对应的session数据。

使用时只需要包含SessionManager类，然后实例化一个SessionManager对象。下面例子使用SessionManager来管理session，首先创建一个session_set.php，输入代码如下：

include('SessionManager.php');
new SessionManager();
$_SESSION['username'] = 'newsession';

然后再建立一个sesion_get.php 文件代码如下：

include('SessionManager.php');
new SessionManager();
echo $_SESSION['username'];

测试时先访问 session_set.php 然后再访问 session_get.php