swoole( 网络IO 四)
|
Swoole结构与网络io模型 |
|
|
Swoole结构 |
Ps aux | grep swoole
|
|
|
Master(老大，老板) 这个是swoole的主进程，这个进程是用于处理swoole的核心事件，在这个进程中可以看到它拥有一个mainReactor线程以及若干个reactor线程
Mainreactor: 主线程会负责监听server socket，如果有新的连接accept，主线程会评估每个Reactor线程的连接数量。将此连接分配给连接数最少的reactor线程，做一个负载均衡。
Reactor: Reactor线程负责维护客户端机器的TCP连接、处理网络IO、收发数据完全是异步非阻塞的模式。 swoole的主线程在Accept新的连接后，会将这个连接分配给一个固定的Reactor线程，在socket可读时读取数据，并进行协议解析，将请求投递到Worker进程。在socket可写时将数据发送给TCP客户端。 （负责维护客户端机器的tcp连接，处理网络IO； swoole的主线程在accept新的连接后，会将这个连接分配给一个固定的reactor线程。在socket可读时读取数据，进行协议解析，将请求投递给到worker进程。 ）
Manager（总经理） Swoole想要实现最好的性能必须创建出多个工作进程帮助处理任务，但Worker进程就必须fork操作，但是fork操作是不安全的，如果没有管理会出现很多的僵尸进程，进而影响服务器性能，同时worker进程被误杀或者由于程序的原因会异常退出，为了保证服务的稳定性，需要重新创建worker进程。 （创建多个工作进程 ， fork不安全，会有僵尸进程）
Worker（员工） worker 进程属于swoole的主逻辑进程，用户处理客户端的一系列请求，接受由Reactor线程投递的请求数据包，并执行PHP回调函数处理数据生成响应数据并发给Reactor线程，由Reactor线程发送给TCP客户端可以是异步非阻塞模式，也可以是同步阻塞模式 （主逻辑进程，处理客户的请求）
Task（外包人员） taskWorker进程这一进城是swoole提供的异步工作进程，这些进程主要用于处理一些耗时较长的同步任务，在worker进程当中投递过来。 （处理一些耗时的任务） |
|
swoole进程数量 |
当启动一个Swoole应用时，一共会创建2 + n + m个进程，2为一个Master进程和一个Manager进程，其中n为Worker进程数。m为TaskWorker进程数。
一共会创建2+n+m个进程 n是worker m是task Worker创建需要根据自己的电脑的cpu处理核数（机器为1核的，worker为1）
可以对于swoole的进程限制数量 $server->set([ 'worker_num'=>1, //设置进程 ]);
|
|
Swoole运行流程图 |
|
|
Swoole进程函数 |
Master进程： onstart server启动在主进程 onshutdown 此事件在server正常结束时发生
Manager进程： onManagerStart 当管理进程启动时调用它 onManagerStop 当管理进程结束时调用它 onWorkError 当worker/task_worker进程发生异常后会在manager进程内回调此函数
Worker进程： onWorkerStart 此事件在Worker进程/Task进程启动时发生 onWorkerStop 此事件在worker进程终止时发生 onConnect 有新的连接进入时，在worker进程中回调 onClose TCP客户端连接关闭后，在worker进程中回调此函数 onReceive 接收到数据时回调此函数，发生在worker进程中 onPacket 接收到UDP数据包时回调此函数，发生在worker进程中 onFinish 当worker进程投递的任务在task_worker中完成时，task进程会通过finish()方法将任务处理的结果发送给worker进程 onWorkerExit 仅在开启reload_async特性后有效。异步重启特性 onPipeMessage 当工作进程收到由 sendMessage 发送的管道消息时会触发事件 onTask 在task_worker进程内被调用。worker进程可以使用swoole_server_task函数向task_worker进程投递新的任务 onWorkerStart 此事件在Worker进程/Task进程启动时发生 onPipeMessage 当工作进程收到由 sendMessage 发送的管道消息时会触发事件
Task进程： |