建立一個cli指令

php think make:command Thread thread

測試能否成功執(zhí)行

php think thread

安裝Guzzle類別庫

文件位址：guzzle文檔位址(https://guzzle-cn.readthedocs.io/zh_CN/latest/quickstart.html)

實(shí)作程式碼

<?php
/**
 * Created by.
 * User: Jim
 * Date: 2020/9/29
 * Time: 14:31
 */

namespace app\command;

use GuzzleHttp\Client;
use GuzzleHttp\Pool;
use think\console\Command;
use think\console\Input;
use think\console\Output;

/**
 * Guzzle
 * Class Thread
 * @package app\command
 * 文檔地址 https://guzzle-cn.readthedocs.io/zh_CN/latest/quickstart.html
 */

class Thread extends Command
{

    /**
     * 請求的總次數(shù)
     * @var int
     */
    protected $totalPageCount = 50;
    /**
     * 當(dāng)前請求的次數(shù)
     * @var int
     */
    protected static $counter = 1;
    /**
     * 線程的數(shù)量
     * @var int
     */
    protected $threads = 20;

    protected function configure()
    {
        // 指令配置
        $this->setName(&#39;thread&#39;);
        // 設(shè)置參數(shù)

    }

    protected function execute(Input $input, Output $output)
    {

        $client = new Client();
        $requests = function ($total) use ($client) {
            foreach (range(1, $total) as $r) {
                $uri = &#39;https://apinew.juejin.im/content_api/v1/short_msg/detail&#39;;
                yield function () use ($client, $uri) {
                    return $client->postAsync($uri, [
                        &#39;verify&#39; => false,
                        &#39;json&#39; => [
                            &#39;msg_id&#39; => &#39;6845185452727599118&#39;
                        ]
                    ]);
                };
            }

        };

        $pool = new Pool($client, $requests($this->totalPageCount), [
            &#39;concurrency&#39; => $this->threads,
            // 請求成功
            &#39;fulfilled&#39; => function ($response, $index) use ($output) {
                $res = $response->getBody()->getContents();
                $output->writeln($res);
                $output->writeln("正在執(zhí)行第{$index}個·····");
                if ($this->checkThreadIsEnd() == true) {
                    $output->writeln("------------請求結(jié)束---------");
                    return false;
                }
            },
            // 請求失敗
            &#39;rejected&#39; => function ($reason, $index) use ($output) {
                $output->writeln("執(zhí)行失敗，{$reason}");
            },
        ]);
        $promise = $pool->promise();
        $promise->wait();
    }

    /**
     * 檢測任務(wù)是否結(jié)束
     * @return bool
     */
    private function checkThreadIsEnd()
    {
        if (self::$counter < $this->totalPageCount) {
            self::$counter++;
            return false;
        } else {
            return true;
        }
    }


}

執(zhí)行指令

php think thread

以上是thinkphp5.1怎麼實(shí)作多執(zhí)行緒爬蟲的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！