浅谈Swoole并发编程的魅力

场景介绍

假设我们要做一个石头剪刀布的Web游戏，3个玩家同时提交竞猜后显示胜者。在传统串行化Web编程中，我们一般思路是这样：

设置form表单，用户提交竞猜后保存到MySQL/Redis存储
添加一个查看结果按钮，如果未全部完成，显示正在等待其他人提交。当3个人全部提交时，查询存储，并显示最终结果

并发编程

这个场景就可以使用Swoole实现并发编程，无需依赖MySQL/Redis存储，在内存中可以完成竞猜。

当有用户提交竞猜时，hold住请求，不返回结果，用户进入等待状态。当前请求和连接保持在内存中

当3个人全部提交时，从内存中取出相关请求的内容，计算并遍历向所有请求发送响应

编码实现

<?php
$server = new Swoole\\Http\\Server(\'127.0.0.1\', 9501, SWOOLE_BASE);
$result = [];
$server->on(\'request\', function ($req, $resp) use(&$result) {
$resp->header(\'Content-Type\', \'text/html; charset=UTF-8\');
if ($req->server[\'request_method\'] == \'GET\') {
$resp->end(\'
<meta http-equiv=\"Content-Type\" content=\"text/html; charset=UTF-8\" />
<form method=\"post\" action=\"\">
<input type=\"radio\" value=\"石头\" name=\"result\">石头
<input type=\"radio\" value=\"剪刀\" name=\"result\">剪刀
<input type=\"radio\" value=\"布\" name=\"result\">布
<button type=\"submit\">提交</button>
</form>
\');
} else {
$result[$req->get[\'name\']] = [$req, $resp];
if (count( $result) == 3) {
$out = \'\';
foreach($result as $arr) {
[$_req, $_resp] = $arr;
$out .= $_req->get[\'name\'] .\" : \". $_req->post[\'result\'].\"<br />\\n\";
}
foreach($result as $arr) {
[$_req, $_resp] = $arr;
$_resp->end($out);
}
$result = [];
}
}
});
$server->start();

执行程序