File d'attente de messages de Swoole et Workerman et capacités de traitement collaboratif informatique en temps réel

Swoole et Workerman sont deux extensions PHP puissantes qui permettent une communication réseau hautes performances et un traitement simultané. Dans le développement réel, nous devons parfois combiner des files d'attente de messages avec l'informatique en temps réel pour obtenir des capacités de traitement collaboratif plus efficaces.

La file d'attente de messages est une technologie middleware courante utilisée pour mettre en œuvre une communication asynchrone et un traitement de données découplé. L'informatique en temps réel fait référence au calcul et au traitement en temps réel pendant la génération des données.

Dans cet article, nous utiliserons des exemples de code spécifiques pour présenter comment utiliser Swoole et Workerman pour obtenir des capacités de traitement collaboratif des files d'attente de messages et de calcul en temps réel.

Tout d'abord, nous devons installer et configurer les extensions Swoole et Workerman. Pour le processus d'installation spécifique, veuillez vous référer à la documentation officielle.

Ensuite, nous devons écrire un producteur et un consommateur de file d'attente de messages pour envoyer et recevoir des messages.

// 生产者
$producer = new SwooleCoroutineChannel();

SwooleCoroutine::create(function () use ($producer) {
    for ($i = 0; $i < 10; $i++) {
        $producer->push("Message $i");
        usleep(100000); // 模拟数据产生的延迟
    }
    $producer->close();
});

// 消费者
SwooleCoroutine::create(function () use ($producer) {
    while (true) {
        if ($producer->isEmpty()) {
            break;
        }
        $message = $producer->pop();
        echo "Received message: $message
";
        // 在这里进行实时计算和处理
    }
});

Dans le code ci-dessus, nous créons d'abord un objet Channel en tant que conteneur pour la file d'attente des messages. Ensuite, utilisez une boucle dans le producteur pour transmettre le message au canal et simulez le délai de génération de données via la fonction usleep. Ensuite, utilisez une boucle infinie dans le consommateur pour recevoir le message et effectuer les opérations correspondantes dans la partie calcul et traitement en temps réel.

De plus, nous pouvons également utiliser Workerman pour implémenter un traitement simultané multi-processus. Voici un exemple d'utilisation de Workerman :

$producer = new WorkermanWorker();
$producer->onWorkerStart = function () use ($producer, &$messageCount) {
    for ($i = 0; $i < 10; $i++) {
        $producer->queue->push("Message $i");
        usleep(100000); // 模拟数据产生的延迟
        $messageCount++;
    }
};

$producer->queue = new WorkermanChannel();

$consumer = new WorkermanWorker();
$consumer->onWorkerStart = function () use ($consumer) {
    while (true) {
        $message = $consumer->queue->pop();
        echo "Received message: $message
";
        // 在这里进行实时计算和处理
    }
};

WorkermanWorker::runAll();

Dans le code ci-dessus, nous créons d'abord deux objets Worker, un pour être producteur et un pour être consommateur. Dans la fonction de rappel onWorkerStart du producteur, nous poussons le message vers la file d'attente via la boucle et simulons le délai de génération des données via la fonction usleep. Ensuite, dans la fonction de rappel onWorkerStart du consommateur, nous recevons les messages de la file d'attente via une interrogation et effectuons le calcul et le traitement correspondants en temps réel.

Grâce aux exemples de code ci-dessus, nous pouvons voir comment utiliser Swoole et Workerman pour réaliser les capacités de traitement collaboratif des files d'attente de messages et de l'informatique en temps réel. De cette façon, nous pouvons obtenir une communication asynchrone efficace et un traitement simultané, offrant à nos applications plus de performances et de flexibilité.

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!