Comment gérer la file d'attente de messages et le mécanisme de diffusion dans le développement d'API back-end PHP

Dans le développement d'API back-end PHP, la file d'attente des messages et le mécanisme de diffusion sont des moyens importants pour obtenir une interaction efficace des données et résoudre les problèmes de performances côté serveur. Cet article explique comment gérer les files d'attente de messages et les mécanismes de diffusion.

1. Qu'est-ce que la file d'attente des messages et le mécanisme de diffusion ?

La file d'attente des messages est un mécanisme de communication asynchrone qui alloue des tâches à la file d'attente pour traitement. Dans les API backend, les files d'attente de messages sont utilisées pour le découplage car elles peuvent séparer différentes tâches, améliorant ainsi les performances de l'application. Les files d'attente de messages ont de nombreuses utilisations, telles que le traitement asynchrone, qui permet aux applications de répondre rapidement après que les utilisateurs soumettent des demandes et effectuent le travail correspondant en arrière-plan ; et la planification des tâches, qui peut déclencher l'exécution d'une tâche à un moment donné ou lorsqu'un événement se produit.

Le mécanisme de diffusion est un mécanisme push actif implémenté côté serveur. Dans le mécanisme de diffusion, le serveur peut activement transmettre des données au client sans dépendre de la demande du client. Le mécanisme de diffusion fournit des capacités de communication instantanées à l'API et convient à l'envoi de messages push aux utilisateurs en ligne, à la mise à jour des données en temps réel, etc.

2. Développement et application d'une file d'attente de messages et d'un mécanisme de diffusion

1. File d'attente de messages

L'utilisation de la file d'attente de messages dans l'API peut traiter efficacement de grandes quantités de données ou de requêtes tout en améliorant l'efficacité du traitement, elle peut également aider les applications à économiser beaucoup de données. ressources. . Par exemple, vous pouvez utiliser la file d'attente des messages pour envoyer des e-mails. De cette façon, le programme n'a pas besoin d'attendre que l'e-mail soit envoyé. Vous pouvez directement ajouter les informations de l'e-mail à la file d'attente des messages et laisser le programme en arrière-plan les traiter. améliorant ainsi la vitesse de réponse et l'efficacité du traitement.

De plus, de nombreuses tâches de traitement dans l'application prennent du temps, telles que le téléchargement de fichiers volumineux, la compression d'images, la copie de données, etc. Ces tâches peuvent être traitées de manière asynchrone à l'aide de files d'attente de messages pour améliorer les performances et la vitesse de réponse du programme.

2. Mécanisme de diffusion

Le mécanisme de diffusion peut être utilisé pour envoyer des messages en temps réel aux utilisateurs en ligne, tels que l'envoi de messages dans les applications de chat en temps réel. Grâce au mécanisme de diffusion, le serveur peut transmettre des informations à tous les clients qui y sont connectés. Ce mécanisme convient également pour transmettre au client des messages en temps réel tels que des mises à jour de données, telles que des cotations boursières, etc.

Lorsque vous utilisez le mécanisme de diffusion, vous devez ajouter une interface de connexion au script client afin que le serveur puisse transmettre des informations sur les données au client. L'abonnement à l'interface et la réception de données peuvent être facilement mis en œuvre via JavaScript ou d'autres langages de programmation.

3. Application de la file d'attente de messages et du mécanisme de diffusion dans le développement PHP

1. Traitement de la file d'attente de messages

En PHP, vous pouvez utiliser la bibliothèque d'extension de file d'attente de messages pour implémenter le traitement asynchrone. Les files d'attente de messages couramment utilisées incluent RabbitMQ, Redis et ZeroMQ, etc., qui peuvent toutes être implémentées via l'extension de script d'excuse de PHP. Parmi eux, RabbitMQ est une file d'attente de messages très puissante avec des performances élevées, une grande capacité de traitement et la prise en charge de plusieurs langages de développement.

Ce qui suit est un exemple d'application RabbitMQ en PHP :

// Composer doit être installé require php-amqplib/php-amqplib

require_once DIR '/../vendor/. autoload.php ';

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

