Expliquez comment implémenter un robot d'exploration multithread dans thinkphp5.1-PensezPHP-php.cn

La colonne suivante du didacticielthinkphp frameworkvous expliquera comment thinkphp5.1 utilise la ligne de commande cli + la bibliothèque de classes Guzzle pour implémenter des robots d'exploration multithread. J'espère que cela sera utile aux amis dans le besoin !

Créez une commande cli

php think make:command Thread thread

Copier après la connexion

Testez si elle peut être exécutée avec succès

php think thread

Copier après la connexion

Installez la bibliothèque de classes Guzzle

Adresse du document : adresse du document guzzle (https://guzzle-cn.readthedocs. io/zh_CN /latest/quickstart.html)

code d'implémentation

setName('thread'); // 设置参数 } protected function execute(Input $input, Output $output) { $client = new Client(); $requests = function ($total) use ($client) { foreach (range(1, $total) as $r) { $uri = 'https://apinew.juejin.im/content_api/v1/short_msg/detail'; yield function () use ($client, $uri) { return $client->postAsync($uri, [ 'verify' => false, 'json' => [ 'msg_id' => '6845185452727599118' ] ]); }; } }; $pool = new Pool($client, $requests($this->totalPageCount), [ 'concurrency' => $this->threads, // 请求成功 'fulfilled' => function ($response, $index) use ($output) { $res = $response->getBody()->getContents(); $output->writeln($res); $output->writeln("正在执行第{$index}个·····"); if ($this->checkThreadIsEnd() == true) { $output->writeln("------------请求结束---------"); return false; } }, // 请求失败 'rejected' => function ($reason, $index) use ($output) { $output->writeln("执行失败，{$reason}"); }, ]); $promise = $pool->promise(); $promise->wait(); } /** * 检测任务是否结束 * @return bool */ private function checkThreadIsEnd() { if (self::$counter < $this->totalPageCount) { self::$counter++; return false; } else { return true; } } }

Copier après la connexion