Introduction to laravel5.2 and redis_cluster configuration-PHP Tutorial-php.cn

Abstract:In this part of the application of redis cluster in laravel, I would like to share the configuration of redis cluster in laravel5.2 (the official website also has an explanation of the configuration of redis cluster, but Version 5.2 is still a bit lacking. It only says to set the cluster configuration item to true, but this option alone cannot represent that a novice can directly use the redis cluster...

redis cluster in laravel Application

In this part, I would like to share the configuration of the redis cluster in laravel5.2 (the official website also has an explanation of the configuration of the redis cluster, but version 5.2 is still a bit lacking. It just says to set the cluster configuration item to true, but such an option alone cannot mean that a novice can directly use the redis cluster. This part also includes the predis client, so I will also share the source code analysis of predis later)

redis-cluster. Build: Easy Building Redis-cluster (Easy to build reids cluster)

System software list:

##laravel version:5.2
redis version:>=3.0 to download the latest version
predis:>=1.0 download address

Configuration file: config/database.php

&#39;redis&#39; => [    &#39;cluster&#39; => env(&#39;REDIS_CLUSTER&#39;, true),
    **&#39;options&#39;=>[&#39;cluster&#39;=>&#39;redis&#39;]**,  //官网没说这个,这是必须的！！后面会讲为什么这么配?
    &#39;default&#39; => [        &#39;host&#39; => env(&#39;REDIS_HOST&#39;, &#39;127.0.0.1&#39;), //任选一个master节点
        &#39;port&#39; => env(&#39;REDIS_PORT&#39;,6379),        &#39;database&#39; => 0,        &#39;timeout&#39;=>15,        &#39;read_write_timeout&#39;=>1800 //redis客户端连接以后的读写超时时间(默认是60s)
    ],    &#39;extra&#39;=>[                      
        &#39;host&#39;=>env(&#39;REDIS_EXTRA_HOST&#39;,&#39;127.0.0.1&#39;),  //任意一个集群中的节点即可
        &#39;port&#39;=>env(&#39;REDIS_EXTRA_PORT&#39;,7001)
    ]
 ]

Copy after login

ok, after completing the above steps, the redis cluster can be used.
There are many specific application scenarios for using redis clusters according to business needs, such as cluster storage sessions, etc.
app('request')->session()->put('key','value '); is saved in the cluster.

predis's underlying implementation of the redis cluster

ok, if you want to understand the parameters in the configuration file, you still have to look at the source The code, of course, is also predis, the above code.

