redis-react

(要求Workerman版本>=3.3.6)

安装：

  1. composer require clue/redis-react

示例：

  1. <?php
  2. require_once __DIR__ . '/vendor/autoload.php';
  3. use Clue\React\Redis\Factory;
  4. use Clue\React\Redis\Client;
  5. use Workerman\Worker;
  7. $worker = new Worker('text://0.0.0.0:6161');
  9. // 进程启动时
  10. $worker->onWorkerStart = function() {
  11.     global $factory;
  12.     $loop    = Worker::getEventLoop();
  13.     $factory = new Factory($loop);
  14. };
  16. $worker->onMessage = function($connection, $data) {
  17.     global $factory;
  18.     $factory->createClient('localhost:6379')->then(function (Client $client) use ($connection) {
  19.         $client->set('greeting', 'Hello world');
  20.         $client->append('greeting', '!');
  22.         $client->get('greeting')->then(function ($greeting) use ($connection){
  23.             // Hello world!
  24.             echo $greeting . PHP_EOL;
  25.             $connection->send($greeting);
  26.         });
  28.         $client->incr('invocation')->then(function ($n) use ($connection){
  29.             echo 'This is invocation #' . $n . PHP_EOL;
  30.             $connection->send($n);
  31.         });
  32.     });
  33. };
  35. Worker::runAll();

文档：

https://github.com/clue/php-redis-react

注意：

1、所有的异步编码必须在onXXX回调中编写

2、异步客户端需要的$loop变量请使用Worker::getEventLoop();返回值