PHP网络请求插件Guzzle使用

概述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 请求获取自动回答内容，直接上代码：

<?PHPnamespace 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' => '',            'top@R_403_6004@' => '',            '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教程》 总结

以上是内存溢出为你收集整理的PHP网络请求插件Guzzle使用全部内容，希望文章能够帮你解决PHP网络请求插件Guzzle使用所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。