Illuminate\Support\ServiceProvider\RedisServiceProvider；    public function register()
    {        $this->app->singleton(&#39;redis&#39;, function ($app) {            return new Database($app[&#39;config&#39;][&#39;database.redis&#39;]);
        });
    }
 

 Illuminate\Redis\Database;    
     public function __construct(array $servers = [])
     {
        $cluster = Arr::pull($servers, &#39;cluster&#39;);   //获取&#39;cluster&#39;的键值
       
        $options = (array) Arr::pull($servers, &#39;options&#39;);       //options 就是database.php中&#39;options&#39;的键值,是一个数组(但官网没有提到，是个坑.)
        if ($cluster) {  
            $this->clients = $this->createAggregateClient($servers, $options);   //集群模式&#39;cluster=true&#39;
        } else {       
             $this->clients = $this->createSingleClients($servers, $options);   //单机模式 &#39;cluster=false&#39;
        }
    }   protected function createAggregateClient(array $servers, array $options = [])
    {                
        return [&#39;default&#39; => new Client(array_values($servers), $options)];   //predis的Client类
    }
    


----------


注意：这里提醒一下各参数的值:
此时$servers=[
    [      &#39;host&#39; => env(&#39;REDIS_HOST&#39;, &#39;127.0.0.1&#39;),      &#39;port&#39; => env(&#39;REDIS_PORT&#39;,6379),      &#39;database&#39; => 0,      &#39;timeout&#39;=>15,      &#39;read_write_timeout&#39;=>1800
    ],
    [      &#39;host&#39;=>env(&#39;REDIS_EXTRA_HOST&#39;,&#39;127.0.0.1&#39;),      &#39;port&#39;=>env(&#39;REDIS_EXTRA_PORT&#39;,7001)
    ]
]
$options = [&#39;cluster&#39;=>&#39;redis&#39;]

其实到这儿，就可以解释在database.php中增加options选项，而且是必选项，因为底层代码需要判断数据切片的方式.
除了看源码，
predis的包文档也做了解释.https://packagist.org/packages/predis/predis-------

Copy after login

Next let’s take a look at these underlying classes to be initialized.

  Predis\Client;      public function __construct($parameters = null, $options = null)
    {        $this->options = $this->createOptions($options ?: array());        #$this->connection = $this->createConnection($parameters ?: array());
        #$this->profile = $this->options->profile;
    }    
    protected function createOptions($options)
    {        if (is_array($options)) {            return new Options($options);  //如你所见,实例化Options类
        }        if ($options instanceof OptionsInterface) {            return $options;
        }        throw new \InvalidArgumentException(&#39;Invalid type for client options.&#39;);
    }   
    public function __construct(array $options = array())
    {        $this->input = $options;        $this->options = array();        $this->handlers = $this->getHandlers();
    }

Copy after login

$this->connection = $this-> ;createConnection($parameters?: array())

Predis\Client 文件

    protected function createConnection($parameters)
    {
       # if ($parameters instanceof ConnectionInterface) {
       #     return $parameters;
       # }

       # if ($parameters instanceof ParametersInterface || is_string($parameters)) {
       #     return $this->options->connections->create($parameters);
       # }

       # if (is_array($parameters)) {
       #     if (!isset($parameters[0])) {
       #         return $this->options->connections->create($parameters);
       #     }            $options = $this->options;

       #     if ($options->defined(&#39;aggregate&#39;)) {
       #         $initializer = $this->getConnectionInitializerWrapper($options->aggregate);
       #         $connection = $initializer($parameters, $options);
       #     } else {
       #         if ($options->defined(&#39;replication&#39;) && $replication = $options->replication) {
       #             $connection = $replication;
       #         } else {                
                    $connection = $options->cluster; //
       #         }                $options->connections->aggregate($connection, $parameters);
       #     }

            return $connection;
       # }

       # if (is_callable($parameters)) {
       #     $initializer = $this->getConnectionInitializerWrapper($parameters);
       #     $connection = $initializer($this->options);

       #     return $connection;
       # }

       # throw new \InvalidArgumentException(&#39;Invalid type for connection parameters.&#39;);
    }
    
Predis\Configuration\Options;

    protected function getHandlers()
    {
        return array(            &#39;cluster&#39; => &#39;Predis\Configuration\ClusterOption&#39;,            &#39;connections&#39; => &#39;Predis\Configuration\ConnectionFactoryOption&#39;,
            #&#39;exceptions&#39; => &#39;Predis\Configuration\ExceptionsOption&#39;,
            #&#39;prefix&#39; => &#39;Predis\Configuration\PrefixOption&#39;,
            #&#39;profile&#39; => &#39;Predis\Configuration\ProfileOption&#39;,
            #&#39;replication&#39; => &#39;Predis\Configuration\ReplicationOption&#39;,
        );
    }

    public function __get($option)
    {
        #if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
        #    return $this->options[$option];
        #}         if (isset($this->input[$option]) || array_key_exists($option, $this->input)) {            $value = $this->input[$option];
            unset($this->input[$option]);

        #    if (is_object($value) && method_exists($value, &#39;__invoke&#39;){
        #        $value = $value($this, $option);
        #    }            if (isset($this->handlers[$option])) {                $handler = $this->handlers[$option];                $handler = new $handler(); //会实例化Predis\Configuration\ClusterOption类
                $value = $handler->filter($this, $value);
            }

            return $this->options[$option] = $value;
        }

       # if (isset($this->handlers[$option])) {
       #     return $this->options[$option] = $this->getDefault($option);
       # }

       # return;
    }
    
Predis\Configuration\ClusterOption文件

    public function filter(OptionsInterface $options, $value)
    {        if (is_string($value)) {            $value = $this->createByDescription($options, $value);
        }

       # if (!$value instanceof ClusterInterface) {
       #     throw new \InvalidArgumentException(
       #         "An instance of type &#39;Predis\Connection\Aggregate\ClusterInterface&#39; was expected."
       #     );
       # }

        return $value;
    }
       
       
        protected function createByDescription(OptionsInterface $options, $id)
    {
        switch ($id) {
         * Abstraction for a cluster of aggregate connections to various Redis servers
 * implementing client-side sharding based on pluggable distribution strategies.
          # case &#39;predis&#39;:
          # case &#39;predis-cluster&#39;:
          #      return new PredisCluster(); 
          //这个模式是客户端通过CRC16算法在客户端进行数据切片,
          显然这种模式的集群是脆弱的,如果一个master节点挂了，
          那其备节点若也挂了，那么获取数据就成问题了;
          再有这种模式扩展性很差,维护成本高,
          因此这个模式不推荐.当然用最新predis不存在这个问题.
          我这边predis,1.0算比较老了.

            case &#39;redis&#39;:
            case &#39;redis-cluster&#39;:
                return new RedisCluster($options->connections);            //这种模式是基于服务端的数据切片，相较于第一种模式，优点也显而易见,维护成本低,扩展性好等.
            default:
                return;
        }
    } 
    
        public function __get($option)
    {
        #if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
        #    return $this->options[$option];
        #}

        # if (isset($this->input[$option]) || array_key_exists($option, $this->input)) {
        #    $value = $this->input[$option];
        #    unset($this->input[$option]);

        #    if (is_object($value) && method_exists($value, &#39;__invoke&#39;){
        #        $value = $value($this, $option);
        #    }

        #    if (isset($this->handlers[$option])) {
        #       $handler = $this->handlers[$option];
        #        $handler = new $handler(); 
        #        $value = $handler->filter($this, $value);
        #    }

        #    return $this->options[$option] = $value;
        #}         if (isset($this->handlers[$option])) {  //$options=&#39;connections&#39;       
            return $this->options[$option] = $this->getDefault($option);
       # }

       # return;
    }  
    
    public function getDefault($option)
    {        if (isset($this->handlers[$option])) {            $handler = $this->handlers[$option]; //$handler = &#39;Predis\Configuration\ConnectionFactoryOption&#39;;
            $handler = new $handler();

            return $handler->getDefault($this);
        }
    }
    
 Predis\Configuration\ConnectionFactoryOption文件
    public function getDefault(OptionsInterface $options)
    {
        return new Factory(); //最后实例化了一个&#39;工厂&#39;类
    }

Copy after login

$this->profile = $this->options->profile;

Predis\Configuration\ProfileOption文件


        public function __get($option)
    {
        #if (isset($this->options[$option]) || array_key_exists($option, $this->options)) {
        #    return $this->options[$option];
        #}

        # if (isset($this->input[$option]) || array_key_exists($option, $this->input)) {
        #    $value = $this->input[$option];
        #    unset($this->input[$option]);

        #    if (is_object($value) && method_exists($value, &#39;__invoke&#39;){
        #        $value = $value($this, $option);
        #    }

        #    if (isset($this->handlers[$option])) {
        #       $handler = $this->handlers[$option];
        #        $handler = new $handler(); 
        #        $value = $handler->filter($this, $value);
        #    }

        #    return $this->options[$option] = $value;
        #}         if (isset($this->handlers[$option])) {  //$options=&#39;profile&#39;       
            return $this->options[$option] = $this->getDefault($option);
       # }

       # return;
    }  
    
        public function getDefault($option)
    {        if (isset($this->handlers[$option])) {            $handler = $this->handlers[$option]; //$handler = &#39;Predis\Configuration\ProfileOption&#39;;
            $handler = new $handler();

            return $handler->getDefault($this);
        }
    }
    
 Predis\Configuration\ProfileOption文件
     public function getDefault(OptionsInterface $options)
    {        $profile = Factory::getDefault(); //实例化了Predis\Profile\RedisVersion300类
        $this->setProcessors($options, $profile);

        return $profile;  
    }

Copy after login

The above is the detailed content of Introduction to laravel5.2 and redis_cluster configuration. For more information, please follow other related articles on the PHP Chinese website!