バックグラウンド コードを記述するときは、サービス アカウントにテンプレート メッセージを送信するなど、他のサードパーティ インターフェイスと対話することが避けられません。場合によっては、100,000 を超えるメッセージを送信する必要がある場合があります。現時点では、非同期および「マルチスレッド」ネットワーク要求の使用を検討する必要があります。
今日は、PHP エンジニアに Guzzle プラグインをお勧めします。
Guzzle
Guzzle は PHP 用の HTTP クライアントで、リクエストを簡単に送信し、Web サービスに統合するために使用されます。
インターフェイスはシンプルです: クエリ ステートメントの構築、POST リクエスト、大きなファイルの分割アップロードとダウンロード、HTTP Cookie の使用、JSON データのアップロードなど。
同期リクエストまたは非同期リクエストの送信には、同じインターフェイスが使用されます。
PSR-7 インターフェイスを使用してリクエスト、応答、オフロードを行うと、他の互換性のある PSR-7 クラス ライブラリを使用して Guzzle と一緒に開発できるようになります。
基盤となる HTTP トランスポートを抽象化し、cURL および PHP ストリームまたはソケットに大きく依存しない、ノンブロッキング イベント ループなど、環境やその他のコードを変更できるようにします。
ミドルウェア システムを使用すると、クライアント側の動作を作成できます。
Guzzle のインストール
この記事では、Laravel プロジェクトを組み合わせて Guzzle の基本的な使用法を紹介します。そのため、Guzzle と Guzzle 公式 Web サイトをインストールするには、composer を使用するのが最適です。また、composer を使用してインストールすることをお勧めします。
composer require guzzlehttp/guzzle:~6.0 // 或者 php composer.phar require guzzlehttp/guzzle:~6.0
単純な POST リクエストを送信する
サードパーティのインターフェイスにアクセスします。基本的には POST リクエストがメインです。シンプルでインテリジェントなチャット ツールを作成したい場合は、Turing Robot 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 functionはい、アクセス インターフェイスとリクエスト パラメータのみが必要です。パラメータには主に本文、ヘッダー、クエリなどが含まれます。詳細については、
http://guzzle- を参照してください。 cn.readthedocs.io/zh_CN /latest/quickstart.html#id8
テスト:
注: Turing ロボットは依然として非常に賢く、同じユーザー ID に基づいてコンテキストを識別し、インテリジェントなチャットを実現します。
非同期 POST リクエストを送信する
PHP 開発では主に「プロセス指向」の開発手法ですが、サードパーティのインターフェイスをリクエストする場合実行を続行する前に、サードパーティのインターフェイスが結果を返すのを待つ必要はありません。たとえば、ユーザーの購入が成功した場合、SMS インターフェイスに投稿リクエストを送信する必要があります。SMS プラットフォームはユーザーにテキスト メッセージを送信して、支払いが成功したことをユーザーに通知します。 「メッセージ」は「追加の追加機能」であり、必須ではありません。ユーザーが支払いを行うときに、リマインダーが正常に送信されたかどうかが「わかります」。
現時点では、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', []);
}最初にインターフェイス データを返します:
その後、ログを出力します:
[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"}}}最後に受信した SMS メッセージ:
マルチスレッドの非同期 POST リクエストを送信します
「「マルチスレッド非同期 POST リクエストの送信」は多くの場面で使用されます。例: ダブル イレブンが近日開催されます。古いユーザーに恩返しするためにいくつかのアクティビティを実行できます。これには、テンプレート メッセージを古いユーザーにバッチ プッシュする必要があります。ユーザーはどのアクティビティに参加するかを伝えることができます。現時点では、マルチスレッドの非同期リクエスト WeChat 公式アカウント インターフェイスを使用する必要があります。
コードに直接移動します:
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();
}リクエスト メソッド:
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);
};
}GuzzleHttp\Pool オブジェクトを使用した Guzzle マルチスレッド非同期リクエスト プロトタイプ関数
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 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
