首頁  >  文章  >  後端開發  >  PHP網路請求插件Guzzle使用

PHP網路請求插件Guzzle使用

Guanhui
Guanhui轉載
2020-05-01 09:40:575875瀏覽

在寫後台程式碼時,避免不了需要與其他第三方介面交互,如向服務號下發範本訊息,有時可能需要下發超過 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 = [
            &#39;key&#39; => &#39;*****&#39;,
            &#39;userid&#39; => &#39;yemeishu&#39;
        ];
        $params[&#39;info&#39;] = $request->input(&#39;info&#39;, &#39;你好吗&#39;);
        $client = new Client();
        $options = json_encode($params, JSON_UNESCAPED_UNICODE);
        $data = [
            &#39;body&#39; => $options,
            &#39;headers&#39; => [&#39;content-type&#39; => &#39;application/json&#39;]
        ];
        // 发送 post 请求
        $response = $client->post(&#39;http://www.tuling123.com/openapi/api&#39;, $data);
        $callback = json_decode($response->getBody()->getContents());
        return $this->output_json(&#39;200&#39;, &#39;测试图灵机器人返回结果&#39;, $callback);
    }
}

Guzzle client->post 函數還是很簡單的,只需要存取的接口,和請求的參數,參數中主要包含:body、headers、query等,具體可參考

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

測試下:

PHP網路請求插件Guzzle使用

PHP網路請求插件Guzzle使用

#:圖靈機器人還是很聰明的,根據相同的userid 能夠辨識上下文,做到智慧聊天的。

發送非同步的POST 請求

在PHP 開發中主要是「過程導向」式的開發方式,但請求第三方介面時,有時並不需要等待第三方介面回傳結果才繼續執行。如用戶購買成功時,我們需要向短信接口,發送一個post 請求,由短信平台發送一條短信給用戶,告知用戶支付成功了,因為這類“提醒消息”屬於“額外的附加功能”,並不需要在用戶付款時「知道」有沒有發送提醒成功。

這時候可以使用Guzzle 的非同步請求功能,直接看程式碼:

public function sms(Request $request) {
    $code = $request->input(&#39;code&#39;);
    $client = new Client();
    $sid = &#39;9815b4a2bb6d5******8bdb1828644f2&#39;;
    $time = &#39;20171029173312&#39;;
    $token = &#39;af8728c8bc*******12019c680df4b11c&#39;;

    $sig =  strtoupper(md5($sid.$token.$time));

    $auth = trim(base64_encode($sid . ":" . $time));

    $params = [&#39;templateSMS&#39; => [
            &#39;appId&#39; => &#39;12b43**********0091c73c0ab&#39;,
            &#39;param&#39; => "coding01,$code,30",
            &#39;templateId&#39; => &#39;3***3&#39;,
            &#39;to&#39; => &#39;17689974321&#39;
        ]
    ];
    $options = json_encode($params, JSON_UNESCAPED_UNICODE);
    $data = [
        &#39;query&#39; => [
            &#39;sig&#39; => $sig
        ],
        &#39;body&#39; => $options,
        &#39;headers&#39; => [
            &#39;content-type&#39; => &#39;application/json&#39;,
            &#39;Authorization&#39; => $auth
        ]
    ];

    // 发送 post 请求
    $promise = $client->requestAsync(&#39;POST&#39;, &#39;https://api.ucpaas.com/2014-06-30/Accounts/9815b4a2bb6d5******8bdb1828644f2/Messages/templateSMS&#39;, $data);

    $promise->then(
        function (ResponseInterface $res) {
            Log::info(&#39;---&#39;);
            Log::info($res->getStatusCode() . "\n");
            Log::info($res->getBody()->getContents() . "\n");
        },
        function (RequestException $e) {
            Log::info(&#39;-__-&#39;);
            Log::info($e->getMessage() . "\n");
        }
    );
    $promise->wait();

    return $this->output_json(&#39;200&#39;, &#39;测试短信 api&#39;, []);
}

先回傳介面資料:

PHP網路請求插件Guzzle使用

##然後再輸出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"}}}

最後收到簡訊訊息:

PHP網路請求插件Guzzle使用

#發送多執行緒非同步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(&#39;sendtemplate:&#39;.$e->getMessage());
                }
            }
        };

        $pool = new Pool($client, $requests($openid), [
            &#39;concurrency&#39; => 16,
            &#39;fulfilled&#39; => function ($response, $index) {
            },
            &#39;rejected&#39; => function ($reason, $index) {
            },
        ]);

        $promise = $pool->promise();

        $promise->wait();
    }

其中request 方法:

public function request($data = [])
    {
        $params = array_merge([
            &#39;touser&#39; => &#39;&#39;,
            &#39;template_id&#39; => &#39;&#39;,
            &#39;url&#39; => &#39;&#39;,
            &#39;topcolor&#39; => &#39;&#39;,
            &#39;miniprogram&#39; => [],
            &#39;data&#39; => [],
        ], $data);
        
        $required = [&#39;touser&#39;, &#39;template_id&#39;];

        foreach ($params as $key => $value) {
            if (in_array($key, $required, true) && empty($value) && empty($this->message[$key])) {
                throw new InvalidArgumentException("Attribute &#39;$key&#39; can not be empty!");
            }

            $params[$key] = empty($value) ? $this->message[$key] : $value;
        }

        $params[&#39;data&#39;] = $this->formatData($params[&#39;data&#39;]);

        $this->message = $this->messageBackup;

        $options = json_encode ( $params,  JSON_UNESCAPED_UNICODE);
        $data = [
            &#39;query&#39; => [
                &#39;access_token&#39; => $this->getAccessToken()->getToken()
            ],
            &#39;body&#39; => $options,
            &#39;headers&#39; => [&#39;content-type&#39; => &#39;application/json&#39;]
        ];
        return function() use ($data) {
            return $this->getHttp()->getClient()->requestAsync(&#39;POST&#39;, $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 = &#39;http://127.0.0.1:8126/guzzle-server/perf&#39;;
    for ($i = 0; $i < $total; $i++) {
        yield new Request(&#39;GET&#39;, $uri);
    }};$pool = new Pool($client, $requests(100), [
    &#39;concurrency&#39; => 5,
    &#39;fulfilled&#39; => function ($response, $index) {
        // this is delivered each successful response
    },
    &#39;rejected&#39; => 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中文網其他相關文章!

陳述:
本文轉載於:jianshu.com。如有侵權,請聯絡admin@php.cn刪除