Comment utiliser des coroutines pour implémenter la fonction swoole_sntp à haute concurrence dans Swoole

Swoole est un framework de coroutines PHP hautes performances avec des fonctionnalités telles que des coroutines, des E/S asynchrones, des performances élevées et une concurrence élevée. Il est très approprié pour développer des services réseau. Parmi elles, la fonction swoole_sntp est utilisée pour synchroniser l'heure du serveur et peut jouer un rôle très important dans le développement. Dans cet article, nous présenterons comment utiliser les coroutines pour implémenter la fonction swoole_sntp à haute concurrence dans Swoole.

Introduction à Swoole_sntp

La fonction Swoole_sntp est une fonction du framework Swoole qui synchronise l'heure du serveur. Elle peut envoyer une requête de protocole NTP à un serveur de temps réseau spécifié, puis obtenir les informations horaires du serveur. Sa fonction est définie comme suit :

bool swoole_sntp(string $server, float $timeout = 1.0, float $offset = null);

Parmi eux, le paramètre $server est l'adresse du serveur de temps spécifié, le paramètre $timeout est le délai d'attente et le paramètre $offset est le décalage horaire entre l'heure locale et l'heure réseau, ce qui n'a pas besoin d'être précisé.

Utilisation de coroutines

Lors de l'utilisation de la fonction Swoole_sntp, il est souvent nécessaire de demander des informations temporelles à plusieurs serveurs de temps, et la demande doit être complétée dans un certain laps de temps. Dans ce cas, l’utilisation de coroutines peut atteindre une concurrence élevée et améliorer la vitesse des requêtes.

Les coroutines sont des threads légers qui peuvent exécuter plusieurs tâches simultanément dans le même processus, évitant ainsi la perte de performances causée par le changement de contexte multithread. Dans Swoole, les coroutines peuvent être utilisées pour implémenter des requêtes simultanées vers plusieurs serveurs de temps.

Ce qui suit est un exemple de code pour utiliser des coroutines pour implémenter la fonction swoole_sntp à haute concurrence :

<?php

use SwooleCoroutine;

function sntp($server, $timeout = 1.0, $offset = null)
{
    $cli = new CoroutineHttpClient($server, 80);
    $cli->setDefer();

    $cli->execute('/');

    if ($cli->statusCode !== 200) {
        return false;
    }

    $response = $cli->body;

    $ts = unpack('N12', substr($response, 0, 48));
    $ts = round(($ts[9] * 1.0) + ($ts[10] * 1.0 / 4294967296.0) - 2208988800.0);

    $cli->close();

    return $ts;
}

$serverList = ['cn.pool.ntp.org', 'tw.pool.ntp.org', 'jp.pool.ntp.org'];

$sntp = function ($server) {
    $cli = new CoroutineHttpClient($server, 80);
    $cli->setDefer();

    $cli->execute('/');

    if ($cli->statusCode !== 200) {
        return false;
    }

    $response = $cli->body;

    $ts = unpack('N12', substr($response, 0, 48));
    $ts = round(($ts[9] * 1.0) + ($ts[10] * 1.0 / 4294967296.0) - 2208988800.0);

    $cli->close();

    return $ts;
};

$results = [];
foreach ($serverList as $server) {
    Coroutine::create(function () use ($server, &$results, $sntp) {
        $results[$server] = $sntp($server);
    });
}

while (count($results) < count($serverList)) {
    Coroutine::sleep(0.1);
}

print_r($results);

Dans le code ci-dessus, une fonction nommée sntp est d'abord définie pour demander au serveur de temps et renvoyer des informations de temps. Ensuite, une fonction anonyme nommée $sntp est définie, qui est également utilisée pour demander au serveur de temps et renvoyer des informations temporelles. Dans la boucle, utilisez Coroutine::create pour créer une nouvelle coroutine, utilisez la fonction $sntp pour demander le serveur de temps et enregistrez les résultats dans le tableau $results. Enfin, utilisez une boucle while pour attendre que toutes les coroutines se terminent et génèrent toutes les informations temporelles.

Résumé

Grâce à l'introduction ci-dessus, vous devriez avoir une compréhension préliminaire de la façon d'utiliser les coroutines pour implémenter la fonction swoole_sntp hautement concurrente dans Swoole. Les coroutines sont une fonctionnalité très importante du framework Swoole. Elles peuvent améliorer considérablement les performances et la concurrence des services réseau et méritent une étude et une pratique approfondies de la part des développeurs.

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!