swPromise PHP纯异步非阻塞框架

swPromise 是基于 Swoole 的 PHP promise 框架。

在日常的使用场景中，PHP一般用作接口聚合层。 一个业务请求可能会串行的请求多个接口A->B->C，此时如果接口B的响应时间较慢（关键性业务，需要有较长的timeout等待时间），则会导致请求整体的时间过长，严重降低系统的响应能力。 考虑到这个业务场景下，进程的主要时间用在等待网络io返回。 如果能够使用异步编程的方式，则会极大的提升服务的吞吐量（NodeJS的优势）。

如果某接口响应时间超过往常，会导致php-fpm进程数急剧升高，从而导致大量cpu资源浪费在进程调度上面，甚至导致服务崩溃。swPromise框架是为了解决该问题而开发的。

异步非阻塞模式是实现高性能网络编程的一种方法。 传统上，为进行异步调用，会在代码中实现大量的回调函数，导致代码可读性与可维护性的急剧下降。 为了解决这个问题，主流方案有以下几种：

• 自定义事件式方案

• Promise/Deferred

• 高阶函数篡改回调函数

• 协程(GeneRATor)

Swoole 是PHP语言的高性能网络通信框架，提供了PHP语言的异步多线程服务器。 swoole采用自定义事件式方案，为我们提供网络层基本封装。基于swoole，可以扩展出业务层的异步开发框架。

tsf （Tencent Server Framework） 是腾讯公司推出的 PHP 协程方案，基于 Swoole+PHP GeneraTor 实现的 Coroutine。 该框架使用协程模式，基于swoole与swoole framework开发。 实现了真正的异步非阻塞开发模式，同时具有极高的性能。 其核心代码来源于该文章Cooperative multitasking using coroutines (in PHP!) 。 tsf使用了较为复杂的用户态任务调度逻辑，暂时没有看到生产环境的使用案例。另外由于使用了swoole framework，也使其略显重量级。

swPromise的主要处理流程在Core\Async\Promise类中。 该类实现了基本的then方法，并通过对promise流程的延迟计算，保证了异步流程的动态控制能力。 该框架是一个非常基础的web框架，目前仅实现通用Future（通用延迟计算）、HTTPClIEntFuture、ResponseFuture三个延迟计算类。

该框架需要配合Swoole、php-http-parser扩展使用，第二个扩展用于解析http协议。

演示代码

class Handler_Index extends \Core\Handler{
    public Function run($request, $response){
        Promise::create ( Model::getUserInfo ( 'user1', 'haha' ) )
            ->then (function(&$promise){
                $user1 = $promise->get('user1');
                if($user1){
                    return Model::getUserInfo ( 'user2', 'haha2' )
                            ->then(function(&$promise){
                                $user2 = $promise->get('user2');
                                $promise->accept(['useR3'=>$user2['body']]);
                            });
                }
                else $promise->accept();
            })
            ->then ( Model::getUserInfo ( 'user4', 'haha4' ) )
            ->then ( Model::getUserInfo ( 'user5', 'haha5' ) )
            ->then ( new ResponseFuture ($response) )
            ->start ( new PromiseContext () );
    }
}

这段流程表明了，先获取haha这个用户的信息，写入上下文的user1字段中。 如果获取到了数据，再获取haha2这个用户的信息，写入上下文user2字段中。 并将user2的body字段放入user3字段中。然后获取haha4和haha5的信息。 最后将所有数据输出到网页。

可以看到，在第一个then中，通过if条件返回promise对象，实现了对异步流程的动态控制。 同样的，整个流程通过then串联起来，已经较为接近同步代码的书写了。 而使用回调的方式，代码会变得极为恐怖。

并行请求

class Handler_Index extends \Core\Handler{
    public function run($request, $response){
        Promise::create([
            Model::getUserInfo ( 'user1', 'haha' ),
            Model::getUserInfo ( 'user2', 'haha2' ),
        ])->then(
            new ResponseFuture ($response)
        )->start(new PromiseContext ());
    }
}

这个请求并行获得haha与haH2两个用户的数据，分布放到user1和user2两个字段中。

存在问题

其中Handler_Sync实现的就是该框架同步的使用方式。 另外，目前reject方法以及异常处理流程均没有实现，有兴趣的朋友可以自行扩展。

目前有一个比较严重的bug，如果大量http request没有完成就自行中断的话，会导致swoole http server发生错误，从而退出。在swoole前面放一个Nginx就可以解决问题。

测试方法

启动

php run.php

测试：

ab -n 10000 -c 100 "http://localhost:9502/async"
ab -n 10000 -c 100 "http://localhost:9502/sync"

经过测试，在后端接口响应性能有问题的情况下，swPromise 可以同时处理大量连接，用很低的 cpu 负载等待接口数据返回。