easyswoole - 基于swoole扩展实现的一款高性能php框架

自定義進(jìn)程實(shí)現(xiàn)redis訂閱

實(shí)現(xiàn)代碼

<?php
/**
 * Created by PhpStorm.
 * User: Tioncico
 * Date: 2018/10/18 0018
 * Time: 10:28
 */

namespace App\Process;

use EasySwoole\Component\Process\AbstractProcess;
use Swoole\Process;

class Subscribe extends AbstractProcess
{
    public function run($arg)
    {
        // TODO: Implement run() method.
        $redis = new \Redis();//此處為偽代碼，請(qǐng)自己建立連接或者維護(hù)
        $redis->connect('127.0.0.1');
        $redis->subscribe(['ch1'],function (){
            var_dump(func_get_args());
        });
    }

    public function onShutDown()
    {
        // TODO: Implement onShutDown() method.
    }

    public function onReceive(string $str, ...$args)
    {
        // TODO: Implement onReceive() method.
    }

}

接下來(lái)，需要做的事情，就是到EasySwooleEvent.php的主服務(wù)創(chuàng)建事件中，注冊(cè)該進(jìn)程即可。

use App\Process;
use EasySwoole\Core\Swoole\Process\ProcessManager;

\EasySwoole\Component\Process\Manager::getInstance()->addProcess(new Subscribe('sub'));