oblind

swoole 协程 redis 订阅

协程redis订阅

$svr->on('workerStart', function($svr, $wid) {

    $svr->after($wid * 50 + 50, function() {

        $redis = new Redis;

        $redis->connect('127.0.0.1', 6379);

        while(true) {

            $r = $redis->subscribe(['ch1', 'ch2']);

            $redis->setDefer(false);

            print_r($r);

        }

    });

});