xyzshop/test/swool_pop.php

<?php

define('APP_ID', 'test');
define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_CORE_PATH . '/lrlz.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_ROOT_PATH . '/core/framework/function/http.php');

require_once(BASE_CORE_PATH . '/framework/function/http.php');
require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');

//Co::set(['hook_flags' => SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_TCP]);

go(function () {
    $redis = new Swoole\Coroutine\Redis();
    $ret = $redis->connect('192.168.1.220', 6379);

    while(true) {
        $data = $redis->brPop(["QUEUE_DISPATCHER_1","QUEUE_DISPATCHER_2","QUEUE_DISPATCHER_3"], 3);
        Log::record("Recv msg = {$data}",Log::DEBUG);
    }
});