本文主要是介绍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();
});演示结果如下：
每次添加10个消息，查看队列数量。消费一个消息，当添加到100消息的时候，后面添加的消息阻塞在队列之外，等待消费者消费消息在100以下，后面的消息才能入队。不然会一直阻塞等待在队列之外等待入队。
以上就是消息队列的简单例子，感觉用起来有点单一，难道整个服务器启动之后就只能创建以个数为名字的消息队列吗？我创建两个消息队列相互影响吗？ 还需要继续探究一下。
这篇关于swoole coroutine协程消息队列的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
