zoukankan      html  css  js  c++  java
  • 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

  • 相关阅读:
    Html禁止粘贴 复制 剪切
    表单标签
    自构BeanHandler(用BeansUtils)
    spring配置中引入properties
    How Subcontracting Cockpit ME2ON creates SD delivery?
    cascadia code一款很好看的微软字体
    How condition value calculated in sap
    Code in SAP query
    SO Pricing not updated for partial billing items
    Javascript learning
  • 原文地址:https://www.cnblogs.com/phpshen/p/6306739.html
Copyright © 2011-2022 走看看