Utilisation de PHP-Resque

Utilisation de PHP-Resque

PHP-Resque est la bibliothèque d'extensions de PHP pour Resque, qui permet à PHP d'utiliser également Resque Resque est un arrière-plan. système de processus développé sur la base de Redis Par rapport à d'autres systèmes de file d'attente, la conception de Resque est très simple et utilise pleinement les caractéristiques de Redis.

1. Installez php-resque

Entrez dans le répertoire racine du projet, composer install php-resque

composer require chrisboulton/php-resque

2. Méthodes courantes

1. Connectez-vous à redis

// setBackend($server, $database = 0)
Resque::setBackend('127.0.0.1:6379');

2 Ajouter du travail à la file d'attente

// enqueue($queue, $class, $args = null, $trackStatus = false)
$token = Resque::enqueue('default', 'My_Job', ['name'=>'test'], true);

3. 🎜>

$status = (new Resque_Job_Status($token))->get();

4. Arrêter (supprimer) le travail

(new Resque_Job_Status($token))->stop();

3. File d'attente de traitement des tâches résidentes (exemple : travailleur.php)

// 处理 default 队列；也可以填 *，代表所有队列
$worker = new Resque_Worker('default');
// LOG_NONE 不写日志, LOG_NORMAL 普通，LOG_VERBOSE 详细
$worker->logLevel = Resque_Worker::LOG_VERBOSE;
// 队列处理时间间隔，单位：秒
$worker->work(5);

Remarque : worker.php doit être exécuté via la ligne de commande et réside en arrière-plan, /usr/local/php/bin/php /xxx/xxx/worker.php

4. Cours pour le travail de traitement

class My_Job
{
    /**
     * 前置操作
     * @return void
     */
    public function setUp()
    {
        // ... Set up environment for this job
    }
    /**
     * 消费队列
     * @return void
     */
    public function perform()
    {
        // execute a job
    }
    /**
     * 后置操作
     * @return void
     */
    public function tearDown()
    {
        // ... Remove environment for this job
    }
}

Tutoriel recommandé : "

Tutoriel PHP"

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!