swoole coroutine协程消息队列

本文主要是介绍swoole coroutine协程消息队列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

首先测试一个消息队列的例子：

use Swoole\Coroutine as co;$channel = new co\Channel(100);co::create(function() use($channel){for($i = 0; $i < 20; $i++) {co::sleep(1.0);$channel->push(['key'=>$i,'value'=>rand(111111,999999)]); //数组echo "$i\n";}
});var_dump($channel->length());swoole_event::wait()

演示结果：

可以看到，程序先返回的是消息队列的数量，我看官方这个例子下面有人提问说为什么队列数量一直是0，看到这个显示结果应该明白了，程序是执行到协程代码的地方直接返回结果，然后在执行协程里面的代码，就如上图所示。那怎么能查询到当前内存中消息队列的数量呢，我想有两种方法，一种在添加消息队列过后直接查询数量，第二种在服务器中使用消息队列，服务器没有关闭之前，只要消息队列里面的消息没有被消费，就可以查询到消息队列的数量和状态。估计要使用协程服务器才可以。

第一种代码很简单，在echo "$i\n"; 的后面加上 var_dump($channel->length()); 插入一条，显示一下消息队列的数量。下面是第二种方法：

use Swoole\Coroutine as co;$channel = new co\Channel(100);go(function () use($channel){$server = new Co\Http\Server("127.0.0.1", 8888, false);$server->handle('/', function ($request, $response) use($channel,$server){if(strpos($request->server['request_uri'],'.ico') !== false){$response->end("");}else{echo "开始创建消息队列，推入10个消息".PHP_EOL;co::create(function() use($channel){for($i = 0; $i < 10; $i++) {$channel->push(['key'=>$i,'value'=>rand(111111,999999)]); //数组}});$response->header("Content-Type","text/html; charset=UTF-8");$response->end("<h1>创建了".$channel->length()."消息</h1>");}});$server->handle('/test', function ($request, $response) use($channel,$server){if(strpos($request->server['request_uri'],'.ico') !== false){$response->end("");}else{echo "查看消息队列".PHP_EOL;;$response->header("Content-Type","text/html; charset=UTF-8");$response->end("<h1>查看消息的个数:".$channel->length()."</h1>");}});$server->handle('/stop', function ($request, $response) use ($channel,$server) {if(strpos($request->server['request_uri'],'.ico') !== false){$response->end("");}else{$response->header("Content-Type","text/html; charset=UTF-8");$response->end("<h1>消费一个消息：".json_encode($channel->pop())."</h1>");//$server->shutdown();}});$server->start();
});

演示结果如下：