在写后台代码时，避免不了需要与其他第三方接口交互，如向服务号下发模板消息，有时可能需要下发超过 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 请求获取自动回答内容，直接上代码：

1. <?php 
2.  
3. namespace App\Http\Controllers; 
4.  
5. use GuzzleHttp\Client; 
6.  
7. use Illuminate\Http\Request; 
8.  
9. class GuzzleUseController extends Controller { 
10.  
11.     public function tuling(Request $request) { 
12.  
13.         $params = [ 
14.  
15.             'key' => '*****', 
16.  
17.             'userid' => 'yemeishu' 
18.  
19.         ]; 
20.  
21.         $params['info'] = $request->input('info', '你好吗'); 
22.  
23.         $client = new Client(); 
24.  
25.         $options = json_encode($params, JSON_UNESCAPED_UNICODE); 
26.  
27.         $data = [ 
28.  
29.             'body' => $options, 
30.  
31.             'headers' => ['content-type' => 'application/json'] 
32.  
33.         ]; 
34.  
35.         // 发送 post 请求 
36.  
37.         $response = $client->post('http://www.tuling123.com/openapi/api', $data); 
38.  
39.         $callback = json_decode($response->getBody()->getContents()); 
40.  
41.         return $this->output_json('200', '测试图灵机器人返回结果', $callback); 
42.  
43.     } 
44.  
45. } 

Guzzle client->post 函数还是很简单的，只需要访问的接口，和请求的参数，参数中主要包含：body、headers、query等，具体可参考

http://guzzle-cn.readthedocs.io/zh_CN/latest/quickstart.html#id8

测试下：

注：图灵机器人还是很智能的，根据相同的 userid 能够识别上下文，做到智能聊天的。

发送异步的 POST 请求

在 PHP 开发中主要是「面向过程」式的开发方式，但请求第三方接口时，有时候并不需要等待第三方接口返回结果才继续执行。如用户购买成功时，我们需要向短信接口，发送一个 post 请求，由短信平台发送一条短信给用户，告知用户支付成功了，因为这类「提醒消息」属于「额外的附加功能」，并不需要在用户支付时「知道」有没有发送提醒成功。

这时候可以使用 Guzzle 的异步请求功能，直接看代码：

1. public function sms(Request $request) { 
2.  
3.     $code = $request->input('code'); 
4.  
5.     $client = new Client(); 
6.  
7.     $sid = '9815b4a2bb6d5******8bdb1828644f2'; 
8.  
9.     $time = '20171029173312'; 
10.  
11.     $token = 'af8728c8bc*******12019c680df4b11c'; 
12.  
13.  
14.  
15.     $sig =  strtoupper(md5($sid.$token.$time)); 
16.  
17.  
18.  
19.     $auth = trim(base64_encode($sid . ":" . $time)); 
20.  
21.  
22.  
23.     $params = ['templateSMS' => [ 
24.  
25.             'appId' => '12b43**********0091c73c0ab', 
26.  
27.             'param' => "coding01,$code,30", 
28.  
29.             'templateId' => '3***3', 
30.  
31.             'to' => '17689974321' 
32.  
33.         ] 
34.  
35.     ]; 
36.  
37.     $options = json_encode($params, JSON_UNESCAPED_UNICODE); 
38.  
39.     $data = [ 
40.  
41.         'query' => [ 
42.  
43.             'sig' => $sig 
44.  
45.         ], 
46.  
47.         'body' => $options, 
48.  
49.         'headers' => [ 
50.  
51.             'content-type' => 'application/json', 
52.  
53.             'Authorization' => $auth 
54.  
55.         ] 
56.  
57.     ]; 
58.  
59.  
60.  
61.     // 发送 post 请求 
62.  
63.     $promise = $client->requestAsync('POST', 'https://api.ucpaas.com/2014-06-30/Accounts/9815b4a2bb6d5******8bdb1828644f2/Messages/templateSMS', $data); 
64.  
65.  
66.  
67.     $promise->then( 
68.  
69.         function (ResponseInterface $res) { 
70.  
71.             Log::info('---'); 
72.  
73.             Log::info($res->getStatusCode() . "\n"); 
74.  
75.             Log::info($res->getBody()->getContents() . "\n"); 
76.  
77.         }, 
78.  
79.         function (RequestException $e) { 
80.  
81.             Log::info('-__-'); 
82.  
83.             Log::info($e->getMessage() . "\n"); 
84.  
85.         } 
86.  
87.     ); 
88.  
89.     $promise->wait(); 
90.  
91.  
92.  
93.     return $this->output_json('200', '测试短信 api', []); 
94.  
95. } 

先返回接口数据：

然后再输出 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 请求」在很多场合中使用到的，如：双十一快到了，可以做一些回馈老用户的活动，这是就需要批量的向老用户推送一条模板消息，告诉用户参与哪些活动的。这时候就需要用到多线程异步请求微信公众号接口。

直接上代码：

1. public function send($templateid, $openid, $url, $data) { 
2.  
3.         $client = $this->bnotice->getHttp()->getClient(); 
4.  
5.  
6.  
7.         $requests = function ($open_ids) use ($templateid, $url, $data) { 
8.  
9.             foreach($open_ids as $v){ 
10.  
11.                 try { 
12.  
13.                     yield $this->bnotice 
14.  
15.                         ->template($templateid) 
16.  
17.                         ->to($v) 
18.  
19.                         ->url($url) 
20.  
21.                         ->data($data) 
22.  
23.                         ->request(); 
24.  
25.                 } catch(Exception $e) { 
26.  
27.                     Log::error('sendtemplate:'.$e->getMessage()); 
28.  
29.                 } 
30.  
31.             } 
32.  
33.         }; 
34.  
35.  
36.  
37.         $pool = new Pool($client, $requests($openid), [ 
38.  
39.             'concurrency' => 16, 
40.  
41.             'fulfilled' => function ($response, $index) { 
42.  
43.             }, 
44.  
45.             'rejected' => function ($reason, $index) { 
46.  
47.             }, 
48.  
49.         ]); 
50.  
51.         $promise = $pool->promise(); 
52.  
53.  
54.  
55.         $promise->wait(); 
56.  
57.     } 

其中 request 方法：

1. public function request($data = []) 
2.  
3.     { 
4.  
5.         $params = array_merge([ 
6.  
7.             'touser' => '', 
8.  
9.             'template_id' => '', 
10.  
11.             'url' => '', 
12.  
13.             'topcolor' => '', 
14.  
15.             'miniprogram' => [], 
16.  
17.             'data' => [], 
18.  
19.         ], $data); 
20.  
21.           
22.  
23.         $required = ['touser', 'template_id']; 
24.  
25.  
26.  
27.         foreach ($params as $key => $value) { 
28.  
29.             if (in_array($key, $required, true) && emptyempty($value) && emptyempty($this->message[$key])) { 
30.  
31.                 throw new InvalidArgumentException("Attribute '$key' can not be empty!"); 
32.  
33.             } 
34.  
35.  
36.  
37.             $params[$key] = emptyempty($value) ? $this->message[$key] : $value; 
38.  
39.         } 
40.  
41.  
42.  
43.         $params['data'] = $this->formatData($params['data']); 
44.  
45.  
46.  
47.         $this->message = $this->messageBackup; 
48.  
49.  
50.  
51.         $options = json_encode ( $params,  JSON_UNESCAPED_UNICODE); 
52.  
53.         $data = [ 
54.  
55.             'query' => [ 
56.  
57.                 'access_token' => $this->getAccessToken()->getToken() 
58.  
59.             ], 
60.  
61.             'body' => $options, 
62.  
63.             'headers' => ['content-type' => 'application/json'] 
64.  
65.         ]; 
66.  
67.         return function() use ($data) { 
68.  
69.             return $this->getHttp()->getClient()->requestAsync('POST', $this::API_SEND_NOTICE, $data); 
70.  
71.         }; 
72.  
73.     } 

Guzzle 多线程异步请求原型函数，使用 GuzzleHttp\Pool 对象

1. use GuzzleHttp\Pool;use GuzzleHttp\Client;use GuzzleHttp\Psr7\Request;$client = new Client();$requests = function ($total) { 
2.  
3.     $uri = 'http://127.0.0.1:8126/guzzle-server/perf'; 
4.  
5.     for ($i = 0; $i < $total; $i++) { 
6.  
7.         yield new Request('GET', $uri); 
8.  
9.     }};$pool = new Pool($client, $requests(100), [ 
10.  
11.     'concurrency' => 5, 
12.  
13.     'fulfilled' => function ($response, $index) { 
14.  
15.         // this is delivered each successful response 
16.  
17.     }, 
18.  
19.     'rejected' => function ($reason, $index) { 
20.  
21.         // this is delivered each failed request 
22.  
23.     },]);// Initiate the transfers and create a promise$promise = $pool->promise();// Force the pool of requests to complete.$promise->wait(); 

总结：有了 Guzzle，极大方便了我们并发异步请求第三方接口，如果时间允许，我们可以看看 Guzzle 源代码，看看是如何实现的。

Tags: PHP网络请求插件 Guzzle

分享到：