swoole1.7.3发布，增加PHP多进程管理模块

PHP的异步并行扩展swoole，最近增加了多进程管理模块swoole_process，用来替代PHP的pcntl扩展。 PHP自带的pcntl，存在很多不足，如： pcntl无法用在fpm/apache中 pcntl没有提供进程间通信的功能 pcntl不支持重定向标准输入和输出 pcntl只提供了fork这样原始

PHP的异步并行扩展swoole，最近增加了多进程管理模块swoole_process，用来替代PHP的pcntl扩展。

PHP自带的pcntl，存在很多不足，如：

• pcntl无法用在fpm/apache中
• pcntl没有提供进程间通信的功能
• pcntl不支持重定向标准输入和输出
• pcntl只提供了fork这样原始的接口，容易使用错误

swoole_process提供了比pcntl更强大的功能，更易用的面向对象风格API，使PHP在多进程编程方面更加轻松。

swoole_process提供的功能特性：

• swoole_process提供了基于unixsock的进程间通信，使用很简单只需调用recv/send即可
• swoole_process支持重定向标准输入和输出，在子进程内echo不会打印屏幕，而是写入管道，读键盘输入可以重定向为管道读取数据
• swoole_process允许用于fpm/apache的Web请求中
• 配合swoole_event模块，创建的PHP子进程可以异步的事件驱动模式
• swoole_process提供了exec接口，创建的进程可以执行其他程序，与原PHP父进程之间可以方便的通信
• swoole_process可以安全地用于fpm/apache环境下

代码示例：

Php代码

1. $worker_num?=?8;
2. for($i?=?0;?$i?
3. {
4. ????$process?=?new?swoole_process(&＃8216;callback_function&＃8217;,?true);
5. ????$pid?=?$process->start();
6. ????$workers[$pid]?=?$process;
7. }
8. foreach($workers?as?$pid?=>?$process)
9. {
10. ????$process->write(&＃8220;hello?worker[$pid]\n&＃8221;);
11. ????echo?&＃8221;From?Worker:?&＃8221;.$process->read();
12. }
13. for($i?=?0;?$i?
14. {
15. ????$ret?=?swoole_process::wait();
16. ????$pid?=?$ret['pid'];
17. ????unset($workers[$pid]);
18. ????echo?&＃8221;Worker?Exit,?PID=&＃8221;.$pid.PHP_EOL;
19. }
20. function?callback_function(swoole_process?$worker)
21. {
22. ????//echo?&＃8221;Worker:?start.?PID=&＃8221;.$worker->pid.&＃8221;\n&＃8221;;
23. ????//recv?data?from?master
24. ????$recv?=?$worker->read();
25. ????echo?&＃8221;From?Master:?$recv\n&＃8221;;
26. ????//send?data?to?master
27. ????$worker->write(&＃8220;hello?master\n&＃8221;);
28. ????sleep(2);
29. ????$worker->exit(0);
30. }

子进程事件驱动模式

Php代码

1. function?callback_function_async(swoole_process?$worker)
2. {
3. ????//echo?&＃8221;Worker:?start.?PID=&＃8221;.$worker->pid.&＃8221;\n&＃8221;;
4. ????//recv?data?from?master
5. ????$GLOBALS['worker']?=?$worker;
6. ????swoole_event_add($worker->pipe,?function($pipe)?{
7. ????????$worker?=?$GLOBALS['worker'];
8. ????????$recv?=?$worker->read();
9. ????????echo?&＃8221;From?Master:?$recv\n&＃8221;;
10. ????????//send?data?to?master
11. ????????$worker->write(&＃8220;hello?master\n&＃8221;);
12. ????????sleep(2);
13. ????????$worker->exit(0);
14. ????});
15. }

PHP创建一个Python子进程，并与之通信

Php代码

1. $process?=?new?swoole_process(&＃8216;pyhon_process&＃8217;,?true);
2. $pid?=?$process->start();
3. function?pyhon_process(swoole_process?$worker)
4. {
5. ????$worker->exec(&＃8216;/usr/bin/python&＃8217;,?array(&＃8220;echo.py&＃8221;));
6. }
7. $process->write(&＃8220;hello?world\n&＃8221;);
8. echo?$process->read();
9. $ret?=?swoole_process::wait();
10. var_dump($ret);

Python程序echo.py

Python代码

1. import?sys
2. def?main():
3. ????s?=?raw_input()
4. ????print?&＃8221;Python:&＃8221;?+?s
5. main()

原文地址：swoole 1.7.3发布，增加PHP多进程管理模块, 感谢原作者分享。