title: Redis coroutine client meta:

  • name: description content: Redis coroutine client,Implemented by swoole coroutine client,Covers the method of redis 99%
  • name: keywords content: swoole|swoole extension|swoole framework|EasySwoole redis| Swoole Redis coroutine client|swoole Redis|Redis coroutine

Redis Connection Pool Example

redis-pool component

The connection pool can be implemented by directly installing [redis-pool component] (../redisPool.md):

  1. composer require easyswoole/redis-pool

Install the easyswoole/pool component custom implementation:

  1. composer require easyswoole/pool

Add redisPool manager

Add file /App/Pool/RedisPool.php

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Tioncico
  5.  * Date: 2019/10/15 0015
  6.  * Time: 14:46
  7.  */
  9. namespace App\Pool;
  11. use EasySwoole\Pool\Config;
  12. use EasySwoole\Pool\AbstractPool;
  13. use EasySwoole\Redis\Config\RedisConfig;
  14. use EasySwoole\Redis\Redis;
  16. class RedisPool extends AbstractPool
  17. {
  18.     protected $redisConfig;
  20.     /**
  21.      * Override the constructor in order to pass in the redis configuration
  22.      * RedisPool constructor.
  23.      * @param Config      $conf
  24.      * @param RedisConfig $redisConfig
  25.      * @throws \EasySwoole\Pool\Exception\Exception
  26.      */
  27.     public function __construct(Config $conf,RedisConfig $redisConfig)
  28.     {
  29.         parent::__construct($conf);
  30.         $this->redisConfig = $redisConfig;
  31.     }
  33.     protected function createObject()
  34.     {
  35.         //New redis based on the incoming redis configuration
  36.         $redis = new Redis($this->redisConfig);
  37.         return $redis;
  38.     }
  39. }

Register to the Manager:

  1. $config = new \EasySwoole\Pool\Config();
  3. $redisConfig1 = new \EasySwoole\Redis\Config\RedisConfig(\EasySwoole\EasySwoole\Config::getInstance()->getConf('REDIS1'));
  5. $redisConfig2 = new \EasySwoole\Redis\Config\RedisConfig(\EasySwoole\EasySwoole\Config::getInstance()->getConf('REDIS2'));
  7. \EasySwoole\Pool\Manager::getInstance()->register(new \App\Pool\RedisPool($config,$redisConfig1),'redis1');
  9. \EasySwoole\Pool\Manager::getInstance()->register(new \App\Pool\RedisPool($config,$redisConfig2),'redis2');

Call (can be called globally in the controller):

  1. go(function (){
  3.     $redis1=\EasySwoole\Pool\Manager::getInstance()->get('redis1')->getObj();
  4.     $redis2=\EasySwoole\Pool\Manager::getInstance()->get('redis1')->getObj();
  6.     $redis1->set('name','Alan');
  7.     var_dump($redis1->get('name'));
  9.     $redis2->set('name','Allan');
  10.     var_dump($redis2->get('name'));
  12.     //Recycling object
  13.     \EasySwoole\Pool\Manager::getInstance()->get('redis1')->recycleObj($redis1);
  14.     \EasySwoole\Pool\Manager::getInstance()->get('redis2')->recycleObj($redis2);
  15. });

::: warning For detailed usage, see [pool universal connection pool] (../Pool/introduction.md) :::

::: warning This article redis connection pool is based on [pool universal connection pool] (../Pool/introduction.md) :::