说明 guzzle库是一套强大的 php http 请求套件。
本文重点演示如何使用 guzzle 发起多线程请求。
参考 github 官方用户接口文档 guzzle 并发请求文档 laravel lts 5.1 - artisan 文档 创建命令 1. 运行命令行创建命令 php artisan make:console multithreadingrequest --command=test:multithreading-request
2. 注册命令 编辑 app/console/kernel.php,在 $commands 数组中增加:
commands\multithreadingrequest::class,
3. 测试下命令 修改 app/console/commands/multithreadingrequest.php文件,在 handle方法中增加:
$this->info('hello');
输出:
$ php artisan test:multithreading-requesthello
4. 安装 guzzle composer require guzzlehttp/guzzle 6.2
直接贴代码 一份可运行的代码胜过千言万语呀。
下面代码是 app/console/commands/multithreadingrequest.php里的内容:
totalpagecount = count($this->users); $client = new client(); $requests = function ($total) use ($client) { foreach ($this->users as $key => $user) { $uri = 'https://api.github.com/users/' . $user; yield function() use ($client, $uri) { return $client->getasync($uri); }; } }; $pool = new pool($client, $requests($this->totalpagecount), [ 'concurrency' => $this->concurrency, 'fulfilled' => function ($response, $index){ $res = json_decode($response->getbody()->getcontents()); $this->info(请求第 $index 个请求,用户 . $this->users[$index] . 的 github id 为: .$res->id); $this->countedandcheckended(); }, 'rejected' => function ($reason, $index){ $this->error(rejected ); $this->error(rejected reason: . $reason ); $this->countedandcheckended(); }, ]); // 开始发送请求 $promise = $pool->promise(); $promise->wait(); } public function countedandcheckended() { if ($this->counter totalpagecount){ $this->counter++; return; } $this->info(请求结束!); }}
运行结果:
$ php artisan test:multithreading-request请求第 5 个请求,用户 zhengjinghua 的 github id 为:3413430请求第 6 个请求,用户 nauxliu 的 github id 为:9570112请求第 0 个请求,用户 cycloneaxe 的 github id 为:6268176请求第 1 个请求,用户 appleboy 的 github id 为:21979请求第 2 个请求,用户 aufree 的 github id 为:5310542请求第 3 个请求,用户 lifesign 的 github id 为:2189610请求第 4 个请求,用户 overtrue 的 github id 为:1472352请求结束!
注意请求是同时发送过去的,因为 concurrency并发设置了 7,所以 7 个请求同时发送,只不过接收到返回的时间点不一样。
完。
:beers: :beers: :beers: