实现一个功能:根据卡号去第三方平台获取卡的详细信息,但是由于第三方相应速度比较慢(一张卡大概3S),在批量操作的时候,响应就会很慢,所以想到使用多进程去操作文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
具体代码如下文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 | set_time_limit(0); $forkNums = 20; //开启的进程数 if (!function_exists("pcntl_fork")) { die("pcntl extention is must !"); } for($i=0;$i<$forkNums;$i++){ $pid = pcntl_fork(); //创建子进程 if ($pid == -1) { //错误处理:创建子进程失败时返回-1. die('could not fork'); } else if ($pid) { //父进程会得到子进程号,所以这里是父进程执行的逻辑 //如果不需要阻塞进程,而又想得到子进程的退出状态,则可以注释掉pcntl_wait($status)语句,或写成: pcntl_wait($status,WNOHANG); //等待子进程中断,防止子进程成为僵尸进程。 } else { //这里写子进程执行的逻辑 $list = $this->mysql($v['start'],$v['rows']); foreach($list as $key=>$value){ $terminals = $this->getterminalinfo($value); //这里调用第三方接口,该过程大概需要3s // ... 这里再对获取到的卡号信息进行自己相关的业务处理 } unset($list); exit(0); } } |
其中需要注意的几个坑:文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
1、如果在ThinkPHP中使用多进程,切勿在子进程中连接数据库,会出现gateway timeout错误,导致子进程终止,执行失败。引起原因为ThinkPHP在操作数据库后,没有主动关闭连接,导致连接超时无法连接数据库,解决办法,自己写数据库连接代码,操作完之后,mysql_close($conn)关闭连接文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
2、在子进程中的变量,使用完之后,务必记得unset()注销变量,否则造成内存溢出文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
3、子进程执行完毕之后,需要exit(0)退出程序,否则子进程无法退出,造成僵尸进程,占用系统资源。文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html
其他事项,具体开多少个子进程,视自己业务和服务器配置决定,不是越多越好,数量太多,会造成系统资源耗尽,造成web服务器无法访问文章源自菜鸟学院-https://www.cainiaoxueyuan.com/bc/4432.html