zan框架入门(三)——原理浅析

swoole

在了解zan框架之前,先看一下经典的swoole运行流程图:


swoole运行流程图
swoole运行流程图

swoole运行期间,会有一个Manager进程和多个worker进程。一个Manager管理worker进程。一个woker进程可以同时处理多个请求。

代码分析

流程分析

众所周知,zan框架服务启动的入口文件是bin/httpd,所以我们从bin/httpd切入。

zan框架请求流程图

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来实现非阻塞。

参考资料

Server-Swoole扩展-Swoole文档中心

2.1 Worker进程 · Easy Swoole

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容