Utilisez Swoole pour encapsuler un client HTTP asynchrone hautement fiable

À mesure que les applications Web continuent d'évoluer, le besoin de clients HTTP devient de plus en plus important, en particulier lorsque les données sont demandées sur le réseau. Dans l'implémentation PHP traditionnelle, il est courant d'utiliser des bibliothèques telles que cURL pour effectuer des requêtes réseau, mais elle ne prend pas en charge les requêtes asynchrones, ce qui entraîne des limitations de performances lorsqu'un grand nombre de requêtes simultanées se produisent.

Swoole est un moteur de communication réseau coroutine basé sur PHP, qui fournit une méthode de requête asynchrone qui peut considérablement améliorer les performances des applications. Cet article explique comment utiliser Swoole pour encapsuler un client HTTP asynchrone hautement fiable.

Pourquoi utiliser le client HTTP asynchrone Swoole

Lors d'une demande simultanée, le client HTTP synchrone provoquera un goulot d'étranglement des performances, tandis que le client HTTP asynchrone peut gérer plusieurs requêtes en même temps dans un seul processus. Swoole fournit un modèle de coroutine pour implémenter des requêtes asynchrones sans changer de processus. Il peut également réduire l'utilisation de la mémoire et la surcharge de connexion TCP, et améliorer les performances des applications.

L'utilisation du client HTTP asynchrone Swoole présente également les avantages suivants :

• Fournit des fonctions de rappel d'événements riches, qui peuvent effectuer les opérations de traitement correspondantes lorsque la requête réussit ou échoue
• Traite automatiquement les en-têtes de requête, les en-têtes de réponse et les réponses des requêtes HTTP ; Contenu pratique à utiliser pour les développeurs ;
• Gestion intégrée du pool de connexions, qui peut gérer automatiquement les connexions TCP sous une concurrence élevée.

Écrire un client HTTP asynchrone

Avant de commencer à écrire un client HTTP asynchrone, vous devez installer l'extension Swoole et vous assurer que la version PHP est 7.0 ou supérieure. Pour installer l'extension, utilisez la commande suivante :

pecl install swoole

Ajoutez ensuite le contenu suivant dans le fichier de configuration PHP :

extension=swoole.so

Ensuite, nous pouvons commencer à écrire le code du client HTTP asynchrone. Tout d’abord, nous devons définir une classe HttpClient pour lancer des requêtes HTTP asynchrones. Le code spécifique est le suivant : HttpClient类，用于发起异步HTTP请求。具体代码如下：

class HttpClient
{
    private $client;

    public function __construct($host, $port = 80, $ssl = false)
    {
        $scheme = $ssl ? 'https://' : 'http://';
        $this->client = new SwooleCoroutineHttpClient($host, $port, $ssl);
        $this->client->setHeaders([
            'User-Agent' => 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3',
            'Accept' => 'text/html,application/xhtml+xml,application/xml',
            'Accept-Encoding' => 'gzip',
        ]);
    }

    public async function get($path, $params = [])
    {
        $path .= '?' . http_build_query($params);
        return $this->request('GET', $path);
    }

    public async function post($path, $params = [])
    {
        return $this->request('POST', $path, $params);
    }

    private async function request($method, $path, $params = [])
    {
        $this->client->setMethod($method);
        $this->client->setData($params);
        $this->client->execute($path);

        $statusCode = $this->client->statusCode;
        $body = $this->client->body;

        if ($statusCode !== 200) {
            throw new RuntimeException(sprintf('Request failed with status code %d', $statusCode));
        }

        return $body;
    }
}

在上面的代码中，我们通过__construct方法初始化一个Swoole的HttpClient对象。由于我们需要支持HTTP和HTTPS两种协议，所以我们需要判断URL的协议，然后设置对应的端口号和SSL选项。

然后我们通过get和post方法实现了异步的HTTP请求。在请求中，我们使用http_build_query函数将参数转为URL形式的字符串，并在URL中拼接参数。然后我们将请求方法和参数设置在$client对象中，最后调用$client->execute方法发起请求。

使用$client->execute方法发起请求，Swoole会自动协调请求和响应，并等待响应的到来。在响应到达后，我们可以获取响应的状态码和响应体，然后根据状态码来判断请求是否成功。

使用示例

为了演示如何使用上述的异步HTTP客户端，我们编写了一个简单的示例。代码如下：

$client = new HttpClient('httpbin.org');

go(function () use ($client) {
    $result = yield $client->get('/get', ['hello' => 'world']);
    var_dump($result);
});

go(function () use ($client) {
    $result = yield $client->post('/post', ['name' => 'Jack', 'age' => 29]);
    var_dump($result);
});

在上述代码中，我们首先初始化了一个HttpClient对象，并设置远程主机地址。然后我们通过go协程发起了两个异步请求，一个是GET请求，另一个是POST请求，分别带有参数['hello' => 'world']和['name' => 'Jack', 'age' => 29]。在每个异步请求完成后，我们通过var_dumprrreee

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!