class Rabbitmq
{

private $connection;
private $channel;
private $exchange_name = 'your-exchange';
private $queue_name = 'your-queue';

public function __construct()
{
    // 连接 RabbitMQ
    $this->connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $this->channel = $this->connection->channel();
    $this->channel->exchange_declare($this->exchange_name, 'direct', false, true, false);
    list($this->queue_name, ,) = $this->channel->queue_declare($this->queue_name, false, true, false, false);

    // 绑定到队列
    $this->channel->queue_bind($this->queue_name, $this->exchange_name);
}

public function __destruct()
{
    // 关闭 RabbitMQ 连接
    $this->channel->close();
    $this->connection->close();
}

public function send($message)
{
    // 发送消息
    $msg = new AMQPMessage($message);
    $this->channel->basic_publish($msg, $this->exchange_name);
}

public function recv($callback)
{
    // 接收消息
    $this->channel->basic_consume($this->queue_name, '', false, true, false, false, $callback);
    while (count($this->channel->callbacks)) {
        $this->channel->wait();
    }
}

}

// Initialiser et utiliser
$mq = new Rabbitmq();
$mq-> envoyer( 'bonjour , world! ');
$mq->recv(function ($msg) {

echo "Received message: " . $msg->body . "

";
});

L'exemple ci-dessus montre comment utiliser l'extension RabbitMQ pour créer une file d'attente de messages. Une classe Rabbitmq est créée, dans la classe La file d'attente des messages est connectée dans le constructeur, et une file d'attente est créée et liée. La méthode send() est utilisée pour envoyer des messages à la file d'attente et la méthode recv() est utilisée pour recevoir des messages de la classe. file d'attente.

2. Mécanisme de diffusion. Traitement

En PHP, vous pouvez utiliser des frameworks pour implémenter des mécanismes de diffusion. Les frameworks PHP couramment utilisés incluent Laravel et Symfony, etc. Ces frameworks peuvent implémenter des mécanismes de diffusion via la prise en charge de WebSocket. est l'implémentation du mécanisme de diffusion dans Laravel. Exemple de code :

Définissez le pilote de diffusion correspondant dans app/Providers/BroadcastServiceProvider.php :

class BroadcastServiceProvider extends ServiceProvider

public function boot()
{

    Broadcast::routes(['middleware' => ['auth:api']]);
    Broadcast::channel('your-channel', function ($user) {
        return ['id' => $user->id, 'name' => $user->name];
    });

    // 使用Redis作为广播驱动
    Broadcast::extend('redis', function ($app, $config) {
        return new RedisBroadcaster($app['redis']);
    });

}

Définissez les tâches planifiées dans app/Console/. Kernel.php :

class Kernel extends ConsoleKernel

protected function schedule(Schedule $schedule)
{
    $schedule->call(function () {
        broadcast(new YourEvent());
    })->everyMinute();
}

Définissez l'événement de diffusion dans app/Events/YourEvent.php :

class YourEvent implémente ShouldBroadcast

use Dispatchable, InteractsWithSockets, SerializesModels;

/**
 * Create a new event instance.
 *
 * @return void
 */
public function __construct()
{
    //
}

/**
 * Get the channels the event should broadcast on.
 *
 * @return IlluminateBroadcastingChannel|array
 */
public function broadcastOn()
{
    return new PrivateChannel('your-channel');
}

Dans l'exemple ci-dessus, nous utilisons la diffusion du framework Laravel Le mécanisme implémente la diffusion et utilise Redis comme pilote de diffusion. En définissant des pilotes et des événements, vous pouvez envoyer des messages aux utilisateurs en ligne

En plus de Laravel, Symfony fournit également un support pour le mécanisme de diffusion, et son utilisation est similaire à Symfony, vous pouvez utiliser Mercure comme serveur WebSocket, prenant en charge les protocoles HTTP/2 et les événements envoyés par le serveur.

4. Résumé

La file d'attente des messages et le mécanisme de diffusion ont un large éventail de scénarios d'application dans le développement d'API back-end PHP, qui peuvent améliorer efficacement les performances et la vitesse de réponse des applications. Lorsque vous utilisez ces deux mécanismes, vous devez choisir en fonction des besoins réels et choisir la file d'attente et le cadre de développement appropriés. Dans le même temps, il faut veiller à garantir la stabilité et la fiabilité du programme pendant le processus de développement.

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!