swoole
在了解zan框架之前,先看一下经典的swoole运行流程图:
swoole运行期间,会有一个Manager进程和多个worker进程。一个Manager管理worker进程。一个woker进程可以同时处理多个请求。
代码分析
流程分析
众所周知,zan框架服务启动的入口文件是bin/httpd,所以我们从bin/httpd切入。
request处理
initContext
初始化上下文,路由分发,解析出controller_name和action_name,设置cookie,设置请求超时时间,都在这一步完成。
初始化MiddlewareManager
这一步会去根据resource/middleware/middleware.php的配置,在稍后应用对应的middleware设置。
做限流处理
绑定请求处理完成或者任务超时后的响应处理
读取initContext里设置的超时时间配置,绑定任务完成时执行的方法,用计时器注册请求超时时要执行的方法。
获得coroutine,并建一个Task执行
实例化一个RequestTask类,执行run方法,通过yield来延迟执行doRun方法。将run方法返回的coroutine放到一个新实例化的Task里,并执行run方法,来非阻塞地执行协程。
信号
任务是循环请求调度器来执行任务的,一旦发现任务完成,退出循环。
TASK_SLEEP
当调度器返回此信号后,退出循环
TASK_AWAKE
无引用
TASK_CONTINUE
继续执行任务
TASK_KILLED
退出任务执行
TASK_RUNNING
无引用
TASK_WAIT
当调度器返回此信号后,退出循环
TASK_DONE
执行完成任务后的动作,然后退出循环
调度器
这里的调度器依次执行不同类型的任务。
SysCall
基于SysCall的命令很多,都是非阻塞的方式直接调用,每个返回的信号也不一样。
命令 | 返回值 |
---|---|
taskSleep | TASK_SLEEP |
newTask | TASK_CONTINUE |
go | TASK_CONTINUE |
killTask | TASK_KILLED |
getTaskId | TASK_CONTINUE |
getRpcContext | TASK_CONTINUE |
setRpcContext | TASK_CONTINUE |
getContext | TASK_CONTINUE |
setContext | TASK_CONTINUE |
getContextObject | TASK_CONTINUE |
getTaskResult | TASK_CONTINUE |
getTaskStartTime | NULL |
waitFor | NULL |
wait | NULL |
parallel | TASK_WAIT |
async | TASK_CONTINUE |
getCookieHandler | TASK_CONTINUE |
cookieGet | TASK_CONTINUE |
cookieSet | TASK_CONTINUE |
getSessionHandler | TASK_CONTINUE |
getServerHandler | TASK_CONTINUE |
Coroutine
如果是这个协程返回的值还是一个协程,则将此协程压入堆栈,将当前的协程设置为返回的协程值,并返回TASK_CONTINUE,让调度器下一次执行这个协程。
Async
所的IO请求都基于Async接口重新实现了非阻塞,例如Client、Redis、Mysqli都实现了Async接口。
当调度器遇到异步任务时,会将任务扔到一个地方等待唤醒。返回TASK_WAIT结束这个任务的循环。
Yield
当调度器处理到yield返回值时,如果协程还没有全部被执行完,则返回TASK_CONTINUE继续循环,否则返回null继续执行。
任务堆栈
将堆栈里的协程弹出来,设置send进来的值。效果就是获取子协程执行后的结果,继续执行父协程。
TaskDone
判断协程是否全部被执行完,是的话就结束循环,没有就继续执行。
异步执行的例子
zan框架的异步,底层还是通过调用swoole的接口。
HttpClient
HttpClient底层就是调用swoole_async_dns_lookup来实现非阻塞执行的。
taskSleep
taskSleep是通过调用swoole_timer_after来实现非阻塞。