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

Subscription/release method

Method name Parameter Description Notes
pSubscribe $callback, $pattern, …$patterns Subscribe to one or more channels that match a given pattern. $callback is a callback function
pubSub $subCommand, …$arguments View subscription and release system status.
publish $channel, $message Send the message to the specified channel.
pUnSubscribe $pattern, …$patterns Unsubscribe from all channels in a given mode.
subscribe $callback, $channel, …$channels Subscribe to information for a given channel or channels.
unsubscribe $channel, …$channels Refers to unsubscribing to a given channel.
setSubscribeStop bool $subscribeStop Set whether to opt out of the subscription Call this command when your callback function wants to exit
isSubscribeStop View current subscription status

Instance

  2. defined("REDIS_HOST") ?: define('REDIS_HOST', '127.0.0.1');
  3. defined("REDIS_PORT") ?: define('REDIS_PORT', 6379);
  4. defined("REDIS_AUTH") ?: define('REDIS_AUTH', 'easyswoole');
  5. go(function () {
  6.     $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  7.         'host'      => '127.0.0.1',
  8.         'port'      => '6379',
  9.         'auth'      => 'easyswoole',
  10.         'serialize' => \EasySwoole\Redis\Config\RedisConfig::SERIALIZE_NONE
  11.     ]));;
  13.     //Open a new coroutine to subscribe
  14.     go(function () {
  15.         $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  16.             'host' => REDIS_HOST,
  17.             'port' => REDIS_PORT,
  18.             'auth' => REDIS_AUTH
  19.         ]));
  20.         $redis->pSubscribe(function (\EasySwoole\Redis\Redis $redis, $pattern, $str) {
  21.             var_dump($pattern,$str);
  22.             $data = $redis->unsubscribe('test');
  23.             var_dump($data);
  24.             $redis->setSubscribeStop(true);
  25.         }, 'test', 'test1', 'test2');
  26.     });
  28.     //Open a new coroutine to subscribe
  29.     go(function () {
  30.         $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  31.             'host' => REDIS_HOST,
  32.             'port' => REDIS_PORT,
  33.             'auth' => REDIS_AUTH
  34.         ]));
  35.         $redis->subscribe(function (\EasySwoole\Redis\Redis $redis, $pattern, $str) {
  36.             var_dump($pattern,$str);
  37.             $data = $redis->unsubscribe('test');
  38.             var_dump($data);
  39.             $redis->setSubscribeStop(true);
  40.         }, 'test', 'test1', 'test2');
  41.     });
  44.     $data = $redis->pubSub('CHANNELS');
  45.     var_dump($data);
  46.     \Swoole\Coroutine::sleep(1);
  48.     $data = $redis->publish('test2', 'test');
  49.     var_dump($data);
  51.     $data = $redis->pUnSubscribe('test');
  52.     var_dump($data);
  54. });