自定义进程实现redis订阅

实现代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Tioncico
  5.  * Date: 2018/10/18 0018
  6.  * Time: 10:28
  7.  */
  9. namespace App\Process;
  12. use EasySwoole\Component\Process\AbstractProcess;
  13. use Swoole\Process;
  15. class Subscribe extends AbstractProcess
  16. {
  17.     public function run($arg)
  18.     {
  19.         // TODO: Implement run() method.
  20.         $redis = new \Redis();//此处为伪代码，请自己建立连接或者维护
  21.         $redis->connect('127.0.0.1');
  22.         $redis->subscribe(['ch1'],function (){
  23.             var_dump(func_get_args());
  24.         });
  25.     }
  27.     public function onShutDown()
  28.     {
  29.         // TODO: Implement onShutDown() method.
  30.     }
  32.     public function onReceive(string $str, ...$args)
  33.     {
  34.         // TODO: Implement onReceive() method.
  35.     }
  37. }

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

  1. use App\Process;
  2. use EasySwoole\Core\Swoole\Process\ProcessManager;
  4. ServerManager::getInstance()->getSwooleServer()->addProcess((new Subscribe('sub'))->getProcess());