php之redis短线重连案例讲解

 更新时间:2021-09-22 21:53:41   作者:佚名   我要评论(0)

php redis断线重连,pconnect连接失败问题
介绍
在swoole ,workerman等cli长连接模式下,遇到Redis异常断开,后面又开启的情况,一般得重新启

php redis断线重连,pconnect连接失败问题

介绍

在swoole ,workerman等cli长连接模式下,遇到Redis异常断开,后面又开启的情况,一般得重新启动程序才能正常使用,

本文介绍在不重启服务,实现原来的Redis断线重连

原理

Redis 断开的情况下调用

$Redis->ping()会触发Notice错误,Notice: Redis::ping(): send of 14 bytes failed with errno=10054

当获取redis实例时,如果ping不通或者出现异常,就重新连接

实现1

因为try catch  捕捉不到notice异常,所以ping不通直接重新连接,catch捕捉新连接的实例没有连接上,下次执行ping触发

Redis server went away 异常
    public static function getInstance( )
    {
        try {
            if (!self::$_instance) {
                new self();
            } else {
                if (!self::$_instance->ping())
                    new self();
            }
        } catch (\Exception $e) {
            // 断线重连
            new self();
        }
        return self::$_instance;
    }

实现2

1.调用ping之前先抛出个notice异常,

2.调用ping

3.用error_get_last获取最后一个错误,如果错误信息跟我们抛出的一样,说明ping通了,否则抛出个异常 ,让catch捕捉到执行重连,

当重连一次没连上再次调用$_instance->ping()会直接抛出Redis server went away异常让catch捕捉到

    public static function getInstance( )
    {
        if (!self::$_instance) {
            new self();
        }
        else{
            try {
                @trigger_error('flag', E_USER_NOTICE);
                self::$_instance->ping();
                $error = error_get_last();
                if($error['message'] != 'flag')
                    throw new \Exception('Redis server went away');
            } catch (\Exception $e) {
                // 断线重连
                new self();
            }
        }
        return self::$_instance;
    }

Redis类完整代码

<?php
 
 
namespace lib;
 
 
class Redis
{
 
    private static $_instance; //存储对象
    private function __construct( ){
        $config = Config::get('redis');
        self::$_instance = new \Redis();
        //从配置读取
        self::$_instance->pconnect($config['host'], $config['port']);
        if ('' != $config['password']) {
            self::$_instance->auth($config['password']);
        }
 
    }
 
 
 
 
    public static function getInstance( )
    {
        if (!self::$_instance) {
            new self();
        }
        else{
            try {
                @trigger_error('flag', E_USER_NOTICE);
                self::$_instance->ping();
                $error = error_get_last();
                if($error['message'] != 'flag')
                    throw new \Exception('Redis server went away');
            } catch (\Exception $e) {
                // 断线重连
                new self();
            }
        }
        return self::$_instance;
    }
 
//    public static function getInstance( )
//    {
//        try {
//            if (!self::$_instance) {
//                new self();
//            } else {
//                if (!self::$_instance->ping())
//                    new self();
//            }
//        } catch (\Exception $e) {
//            // 断线重连
//            new self();
//        }
//        return self::$_instance;
//    }
 
 
 
    /**
    * 禁止clone
    */
    private function __clone(){}
 
    /**
     * 其他方法自动调用
     * @param $method
     * @param $args
     * @return mixed
     */
    public function __call($method,$args)
    {
        return call_user_func_array([self::$_instance, $method], $args);
    }
 
    /**
     * 静态调用
     * @param $method
     * @param $args
     * @return mixed
     */
    public static function __callStatic($method,$args)
    {
        self::getInstance();
        return call_user_func_array([self::$_instance, $method], $args);
    }
 
 
 
}

调用

$this->handler = Redis::getInstance();
        $key    = $this->getCacheKey($name);
        $value = $this->handler->get($key);

补充

pconnect建立连接后重连失败问题

经测试长连接下使用pconnect建立连接后,redis超时被动断开了链接,

$res = self::$_instance->pconnect($config['host'], $config['port']); 

$res 会返回true,但不是新建的链接,调用$res-get()会报错

原因

研究发现

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

长连接中只有进程被停止,连接才会断开,所以连接断开时new不起作用,返回连接成功,而事实上已经断了,还是最早的那个连接,从而导致不能进行后续读取数据操作

所以长连接中请使用connect

到此这篇关于php之redis短线重连案例讲解的文章就介绍到这了,更多相关php之redis短线重连内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
  • 详解PHP解决守护进程Redis假死
  • thinkphp5redis缓存新增方法实例讲解
  • PHP使用Redis队列执行定时任务实例讲解
  • php基于redis的分布式锁实例详解
  • Thinkphp5+Redis实现商品秒杀代码实例讲解
  • PHP操作Redis常用命令的实例详解
  • php在linux环境中如何使用redis详解
  • php操作redis命令及代码实例大全

相关文章

  • php之redis短线重连案例讲解

    php之redis短线重连案例讲解

    php redis断线重连,pconnect连接失败问题 介绍 在swoole ,workerman等cli长连接模式下,遇到Redis异常断开,后面又开启的情况,一般得重新启
    2021-09-22
  • Laravel实现登录跳转功能

    Laravel实现登录跳转功能

    前言 登录跳转: 不同的用户在登录成功之后跳转到不同的网页当中 例如:网站管理员登录成功后跳转到网站后台,vip用户登录成功后跳转到vip
    2021-09-22
  • PHP格式化显示时间date()函数案例讲解

    PHP格式化显示时间date()函数案例讲解

    date("yyyyMMdd",time())&#160; date() 函数   功能:用于格式化时间,返回一个字符串。&#160; 语法:string date( string format [, i
    2021-09-22
  • php中重定向网页跳转方法总结案例教程

    php中重定向网页跳转方法总结案例教程

    PHP中重定向网页跳转页面的方法(共三种) 第一种:利用header()函数进行重定向,这也是我用的较多的。(注意!locationhe和“:”之间不能有
    2021-09-22
  • PHP之CI框架学习讲解

    PHP之CI框架学习讲解

    一、前言 CodeIgniter 是一个简单快速的PHP MVC框架。EllisLab 的工作人员发布了 CodeIgniter。CodeIgniter 是一套小巧但功能强大的、给 PHP
    2021-09-22
  • Elasticsearch属性单词常用解析说明

    Elasticsearch属性单词常用解析说明

    一、前言 &#160;&#160;&#160;&#160;&#160;&#160;说实话,刚测试ES的时候,我的内心是崩溃的,好多单词都不知道代表什么意思,只能一边测试,
    2021-09-22
  • PHP 修改SESSION的生存时间案例详解

    PHP 修改SESSION的生存时间案例详解

    需求背景: 用户希望他登录之后,浏览器就帮他记住登录状态,这样他就不用每次进入的时候,都需要登录一次。 session过期时间: 如果我们没有
    2021-09-22
  • HTTP中header头部信息详解

    HTTP中header头部信息详解

    HTTP Request的Header信息 1、HTTP请求方式 如下表: GET 向Web服务器请求一个文件
    2021-09-22
  • laravel多视图共享数据实例代码

    laravel多视图共享数据实例代码

    目录前言在视图间共享数据 视图Composer 添加 Composer 到多个视图 总结前言 在做项目中,网站前台或者后台有些数据需要在多个视图页面使
    2021-09-22
  • php fopen()函数案例详解

    php fopen()函数案例详解

    定义和用法 fopen() 函数打开文件或者 URL。 如果打开失败,本函数返回 FALSE。 语法 fopen(filename,mode,include_path,context)
    2021-09-22

最新评论