Pratique de développement Swoole : comment optimiser la consommation de ressources des requêtes simultanées

Swoole est une bibliothèque de communication réseau hautes performances basée sur PHP pour développer des applications réseau asynchrones et simultanées. En raison de ses caractéristiques de haute performance, Swoole est devenue l'une des technologies préférées de nombreuses sociétés Internet. Dans le développement actuel, comment optimiser la consommation de ressources des requêtes simultanées est devenu un défi auquel de nombreux ingénieurs doivent faire face. Ce qui suit sera combiné avec des exemples de code pour présenter comment utiliser Swoole pour optimiser la consommation de ressources des requêtes simultanées.

1. Utilisez des coroutines pour améliorer la concurrence

Swoole fournit des coroutines puissantes qui peuvent facilement implémenter une programmation asynchrone. La soi-disant coroutine fait référence à une méthode de programmation multitâche qui enregistre l'état actuel d'une tâche dans le programme lorsqu'elle est exécutée sur un nœud intermédiaire, passe à une autre tâche à exécuter, puis revient à la tâche d'origine pour continuer l'exécution. une fois l'autre tâche terminée. Par rapport aux pools de threads, les coroutines peuvent éviter un grand nombre de changements de contexte et améliorer considérablement l'efficacité du traitement simultané.

Ce qui suit est un exemple simple pour simuler des requêtes simultanées vers 10 interfaces API et stocker les résultats dans un tableau :

<?php
$client = new SwooleCoroutineClient(SWOOLE_TCP);
$client->connect('127.0.0.1', 9501);

$tasks = [];
for ($i = 0; $i < 10; $i++) {
    $data = [
        'id' => $i + 1,
        'name' => 'Task ' . ($i + 1),
        'uri' => '/api/test',
    ];
    $tasks[] = json_encode($data);
}

foreach ($tasks as $data) {
    $client->send($data);
    $response = $client->recv();
    var_dump(json_decode($response, true));
}

$client->close();

Dans le code ci-dessus, nous utilisons la classe SwooleCoroutineClient fournie par Swoole pour simuler des requêtes simultanées. Nous créons d’abord un tableau $tasks pour stocker les informations d’interface à demander. Ensuite, pour chaque tâche, nous utilisons $client pour envoyer la requête et attendons que le serveur réponde. Lorsque toutes les demandes sont terminées, le client ferme la connexion.

2. Utilisez le client MySQL asynchrone pour améliorer les performances des opérations de base de données

Swoole fournit également un client MySQL asynchrone, qui peut facilement implémenter des opérations de base de données asynchrones. Par rapport aux méthodes traditionnelles d'opération de base de données synchrone, les opérations de base de données asynchrones peuvent considérablement améliorer les performances des opérations de base de données.

Voici un exemple simple pour montrer comment interroger la base de données de manière asynchrone lors de l'utilisation du client MySQL asynchrone Swoole :

<?php
$client = new SwooleMySQL;

$client->connect([
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'root',
    'password' => '',
    'database' => 'test',
], function($client) {
    $client->query('SELECT * FROM `user` WHERE `id` > 1', function($client, $result) {
        var_dump($result);
        $client->close();
    });
});

Dans le code ci-dessus, nous utilisons la classe SwooleMySQL fournie par Swoole pour interroger la base de données de manière asynchrone. Nous utilisons d’abord la méthode connect() pour nous connecter à la base de données, puis utilisons la méthode query() pour interroger la base de données de manière asynchrone. Lorsque la requête est terminée, nous utilisons var_dump() pour imprimer les résultats de la requête et fermer la connexion à la base de données.

3. Utilisez le mécanisme Task Worker fourni par Swoole pour le traitement des tâches asynchrones

Swoole fournit également le mécanisme Task Worker pour exécuter des tâches asynchrones. Le mécanisme Task Worker peut très facilement réaliser la distribution et l'exécution des tâches. En particulier dans les scénarios qui nécessitent une grande quantité de calculs ou d'opérations d'E/S, le mécanisme Task Worker peut considérablement améliorer les performances des applications.

Voici un exemple simple pour montrer comment exécuter des tâches de manière asynchrone lors de l'utilisation du mécanisme Task Worker de Swoole :

<?php
$server = new SwooleServer('127.0.0.1', 9501);
$server->set([
    'worker_num' => 2,
    'task_worker_num' => 2,
]);

$server->on('start', function($server) {
    echo "Swoole server is started at http://127.0.0.1:9501
";
});

$server->on('receive', function($server, $fd, $from_id, $data) {
    $task_id = $server->task($data);
    echo "New task #{$task_id} is dispatched
";
});

$server->on('task', function($server, $task_id, $from_id, $data) {
    echo "Task #{$task_id} is started
";
    sleep(1);
    echo "Task #{$task_id} is finished
";
    $server->finish("Task #{$task_id} is done");
});

$server->on('finish', function($server, $task_id, $data) {
    echo "Task #{$task_id} is done: {$data}
";
});

$server->start();

Dans le code ci-dessus, nous créons d'abord un serveur Swoole et définissons le travailleur en utilisant la méthode set() et le nombre de tâches. ouvriers. Ensuite, nous avons défini la fonction de rappel pour traiter la demande. Lors de la réception de la demande du client, nous utilisons la méthode task() pour laisser Swoole transmettre la demande au travailleur chargé de la tâche pour traitement. Le travailleur de la tâche exécutera la tâche de manière asynchrone et appellera la fonction de rappel finish() une fois terminée. Dans la fonction de rappel qui exécute la tâche, nous utilisons echo pour imprimer l'état de la tâche et sleep() pour simuler le temps nécessaire à l'exécution de la tâche.

Conclusion :

Swoole est un ensemble d'outils très puissant qui peut grandement optimiser les performances et la concurrence des applications PHP. En utilisant les fonctionnalités fournies par Swoole telles que les coroutines, les clients MySQL asynchrones et les mécanismes Task Worker, nous pouvons facilement optimiser la consommation des ressources pour les demandes simultanées et améliorer les performances et la fiabilité des applications.

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!