Comment effectuer des opérations de file d'attente de messages dans ThinkPHP6 ?

Avec le développement d'Internet, les scénarios d'application deviennent de plus en plus complexes, et les exigences de performances sont de plus en plus élevées. Message Queue est une méthode de communication asynchrone typique qui peut améliorer les performances et la stabilité du programme dans des scénarios à forte concurrence. Dans le langage PHP, le framework ThinkPHP6 fournit également une prise en charge de la file d'attente de messages. Cet article présentera brièvement comment effectuer des opérations de file d'attente de messages dans ThinkPHP6.

1. Configuration de l'environnement

Tout d'abord, avant d'utiliser la file d'attente des messages, vous devez installer le composant ou le serveur de la file d'attente des messages. Ici, nous utilisons RabbitMQ comme serveur de file d'attente de messages. Pour installer RabbitMQ, vous pouvez vous référer à la documentation officielle ou à d'autres ressources en ligne.

Deuxièmement, dans ThinkPHP6, vous pouvez installer le composant de file d'attente de messages officiellement fourni via composer : think-amqp. Vous pouvez utiliser la commande suivante dans le terminal pour installer :

composer require topthink/think-amqp

2. Fichier de configuration

Après avoir installé le composant, vous devez amqp dans le répertoire de configuration. Effectuez les configurations pertinentes dans le fichier php. Exemple :

<?php
return [
    'default' => [
        'host'          => '127.0.0.1',
        'port'          => 5672,
        'vhost'         => '/',
        'login'         => 'guest',
        'password'      => 'guest',
        // 是否自动开启通道，默认为true
        'auto_declare'  => true,
        // 队列列表
        'queue_list'    => [
            'default'   => [
                'queue_name'    => 'default',
            ],
        ],
        // 交换机列表
        'exchange_list' => [
            'default'   => [
                'exchange_name' => 'default',
                // 默认使用direct交换机类型，也可以使用其他类型
                'exchange_type' => 'direct',
            ],
        ],
        // 绑定列表
        'bind_list'     => [
            'default'   => [
                'queue_name'    => 'default',
                'exchange_name' => 'default',
            ],
        ],
    ],
];

Dans le fichier de configuration ci-dessus, « par défaut » est le nom de la connexion et le tableau contient les informations de connexion, la liste de files d'attente, la liste de commutateurs et la liste de liaisons. Dans la liste de files d'attente et la liste de commutateurs, vous pouvez définir plusieurs files d'attente et commutateurs ainsi que leurs configurations associées. Dans la liste de liaisons, vous pouvez définir la relation de liaison entre la file d'attente et le commutateur.

Remarque : Lorsque vous utilisez des noms de file d'attente, des noms de commutateur et des noms de liaison, vous devez vous assurer de leur unicité.

3. Envoyer un message

Vous pouvez utiliser la méthode producteur dans la classe AMQP pour envoyer un message, exemple :

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function index()
    {
        $config = config('amqp.default');
        $exchange_name = 'default';
        $routing_key = 'default';
        $message = "hello world";
        $producer = AMQP::instance($config)->producer($exchange_name, $routing_key);
        $producer->publish($message);
        echo "send message success";
    }
}

#🎜 🎜#Le code ci-dessus, $config est les informations de connexion « par défaut » dans le fichier de configuration ci-dessus, $exchange_name est le nom du commutateur, $routing_key est la clé de routage et $message est le contenu du message.

Recevoir un message

Vous devez utiliser la méthode consumer et la méthode consumer dans la classe AMQP, exemple :

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function queue()
    {
        $config = config('amqp.default');
        $queue_name = 'default';
        $callback = function ($envelope, $queue) {
            $msg = $envelope->getBody();
            echo $msg."
";
            $queue->ack($envelope->getDeliveryTag());
        };
        $consumer = AMQP::instance($config)->consumer($queue_name);
        $consumer->consume($callback);
    }
}

#🎜 🎜 #Dans le code ci-dessus, $config est les informations de connexion « par défaut » dans le fichier de configuration ci-dessus, $queue_name est le nom de la file d'attente et $callback est la fonction de rappel. Dans la fonction de rappel, obtenez d'abord le contenu du message, puis exécutez la méthode ack pour indiquer que le message a été consommé.

Summary

5. Ce qui précède est un exemple simple d'utilisation de la file d'attente de messages dans ThinkPHP6. Grâce à l'utilisation de files d'attente de messages, les programmes peuvent être découplés et les performances et la stabilité du système peuvent être améliorées. Pour plus de types de files d'attente, de mécanismes de confirmation de message et de solutions de cluster, vous pouvez vous référer à la documentation officielle pour apprendre et comprendre.

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!