zoukankan      html  css  js  c++  java
  • PHP中使用Redis长连接笔记

     

    pconnect函数声明

    其中time_out表示客户端闲置多少秒后,就断开连接。函数连接成功返回true,失败返回false:

    pconnect(host, port, time_out, persistent_id, retry_interval)
            host: string. can be a host, or the path to a unix domain socket
            port: int, optional 
            timeout: float, value in seconds (optional, default is 0 meaning unlimited) 
            persistent_id: string. identity for the requested persistent connection 
            retry_interval: int, value in milliseconds (optional)     

    下面的例子详细介绍了pconnect连接的重用情况。

    $redis->pconnect(‘127.0.0.1′, 6379); 
    $redis->pconnect(‘127.0.0.1′); // 默认端口6379,跟上面的例子使用相同的连接。 
    $redis->pconnect(‘127.0.0.1′, 6379, 2.5); // 设置了2.5秒的过期时间。将是不同于上面的新连接 
    $redis->pconnect(‘127.0.0.1′, 6379, 2.5, ‘x’); //设置了持久连接的id,将是不同于上面的新连接
    $redis->pconnect(‘/tmp/redis.sock’); // unix domain socket – would be another connection than the four before.

    pconnect使用介绍

    pconnect方法简单描述

    使用该方法创建连接,连接不会在调用close方法之后关闭,只有在进程结束之后该连接才会被关闭。

    [待验证]如果使用的是长连接,Redis配置文件中的timeout配置项需要设置为0,否则连接池中的连接会因为超时而失效

    针对PHP-FPM来说明一下pconnect

    长连接只会在PHP-FPM进程结束之后结束,连接的生命周期就是PHP-FPM进程的生命周期。

    相比较短连接而言,在每一个PHP-FPM调用过程中都会产生一个redis的连接,在服务器上的表性形式就是过多的time_out连接状态。

    而长连接相反,PHP-FPM调用的所有CGI都只会共用一个长连接,所以也就是只会产生固定数量的time_out。

    如果代码中使用pconnect, close的作用仅是使当前php不能再进行redis请求,但无法真正关闭redis长连接,连接在后续请求中仍然会被重用,直至fpm进程生命周期结束。

    关闭长连接

    可以调用close和unset方法,但两则差异很大:

    - close的作用仅仅是使当前PHP进程不能再进行redis请求,但无法真正关闭redis长连接,连接在后续请求中仍然会被重用,直FPM进程生命周期结束。所以close 并不会销毁redis对象,只是断开连接而已。 
    - unset/赋值null 变量才会销毁。也需要注意并不是使用了 pconnect 就不要 close 了,如果当前脚本执行时间很长 那么也会一直占用一个连接的。

    何判断当前Redis是否处于连接状态

    等效的问题是,在单例模式中,判断当前实例是否有效。
    习惯上调用echo,判断是否正常返回字符串本身,或者调用ping,查看返回值是否为 +PONG。 但是需要特别小心的是,在redis断开连接之后,调用echo以及ping(返回’+POMG’)时,均会抛出异常。所以要通过异常捕获机制来处理。


    代码分析pconnect连接重用的问题

    况一:非单例模式。

    说明:a和b实例共用了一条连接,b将a实例的连接修改了: 
    所以下面的例子导致最终$a实例得到的值变成了2,需要特别注意。

    $a = pconnect(host, port, time_out);
    select(3);
    $a -> setex(id, 3);
    echo $a -> get(id);
    
    //之后执行下面的连接
    $b = pconnect(host, port, time_out);
    select(2);
    $b->set(id,2) 
    echo $a->get(id);    //这个id操作的db变成了2,不再是之前的3了。因为这两个连接共用了一个连接通道。

    况二:单例模式。

    将上述的代码修改,a和b都通过getInstance来生成。生成的前提是判断当前实例是否存在。单例模式的混淆点在于:

    $a生成了一个实例,这时候生成$b, $b使用了$a的实例,然后修改了$a的连接,之后调用$a肯定是调用的$b修改之后的实例。跟情况二一致。
    单例模式的代码如下:
    
    public static function getInstance($db = 0)
    {
        if (!isset(self::$_instance)) {
            self::$_instance = new Redis();
        }
        self::_connect();
        self::$_instance->select($db);
        return self::$_instance;
    }

    两种情况都说明了连接重用的问题。如何修复这个bug?两点:

    1.为每一个db生成一个单例。 
    2.避免连接重用问题。
    

    所以代码可以做调整为返回一个单例数组:

    public static function getInstance($db = 0)
    {
        try{
            if (isset(self::$_instance[$db]) && self::$_instance[$db]->Ping() == 'Pong') {
                return self::$_instance[$db];
            }   
        } catch (Exception $e) {
    
        }
    
        self::$_instance[$db] = new Redis();
        self::_connect($db);
        return self::$_instance[$db];
    }

    需要注意的地方

    避免在Task类成员变量中使用redis对象。

    在redis的单例模式中,声明了time_out的过期时间。如果redis处理的场合是一个任务,而任务调用redis间隔时间又比较长。当间隔大于time_out时候,redis就会断开连接,这时候所有对redis的操作都会失效。解决的办法就是避免这种调用方式,通过在调用的地方动态声明redis类来执行。这种问题对于长连接和短链接是没有区分,属于调用的方式错误。

  • 相关阅读:
    DataTable的一些使用技巧
    Linux下使用Mysql
    【Cocos2d-X开发学习笔记】第28期:游戏中音乐和音效的使用
    HDU 4669 Mutiples on a circle (DP , 统计)
    面试经典-设计包含min函数的栈
    最大熵模型
    这篇文章关于两阶段提交和Paxos讲的很好
    【读书笔记】神经网络与深度学习
    这个对协程的分析不错
    sendfile学习
  • 原文地址:https://www.cnblogs.com/sunsky303/p/9956491.html
Copyright © 2011-2022 走看看