Рекомендовать плагин сетевых запросов PHP Guzzle

При написании фонового кода неизбежно взаимодействие с другими сторонними интерфейсами, например, отправка шаблонных сообщений в учетные записи служб, а иногда может потребоваться отправить более 100 000 сообщений. На этом этапе вы должны рассмотреть возможность использования асинхронных и «многопоточных» сетевых запросов.

Порекомендуйте плагин Guzzle разработчикам PHP уже сегодня.

Guzzle

Guzzle — это HTTP-клиент PHP для простой отправки запросов и интеграции с нашими веб-сервисами.

Интерфейс прост: создавайте операторы запроса, POST-запросы, разгружайте загрузку и загрузку больших файлов, используйте файлы cookie HTTP, загружайте данные JSON и т. д.

Для отправки синхронных или асинхронных запросов используется один и тот же интерфейс.

Используйте интерфейс PSR-7 для запросов, ответов и разгрузки, что позволяет вам совместно разрабатывать с Guzzle, используя другие совместимые библиотеки PSR-7.

Абстрагирует базовый HTTP-транспорт, позволяя вам изменять среду и другой код, такой как потоки или сокеты cURL и PHP, не сильно зависимые, неблокирующий цикл событий.

Система промежуточного программного обеспечения позволяет вам создавать поведение, которое составляет клиент.

Из введения официального сайта Guzzle:
guzzle-talent.read the doc S.IO/this_cn/latshan…

Установить жрать

В этой статье представлены основы использования Guzzle в сочетании с проектом Laravel, поэтому использование composer для установки Guzzle более подходит, а официальный сайт Guzzle также рекомендует использовать composer для установки.

composer require guzzlehttp/guzzle:~6.0

// 或者

php composer.phar require guzzlehttp/guzzle:~6.0

Как установить Composer, смотрите мою предыдущую статью
Потяните Ravel-China.org/docs/5.5/in…

Отправьте простой 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 по-прежнему очень проста. Ей нужен только доступ к интерфейсу и параметры запроса. Параметры в основном включают в себя: тело, заголовки, запрос и т. д. Подробнее см.

guzzle-talent.read the doc S.IO/this_cn/latshan…

Тестируется:

Примечание: робот Turing по-прежнему очень умен, он может распознавать контекст в соответствии с тем же идентификатором пользователя и вести интеллектуальный чат.

Отправить асинхронный запрос 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"}}}

Последнее полученное текстовое сообщение:

Отправить многопоточный асинхронный запрос POST

«Отправить многопоточный асинхронный запрос POST» используется во многих случаях, например: Double Eleven скоро появится, вы можете выполнить некоторые действия, чтобы вернуть старым пользователям, это отправить шаблонное сообщение старым пользователям в пакетах, сообщая пользователи участвовать в каких мероприятиях. В настоящее время вам необходимо использовать интерфейс общедоступной учетной записи 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);
        };
    }

Функция прототипа многопоточного асинхронного запроса 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, чтобы увидеть, как он реализован.