How predis implements the pconnect method of phpredis

This article mainly introduces how predis implements the pconnect method of phpredis. It has a certain reference value. Now I share it with you. Friends in need can refer to it

predis and phpredis are both PHP clients of redis. You can read the difference here and will not go into details here.

phpredis is a PHP extension, written in C language. It was born earlier and many PHPers are familiar with it.
Predis is written in PHP language. Due to the popularity of composer in recent years and the support of composer by many frameworks, predis stored in the composer library has also been widely used.

pconnect() is a method in phpredis. It is different from connect(). For detailed information, you can read this article. To summarize, the connection after the pconnect method is established is not closed with the end of the request, but depends on php-fpm process, php-fpm process does not die, redis connect will always exist until the idle timeout automatically disconnects. That is, a persistent connection is established, which is suitable for PHP requesting Redis under high concurrency.

But predis does not have a pconnect() method, how to implement similar functions?
The project uses the Laravel framework, but the relevant configuration parameters are not found in the document. So I could only read the plug-in source code, and finally found a method to connect to redis in the class /src/Connection/StreamConnection.php:

    /**
     * Initializes a TCP stream resource.
     *
     * @param ParametersInterface $parameters Initialization parameters for the connection.
     *
     * @return resource
     */
    protected function tcpStreamInitializer(ParametersInterface $parameters)
    {
        if (!filter_var($parameters->host, FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {            
        $address = "tcp://$parameters->host:$parameters->port";
        } else {            
        $address = "tcp://[$parameters->host]:$parameters->port";
        }        
        $flags = STREAM_CLIENT_CONNECT;        
        if (isset($parameters->async_connect) && $parameters->async_connect) {            
        $flags |= STREAM_CLIENT_ASYNC_CONNECT;
        }        
        if (isset($parameters->persistent)) {            
        if (false !== $persistent = filter_var($parameters->persistent, FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE))
         {                
        $flags |= STREAM_CLIENT_PERSISTENT;                
        if ($persistent === null) {                    
        $address = "{$address}/{$parameters->persistent}";
                }
            }
        }        $resource = $this->createStreamSocket($parameters, $address, $flags);        
        return $resource;
    }

on line 19 $parameters->persistentWe can see an unfamiliar parameterpersistent, translated as 'persistent'. So as long as when using predis to connect to redis, add the parameter persistent and assign it to a true or 1, you can implement pconnect() of phpredis, which is simple and convenient.

The following is email evidence, indicating that there is no misunderstanding of the source code:

Can the predis support the function pconnect() which in php-redis?
Yes, just add in the connection parameters persistent=1 (when using URI strings) or persistent => true (when using a named array).

How did you step into this pit? Or because of the framework documentation, many PHP frameworks currently support composer, such as Laravel, Yii, CI, etc., but there is no guarantee that the documentation will be updated in time, especially the Chinese documentation, so you still need the ability to read the source code.

In fact, you can see a lot from the code above:

1. predis uses tcp to connect to redis, and the main function used is stream_socket_client (Predis also has an http way to connect to redis, mainly using curl, which is not in this class).

2. predis does not depend on phpredis. Many project environments install phpredis and predis in the framework, thinking that the latter depends on the former, which is wrong.

3. In line 16 of the above code, you can also see another parameter async_connect, which is used for asynchronous connection. It is also very important, but it is not introduced in many documents.

Source:https://blog.csdn.net/u013474436/article/details/53131662

Related recommendations:

php-redis extension installation (phpredis)

The above is the detailed content of How predis implements the pconnect method of phpredis. For more information, please follow other related articles on the PHP Chinese website!