redis 使用案例

wlzxwfk

　　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 = ();　　

$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' => ()
　　
];
　　

　　
$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{(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 回调函数。 此回调函数接收当前会话>$_SESSION 中数据序列化之后的字符串作为参数。 序列化会话数据的过程由 PHP 根据 session.serialize_handler 设定值来完成。
　　序列化后的数据将和会话>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当需要新的会话>　　在使用该函数前，先把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 =  (

[

$this,'open'],

[

$this,'close'],

[

$this,'read'],

[

$this,'write'],

[

$this,'destroy'],

[

$this,'gc']　　);
();　　}
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(){();　　}
　　
}
　　

　　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