guzzle php,PHP网络请求插件Guzzle使用
在写后台代码时,避免不了需要与其他第三方接口交互,如向服务号下发模板消息,有时可能需要下发超过 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 请求获取自动回答内容,直接上代码:<?php
namespace App\Http\Controllers;
use GuzzleHttp\Client;
use Illuminate\Http\Request;
class GuzzleUseController 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 多线程异步请求原型函数,使用 GuzzleHttp\Pool 对象use GuzzleHttp\Pool;use GuzzleHttp\Client;use GuzzleHttp\Psr7\Request;$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教程》
guzzle php,PHP网络请求插件Guzzle使用相关推荐
- PHP guzzle异步请求数据,Guzzle中的异步请求
Guzzle中的异步请求 使用Guzzle发起异步请求 Guzzle是一个PHP的HTTP客户端,它在发起http请求时不仅可以同步发起,还可以异步发起. $client = new Client() ...
- dio拦截器 flutter_详解flutter之网络请求dio,请求,拦截器简单示例
flutter一直很火的网络请求插件dio 直接上代码,写成一个类,可以直接使用 包含请求的封装,拦截器的封装 import 'package:dio/dio.dart'; import 'dart: ...
- RTSP安防网络摄像头/海康大华硬盘录像机/NVR网页无插件低延时播放流媒体服务器EasyNVR页面显示网络请求失败问题
进入移动互联网时代以来,企业微信公众号已成为除官网以外非常重要的宣传渠道,当3.2亿直播用户与9亿微信用户的势能累加,在微信上开启直播已成为越来越多企业的必然选择. 青犀团队研发的EasyNVR核心在 ...
- vue-day3计算属性、监听器、过滤器、混入、插件、生命周期、网络请求、组件
计算属性 模板中放入太多的逻辑会让模板过重且难以维护,使用计算属性可以让模板变得简洁易于维护.计算属性是基于它们的响应式依赖进行缓存的,计算属性比较适合对多个变量或者对象进行处理后返回一个结果值,也就 ...
- fundebug php,用Fundebug插件记录网络请求异常的方法
在服务端,不管我们使用Node.js.Java.PHP还是Python等等,都会用日志以文本的形式记录请求以及报错信息.这个对于后端做事后分析是很有用的. 另一方面,前端有时候出问题其实是因为后端接口 ...
- 用Fundebug插件记录网络请求异常
在服务端,不管我们使用Node.js.Java.PHP还是Python等等,都会用日志以文本的形式记录请求以及报错信息.这个对于后端做事后分析是很有用的. 另一方面,前端有时候出问题其实是因为后端接口 ...
- Flutter开发之——网络请求-JsonToDart插件解析,AnyChat音视频互动开发平台
在创建文件的位置,右键:New->JsonToDart 将Json结果填入文本框中,输入类名,点击Generate生成此类 三 旧类替换并显示 3.1 代码 Future futureArtic ...
- Flutter开发之HTTP网络请求:dio库(28)
dio是Flutter中文网开源的一个强大的Dart Http请求库,支持Restful API.FormData.拦截器.请求取消.Cookie管理.文件上传/下载.超时等- 第三方库 dio实现g ...
- Flutter开发之HTTP网络请求:Http库(27)
第三方库 http实现get,post网络请求. http库文档地址:https://pub.dev/packages/http#-installing-tab- 添加依赖库 Add this to ...
- uni-app——一种通过Nginx反向代理处理302重定向请求解决网络请求中无法获取Cookie的解决方案
问题描述 小程序中不会自动保存和发送Cookie 使用插件(https://uniapp.dcloud.io/api/request/request)方法不能解决302重定向情况下获取Cookie 小 ...
最新文章
- Python-OpenCV——亮度和对比度
- 如何设计一个短URL地址系统
- win2003无法进入桌面_救急,如何通过命令行备份桌面重要文件?
- vue如何在末尾添加_怎样在Linux上开发vue项目
- MORAN文本识别算法开源,刷新多个OCR数据集state-of-the-art
- STM32F103:三.(1)步进电机
- oracle 在 Linux下安装环境配置
- MATLAB基础数组操作及循环语句语法简介
- 190415每日一句
- 可视化软件有哪些?各自的优缺点?
- 1958年第一台电子计算机,第一台电子计算机
- odd ratio置信区间的计算,你学会了吗?
- C++并发编程之线程异步std::packaged_task知识点总结
- 使用POI读取EXCEL模板并填充数据,上传至腾讯云储存桶
- SWFAddress实现Flex深度链接(不同模块具有不同的URL)
- 金融专业本科生毕业论文选题推荐?
- 搜索框(SearchView)详解
- 树莓派3b连接GPS+BD模块并用python获取数据(串口版)
- 2014 年第六届全国大学生数学竞赛江西赛区赣南师范学院获奖名单(数学专业)
- 【杂项】JZ2440挂载NFS网络文件系统
热门文章
- D3D学习笔记1-D3D9设备的初始化
- 看板(Kanban)方法简介
- xshell下载步骤
- 近两年最流行的面试题
- echarts散点图使用(转:http://www.suchso.com/UIweb/echarts-sandiantu.html)
- 交替性注意力_如何培养共同注意力(Joint Attention)——社会性发展基石
- 中棉所建议国家扶持棉花产业
- TI的单芯片毫米波雷达传感器配置命令是如何传递到DSP和ARM核的?(串口程序代码走读)
- 网络文化经营许可证和icp许可证的区别
- wps转ppt怎么转换?通过这些方法学会wps如何转换成ppt