WEB开发中多进程的应用，我们一般会常用在一些批量处理的任务型模块中，例如:

1、服务CURL发包

2、redis消息队列处理

3、邮件、短信群发

4、网络爬虫

等等。

下面我们就通过Swoole的`Swoole/Process`模块，学习下如何利用Swoole进行多进程间的日常开发流程。

### 一、服务器CURL发包
该类业务常用于A端接口批量回调。

假设我们是第三方支付公司，现在有3家企业使用了我们的支付接口，当用户支付完成后，我们需要将支付结果，通知到对应企业的回调地址中。

例如3个，每个需要1秒，如果我们同步运行至少需要3秒完成，这对用户的体验是非常不好的。

在原来的PHP中，我们可以通过curl的多线程模块进行批量回调，但同一进程中，线程数越大则消耗越大，而且处理效率会几何下降。

还有的人会用原生的`pcntl_fork()`实现多进程，但这种方式的代码量非常多，而且子进程很难控制，代码可读性也很差，非常难以维护。

现在我们可以引入swoole的process子进程开启三个进程同时curl则需要1秒处理好。
```php
<?php
echo "start:".date("Ymd H:i:s").PHP_EOL;
$urls = [
    'http://www.baidu.com',
    'http://www.sina.com.cn',
    'http://www.qq.com',
];
//使用swoole的process开启多个子进程
for ($i=0; $i < 3; $i++) {
    # 子进程
    $process = new swoole_process(function (swoole_process $worker) use ($i, $urls) {
        //curl处理
        $content = curlData($urls[$i]);
        //因为下面参数是true所以会输出到管道里
        echo $content.PHP_EOL;
    }, true);
    $pid = $process->start();
    $wokers[$pid] = $process;
}
foreach ($wokers as $process) {
    echo $process->read();
}

# 模拟发包
function curlData($url) {
    # 模拟消耗1秒
    sleep(1);
    return $url."success".PHP_EOL;
}
echo 'end:' . date("Ymd H:i:s");
```
运行结果如下，确实运行缩短至1秒：
```
start:20200113 06:02:21
http://www.baidu.comsuccess
http://www.sina.com.cnsuccess
http://www.qq.comsuccess
end:20200113 06:02:22
```

### 二、发送邮件和短信

比如，我们要对已知的用户数据进行判断，是否需要发送邮件和短信，如果需要发送则发送。

不使用多进程时，我们首先判断是否发送邮件，如果需要则发送

然后再判断是否需要发送短信，如果需要则发送。如果发送邮件耗时2s，发送短信耗时2s，那么我们完成任务大概需要4s左右的时间。

如果我们使用多进程开两个子进程，一个用于处理短信，则耗时一共需要2s左右，处理时间缩短了一半。

下面看详细代码：
```php
<?php
$obj = new process();
$obj->run([
    "sendmail" => 1,
    "mailto"   => "12345@qq.com",
    "sendsms"  => 1,
    "smsto"    => "123456"
]);

class process {
    # 测试参数
    private $info;
    # 发送邮件的进程
    private $mail_process;
    # 发送短信的进程
    private $sms_process;

/**
     * 执行
     * @param array $info 测试参数
     * @return void
    */
    public function run($info) {
        $this->info = $info;

echo "start:".date("Y-m-d H:i:s").PHP_EOL;

$this->mail_process = new swoole_process([$this, 'sendMail'], true);
        $this->mail_process->start();

$this->sms_process = new swoole_process([$this, 'sendSMS'], true);
        $this->sms_process->start();

# 主进程输出子进程范围内容
        echo $this->mail_process->read().PHP_EOL;
        echo $this->sms_process->read().PHP_EOL;
        echo "end:".date("Y-m-d H:i:s");
    }
    # 并行函数
    public function sendMail($worker) {
        if ($this->info['sendmail']==1) {
            sleep(2);
            $worker->write("send mail to ".$this->info['mailto']);
        }
    }
    # 并行函数
    public function sendSMS($worker) {
        if ($this->info['sendsms']==1) {
            sleep(2);
            $worker->write("send mail to ".$this->info['smsto']);
        }
    }
}
```
最终得出结果：
```
start:2020-01-13 06:21:50
send mail to 12345@qq.com
send mail to 123456
end:2020-01-13 06:21:52
```

### 三、网页抓取，循环执行任务，划分多个进程执行

假设我们现在有一个通过curl抓取网页内容的需求，需要抓取10个网页，url地址通过数组读取，每个curl耗时2s。

如果我们通过for循环来抓取这10个网页，需要耗时20s，使用多进程我们可以将任务划分成5份，分别由5个进程执行，每个进程抓取2个url，并发执行，共耗时4s，效率提高5倍。

```php
<?php
# 模拟10次请求
$url_arr = [];
for ($i=0; $i<10; $i++){
    $url_arr[] = "www.baidu.com?wd=".$i;
}

$obj = new process();
$obj->run($url_arr);

class process {
    # 测试参数
    private $info;
    # 发包的进程集合
    private $workers = [];

/**
     * 执行
     * @param array $info 测试参数
     * @return void
    */
    public function run($info) {
        $this->info = $info;
        echo "start:".date("Y-m-d H:i:s").PHP_EOL;

# 创建5个子进程处理
        for ($i=0; $i<5; $i++){
            $process = new swoole_process([$this, 'getContents'],true);
            $process->start();
            $process->write($i);
            $this->workers[] = $process;
        }

# 主进程输出子进程范围内容
        foreach ($this->workers as $process){
            echo '收到有数据了：'.$process->read().PHP_EOL;
        }
        echo "end:".date("Y-m-d H:i:s");
    }
    # 并行函数
    public function getContents($worker) {
        $i = $worker->read();
        # 一个进程就处理2个请求
        $res1 = $this->execCurl($this->info[($i*2)]);
        $res2 = $this->execCurl($this->info[($i*2+1)]);
        echo $res1.'|'.$res2.PHP_EOL;
    }
    # 模拟发包
    public function execCurl($url){
        sleep(2);
        return "handle ".$url." finished";
    }
}
```
执行效果如下：
```
start:2020-01-13 06:30:57
收到有数据了：handle www.baidu.com?wd=0 finished|handle www.baidu.com?wd=1 finished
收到有数据了：handle www.baidu.com?wd=2 finished|handle www.baidu.com?wd=3 finished
收到有数据了：handle www.baidu.com?wd=4 finished|handle www.baidu.com?wd=5 finished
收到有数据了：handle www.baidu.com?wd=6 finished|handle www.baidu.com?wd=7 finished
收到有数据了：handle www.baidu.com?wd=8 finished|handle www.baidu.com?wd=9 finished
end:2020-01-13 06:31:01
```
从上面的例子可以看出：swoole的多进程process方法，比curl模拟并发会好很多。

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