当前位置 博文首页 > 浅谈Swoole并发编程的魅力

    浅谈Swoole并发编程的魅力

    作者:八重樱 时间:2021-08-24 17:44

    目录
    • 场景介绍
    • 并发编程
    • 编码实现
    • 并发难题
    • 数据同步问题
    • 思维转变

    场景介绍

    假设我们要做一个石头剪刀布的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();

    执行程序

    php game.php

    打开3个Chrome的Tab页。并且URL中传入name分别为A、B、C代表3个用户。

    在第一个、第二个提交结果时,并未返回任何结果,Chrome正在转圈等待服务器返回结果。第三个表单提交时3个Tab页同时返回结果。

    并发难题

    并发编程比串行编程更强大,也更复杂。并发编程会遇到之前串行编程所没有的新问题,如:

    数据同步问题

    上下文管理问题

    时序问题

    这需要开发者具备更严谨的工程思维能力,也需要开发者具备更深厚的编程功底。

    思维转变

    Swoole其实颠覆了以往PHP的编程模式,使得程序员的视野不再局限于一次请求的处理,不再局限于对于数据库CURD操作、接口调用。配合使用Swoole4提供的协程编程能力,就可以在内存空间内实现各种复杂的交互。

    新的编程模式,可以让PHPer轻松地去实现网络游戏、服务器系统、智能家居、物联网等项目。

    jsjbwy
    下一篇:没有了