记一次重构：并行化调用接口实践
优化目标
在我现在所在的产品线中 http 接口被大量使用，用来获取各种开放数据，可以说 http 调用在代码中随处可见。比如一个访问最频繁的页面，一次请求将会产生 7~8 次 http 调用。虽然每个接口都非常的快，但 8 次累加起来的消耗还是相当的可观，所以我最近的优化工作主要是：
并行调用各 http 请求，以缩短脚本的运行时间。
重构起因
实际上，将请求并行化并不十分困难，使用 curl 提供的 multi* 方法族就可以实现，网上有很多类似的文章来介绍其使用方法，大致的思想是把多个 curl 句柄放入一个 curl multi_handler 中，以 nonblocking 的方式执行，然后使用内核提供的 IO 复用机制（select/epoll等）进行事件查询，当有 response 返回时处理结果。很明显这是一个异步的过程，而在我们现在用的 php 框架中对于 http 调用则是同步的，建立连接、发送请求、接受响应和处理结果都是串行完成的，这些操作都被封装到一系列类中，使得上层只用一行代码就可以完成 API 的调用并获得 返回结果 ，例如:
$userInfo = $this->apiProxy->general->getUserInfo($uid); //调用 apiecho $userInfo['rst']['username']; //使用结果
上面的返回值 userInfo是个 数组 ，包含了调用方感兴趣的所有数据。虽然只有 2 行，但是框架默默帮你做了大量的工作，其中包括：建立连接、发送请求、接受结果，检查状态 、处理错误、格式化输出、写缓存等等，而且具体到每个 api 对于返回值的处理还有不同的逻辑。如何用一种优雅的方式对现有框架进行重构，既能符合要求，又能保证改动量最小，成为了现在最重要的问题。Lazy evaluation
当我开始接手这项工作的时候，脑海中想到的第一个对应思想就是 Lazy evaluation （ 缓式求值 ），维基百科上对于 缓式求值 的定义是：
In programming language theory, lazy evaluation, or call-by-need[1] is an evaluation strategy which delays the evaluation of an expression until its value is needed (non-strict evaluation) and which also avoids repeated evaluations (sharing).Lazy evaluation 是编程语言设计领域中的一个 表达式求值 策略，它延缓对表达式的求值直到你需要它的时候。看上去 lazy evaluation 好像和我们的问题挨不上边，而且 php 也不支持 lazy evaluation，不过仔细想一下，如果我们能把对 http 请求的 后续操作 延缓到对 返回结果的使用 时，就可以用一种 优雅 的实现来使框架支持并行执行，而且对于 controller 层的改动也非常的小。
具体点说就是在进行 api 调用的时候，不再返回结果数组，而是返回一个 句柄，这个句柄标识了一个被提交到后台的请求，它被加入到 curl multi_handler 中，你不再关心它，由 curl 替你完成，你的代码可以继续往下执行，去完成其他的业务逻辑。而当我们需要这个结果时，检查这个句柄是否已经完成，如果已经完成则执行上面 接受结果 之后的所有操作，返回结果。那么上面的代码重构后变成：
$userInfo = $this->apiProxy->async_general->getUserInfo($uid); //使用 curl 异步调用//
//执行其他的业务逻辑......
//
echo $userInfo['rst']['username']; //检查句柄是否已经完成，返回结果
async_ 前缀表示使用异步来调用 api 。上面代码中，在调用 api 和使用结果之间的时间都留给 curl 去连接服务器、发送请求、获取结果到 socket 输入buffer等等，就可以达到并行操作节省时间的效果。ArrayObject
显然接口调用的返回值必须是个 object 而不能再是个 array ，因为数组的可操作性有限，不能执行逻辑， object 则提供了更大的灵活性，但在原有代码中 array 已经被大量应用，把它们逐个改为 object 是很不现实的，那么 object 是否可以像数组一样被使用呢？经过一番搜索，我发现 php 里还真有这样的东西，它就是 SPL(Standard PHP Library) 提供的 ArrayObject 类，这个类的介绍简单明了：
This class allows objects to work as arrays.
正好是我们需要的。
ArrayObject 主要通过下面 4 个方法提供对数组的支持（实际上它是通过实现 ArrayAccess接口来实现的）：
public bool offsetExists ( mixed $index )public mixed offsetGet ( mixed $index )
public void offsetSet ( mixed $index , mixed $newval )
public void offsetUnset ( mixed $index )
有了这个类的帮助，我们的方案就明确了，思路就是：返回的 object 继承于 ArrayObject ，并覆盖这 4 个方法，在覆盖的方法内检查 http 请求是否完成并获取结果；而 controller 层对于结果的使用几乎不用改变，仍然按照数组方式使用。我们把返回的句柄类命名为 AsyncHandler ，它的定义为：
class AsyncHandler extends ArrayObject事件回调到目前为止，一切都非常的顺利，但是还有一个重要的问题没有解决，那就是对 http response 的处理，就像前面所说的，原有的串行方法，直接返回处理过的结果，而现在只返回一个对象，结果还不知道什么时候能取到呢，这些处理代码显然应该等到 http response 确定返回的时候才能执行，这时就要使用回调来实现了，通过对代码的分析，发现有主要 3 处对结果进行处理的代码，一处在 http response 返回时，此处做了 http 状态值的检查、日志记录等基本操作，这部分是公共的代码；另外一处在接口自身的函数内，做了接口特有的处理，这部分是每个接口一份；最后一处是在把结果返回给调用方之前，对结果做格式化，保存缓存等，这部分也是公共的代码。通过总结出类型，我们对如何修改就胸有成竹了：
首先，在 AsyncHandler 的中定义 3 个回调函数：
//Callback functionsprotected $onRecvResponse = NULL;
protected $recvCtx = NULL;
protected $onBusiness = NULL;
protected $busCtx = NULL;
protected $onAPIReturn = NULL;
protected $apiCtx = NULL;
onXXX是回调函数，xxxCtx 是回调函数的上下文信息，它是个数组，保存了回调函数执行过程中需要的变量。在上述 3 处对 http response 进行处理的地方，把原有的代码封装成一个匿名函数，在异步 curl 模式下，把这个匿名函数和相关上下文传入到 AsyncHandler 中；如果是同步curl模式，就直接执行这个匿名函数（和原来一样）。下面以一处代码为例：
$c['var'] = $varname; //相关上下文，就是回调函数里面用到的一些变量$onApiReturn = function($response, $c) {
评论