上次的回声服务程序有个很大的缺点,就是只能同时连接一个客户端,这明显是不合理的。
所以这次采用多进程的方式来实现同时为多个客户端提供服务。
以下是最终的效果:
在开始编码之前,先介绍一下什么是进程。
进程,即正在运行的占用内存的程序,是一个独立的内存空间。比如我们在 windows 上打开记事本软件,这个操作就相当于打开了一个进程。
而多进程则是通过创建多个进程来共同完成一件事。
我们本次只需实现服务端的程序就行了,客户端还使用之前的。没读过之前文章的可以查看历史文章。
在PHP中,我们可以使用 pcntl_fork 函数来实现创建进程。
下面是函数的原型:
int pcntl_fork ( void )
官方解释:
成功时,在父进程执行线程内返回产生的子进程的PID,在子进程执行线程内返回0。失败时,在 父进程上下文返回-1,不会创建子进程,并且会引发一个PHP错误。
为什么说是父进程执行的线程呢,因为一个进程中至少包含一个线程 ,而这个线程则是进程的主线程。
父进程在调用 pcntl_fork 时,同时复制出一个独立的子进程,这个子进程具有父进程同样的上下文。也就是说两个进程共享一个代码而已。
下面进入编码环节:
通过执行 pcntl_fork 函数,同时复制了一个子进程,此时,如果上下文是父进程的执行环境,则返回值为子进程的进程号。如果是子进程的执行环境,则返回0。所以下面的if程序结构,两个分支都执行了。
子进程同样还是以前的逻辑,用来接收客户端的消息,同时发送给客户端。
倒数第二行调用了 pcntl_waitpid 函数,在讲解这个函数之前我们先了解一下什么是僵尸进程。
正常情况下,子进程是通过父进程创建的。由于进程是互相独立的内存结构,所以父进程是不会知道子进程的运行状态的。子进程完成自己的任务之后,并不能自己退出,这个时候需要父进程通过操作系统来取得子进程的状态,从而回收子进程。否则,我们的子进程将会成为一个垃圾资源,也就是僵尸进程。
下面是这个函数的函数原型:
int pcntl_waitpid ( int $pid , int &$status [, int $options = 0 ] )
官方解释:
等待或返回fork的子进程状态。
其实上面的代码是有问题的,在 foreach 中第一次调用 pcntl_waitpid 之后 ,主进程其实此时是被阻塞着,一直在等待第一个子进程退出,而其他的子进程若此时异常退出,则并没有被主进程回收,也就产生了僵尸进程。而在实际的开发中主进程还是要做其他的事情的。
所以这里推荐采用非阻塞的方式,很简单,只需加上第三个参数:WNOHANG。即:pcntl_waitpid ($pid, $status, WNOHANG)
这样子可以在没有子进程退出的情况下立刻返回,从而继续执行后续代码。