swoole下go协程配合redis队列

国内高佣广告联盟 熊掌联运广告联盟 最新域名优惠/VPS优惠/免备案CDN活动
$n = 10;
$redis = new \Redis();
$redis->connect(env('REDIS_HOST'),env('REDIS_PORT'));
$redis->auth(env('REDIS_PASSWORD'));
$redis->select(env('REDIS_DB'));
for ($i = 0; $i < $n; $i++) {
	go(function () use($redis){
		$re = $redis->lpop('xxxxxxxx');
		if(!$re){
			return false;
		}
		$arr = json_decode($re,true);
		if(is_array($arr) && !empty($arr)){
			//do  something
		}
	});
}