自定义进程实现redis订阅

实现代码

  1. namespace App;
  4. use EasySwoole\Core\Swoole\Process\AbstractProcess;
  5. use Swoole\Process;
  7. class Subscribe extends AbstractProcess
  8. {
  10.     public function run(Process $process)
  11.     {
  12.         // TODO: Implement run() method.
  13.         $redis = new \Redis();
  14.         $redis->connect('127.0.0.1');
  15.         $redis->subscribe(['ch1'],function (){
  16.             var_dump(func_get_args());
  17.         });
  18.     }
  20.     public function onShutDown()
  21.     {
  22.         // TODO: Implement onShutDown() method.
  23.     }
  25.     public function onReceive(string $str, ...$args)
  26.     {
  27.         // TODO: Implement onReceive() method.
  28.     }
  29. }

接下来，需要做的事情，就是到EasySwooleEvent.php的主服务创建事件中，注册该进程即可。

  1. use App\Subscribe;
  2. use EasySwoole\Core\Swoole\Process\ProcessManager;
  4. ProcessManager::getInstance()->addProcess('sub',Subscribe::class);