百木园在写后台代码时，避免不了需要与其他第三方接口交互，如向服务号下发模板消息，有时可能需要下发超过 10 万条。这时不得不考虑使用异步和「多线程」的网络请求。
今天向 php 工程师们推荐一个 Guzzle 插件。
Guzzle
Guzzle 是一个 PHP 的 HTTP 客户端，用来轻而易举地发送请求，并集成到我们的 WEB 服务上。
接口简单：构建查询语句、POST 请求、分流上传下载大文件、使用 HTTP cookies、上传 JSON 数据等等。
发送同步或异步的请求均使用相同的接口。
使用 PSR-7 接口来请求、响应、分流，允许你使用其他兼容的 PSR-7 类库与 Guzzle 共同开发。
抽象了底层的 HTTP 传输，允许你改变环境以及其他的代码，如：对 cURL与 PHP 的流或 socket 并非重度依赖，非阻塞事件循环。
中间件系统允许你创建构成客户端行为。
安装 Guzzle
本文结合 Laravel 项目介绍 Guzzle 基本使用，所以使用 composer 来安装 Guzzle 再适合不过了，而且 Guzzle 官网也推荐使用 composer 来安装。
composer require guzzlehttp/guzzle:~6.0 // 或者 php composer.phar require guzzlehttp/guzzle:~6.0
发送简单的 POST 请求
访问第三方接口，基本上都是 POST 请求为主。如你想做一个简单的智能聊天工具，这时候可以借助图灵机器人 API，发送一个 POST 请求获取自动回答内容，直接上代码：
ntroller extends Controller {
public function tuling(Request $request) {
$params = [
\'key\' => \'*****\',
\'userid\' => \'yemeishu\'
];
$params[\'info\'] = $request->input(\'info\', \'你好吗\');
$client = new Client();
$options = json_encode($params, JSON_UNESCAPED_UNICODE);
$data = [
\'body\' => $options,
\'headers\' => [\'content-type\' => \'application/json\']
];
// 发送 post 请求
$response = $client->post(\'http://www.tuling123.com/openapi/api\', $data);
$callback = json_decode($response->getBody()->getContents());
return $this->output_json(\'200\', \'测试图灵机器人返回结果\', $callback);
}
}
Guzzle client->post 函数还是很简单的，只需要访问的接口，和请求的参数，参数中主要包含：body、headers、query等，具体可参考
http://guzzle-cn.readthedocs.io/zh_CN/latest/quickstart.html#id8
测试下：
注：图灵机器人还是很智能的，根据相同的 userid 能够识别上下文，做到智能聊天的。
发送异步的 POST 请求
在 PHP 开发中主要是「面向过程」式的开发方式，但请求第三方接口时，有时候并不需要等待第三方接口返回结果才继续执行。如用户购买成功时，我们需要向短信接口，发送一个 post 请求，由短信平台发送一条短信给用户，告知用户支付成功了，因为这类「提醒消息」属于「额外的附加功能」，并不需要在用户支付时「知道」有没有发送提醒成功。
这时候可以使用 Guzzle 的异步请求功能，直接看代码：
public function sms(Request $request) {
$code = $request->input(\'code\');
$client = new Client();
$sid = \'9815b4a2bb6d5******8bdb1828644f2\';
$time = \'20171029173312\';
$token = \'af8728c8bc*******12019c680df4b11c\';
$sig = strtoupper(md5($sid.$token.$time));
$auth = trim(base64_encode($sid . \":\" . $time));
$params = [\'templateSMS\' => [
\'appId\' => \'12b43**********0091c73c0ab\',
\'param\' => \"coding01,$code,30\",
\'templateId\' => \'3***3\',
\'to\' => \'17689974321\'
]
];
$options = json_encode($params, JSON_UNESCAPED_UNICODE);
$data = [
\'query\' => [
\'sig\' => $sig
],
\'body\' => $options,
\'headers\' => [
\'content-type\' => \'application/json\',
\'Authorization\' => $auth
]
];
// 发送 post 请求
$promise = $client->requestAsync(\'POST\', \'https://api.ucpaas.com/2014-06-30/Accounts/9815b4a2bb6d5******8bdb1828644f2/Messages/templateSMS\', $data);
$promise->then(
function (ResponseInterface $res) {
Log::info(\'---\');
Log::info($res->getStatusCode() . \"n\");
Log::info($res->getBody()->getContents() . \"n\");
},
function (RequestException $e) {
Log::info(\'-__-\');
Log::info($e->getMessage() . \"n\");
}
);
$promise->wait();
return $this->output_json(\'200\', \'测试短信 api\', []);
}
先返回接口数据：
然后再输出 Log：
[2017-10-29 09:53:14] local.INFO: ---
[2017-10-29 09:53:14] local.INFO: 200
[2017-10-29 09:53:14] local.INFO: {\"resp\":{\"respCode\":\"000000\",\"templateSMS\":{\"createDate\":\"20171029175314\",\"smsId\":\"24a93f323c9*****8608568\"}}}
最后收到短信信息：
发送多线程异步 POST 请求
「发送多线程异步 POST 请求」在很多场合中使用到的，如：双十一快到了，可以做一些回馈老用户的活动，这是就需要批量的向老用户推送一条模板消息，告诉用户参与哪些活动的。这时候就需要用到多线程异步请求微信公众号接口。
直接上代码：
public function send($templateid, $openid, $url, $data) {
$client = $this->bnotice->getHttp()->getClient();
$requests = function ($open_ids) use ($templateid, $url, $data) {
foreach($open_ids as $v){
try {
yield $this->bnotice
->template($templateid)
->to($v)
->url($url)
->data($data)
->request();
} catch(Exception $e) {
Log::error(\'sendtemplate:\'.$e->getMessage());
}
}
};
$pool = new Pool($client, $requests($openid), [
\'concurrency\' => 16,
\'fulfilled\' => function ($response, $index) {
},
\'rejected\' => function ($reason, $index) {
},
]);
$promise = $pool->promise();
$promise->wait();
}
其中 request 方法：
public function request($data = [])
{
$params = array_merge([
\'touser\' => \'\',
\'template_id\' => \'\',
\'url\' => \'\',
\'topcolor\' => \'\',
\'miniprogram\' => [],
\'data\' => [],
], $data);
$required = [\'touser\', \'template_id\'];
foreach ($params as $key => $value) {
if (in_array($key, $required, true) && empty($value) && empty($this->message[$key])) {
throw new InvalidArgumentException(\"Attribute \'$key\' can not be empty!\");
}
$params[$key] = empty($value) ? $this->message[$key] : $value;
}
$params[\'data\'] = $this->formatData($params[\'data\']);
$this->message = $this->messageBackup;
$options = json_encode ( $params, JSON_UNESCAPED_UNICODE);
$data = [
\'query\' => [
\'access_token\' => $this->getAccessToken()->getToken()
],
\'body\' => $options,
\'headers\' => [\'content-type\' => \'application/json\']
];
return function() use ($data) {
return $this->getHttp()->getClient()->requestAsync(\'POST\', $this::API_SEND_NOTICE, $data);
};
}
Guzzle 多线程异步请求原型函数，使用 GuzzleHttpPool 对象
use GuzzleHttpPool;use GuzzleHttpClient;use GuzzleHttpPsr7Request;$client = new Client();$requests = function ($total) {
$uri = \'http://127.0.0.1:8126/guzzle-server/perf\';
for ($i = 0; $i < $total; $i++) {
yield new Request(\'GET\', $uri);
}};$pool = new Pool($client, $requests(100), [
\'concurrency\' => 5,
\'fulfilled\' => function ($response, $index) {
// this is delivered each successful response
},
\'rejected\' => function ($reason, $index) {
// this is delivered each failed request
},]);// Initiate the transfers and create a promise$promise = $pool->promise();// Force the pool of requests to complete.$promise->wait();
总结
有了 Guzzle，极大方便了我们并发异步请求第三方接口。如果时间允许，我们可以看看 Guzzle 源代码，看看是如何实现的。
推荐教程：《PHP教程》
以上就是PHP网络请求插件Guzzle使用的详细内容，更多请关注考高分网其它相关文章！
来源：https://blog.csdn.net/luo2424348224/article/details/123176481
本站部分图文来源于网络，如有侵权请联系删除。