Explication détaillée de la planification des tâches retardée dans Redis

Avec le développement continu de la technologie Internet et du cloud computing, la planification différée des tâches devient de plus en plus courante dans le travail de développement quotidien, comme l'envoi régulier d'e-mails, la sauvegarde régulière des bases de données, etc. À mesure que la complexité et l’ampleur des tâches continuent d’augmenter, de nombreuses méthodes de planification traditionnelles ne peuvent plus répondre aux besoins. Un système de planification des tâches différées efficace et fiable est donc nécessaire. En tant que base de données en mémoire hautes performances, Redis est naturellement devenue un outil puissant pour mettre en œuvre une planification différée des tâches.

Cet article présentera en détail les étapes et les détails techniques associés à l'utilisation de Redis pour implémenter la planification différée des tâches.

1. Structure des données de Redis

Avant de comprendre comment Redis implémente la planification différée des tâches, vous devez d'abord comprendre sa structure de données de base. Redis prend en charge cinq types de données de base, à savoir chaîne, liste, hachage, set et zset. Parmi eux, zset (ensemble ordonné) est la structure de données de base pour la mise en œuvre de la planification différée des tâches.

zset est un ensemble ordonné dans Redis. Chaque membre a une valeur de score qui peut être utilisée pour le tri. Dans zset, chaque membre a une clé unique et un score correspondant. zset fournit les mêmes opérations d'ensemble que set et prend également en charge l'obtention de membres en fonction de la plage de scores ou du classement.

2. Implémenter la planification différée des tâches

L'idée principale de la mise en œuvre de la planification différée des tâches dans Redis est d'insérer les tâches à exécuter dans zset et de définir le temps d'exécution de la tâche comme score. Le côté serveur de Redis fournit plusieurs commandes pour exécuter des collections ordonnées. Ces commandes peuvent facilement implémenter une planification de tâches retardée.

1. Ajouter des tâches

Utilisez la commande zadd pour ajouter des tâches à zset et spécifiez le temps d'exécution de la tâche comme score. Si la tâche existe déjà, sa valeur de score sera mise à jour.

Par exemple : zadd delay_queue 1630509327 "task1"

Lorsque le temps de retard atteint 1630509327, Redis déplacera automatiquement la tâche "task1" hors de l'ensemble ordonné delay_queue et la placera ailleurs pour traitement.

2. Obtenir des tâches

Utilisez la commande zrange pour obtenir les membres de zset dont le score se situe dans une certaine plage.

Par exemple : zrange delay_queue 0 0

Cette commande renverra le membre avec le plus petit score dans l'ensemble ordonné delay_queue, qui est la première tâche.

3. Supprimer la tâche

Utilisez la commande zrem pour supprimer un membre du zset.

Par exemple : zrem delay_queue "task1"

Cette commande supprimera la tâche "task1" de l'ensemble ordonné delay_queue.

4. Tâches d'écoute

L'utilisation de la commande blpop peut implémenter la fonction de file d'attente de blocage de Redis. Cette commande bloquera jusqu'à ce que la tâche soit retirée de la file d'attente.

Par exemple : blpop delay_queue 0

Cette commande bloquera jusqu'à ce qu'un membre de l'ensemble ordonné delay_queue soit retiré de la file d'attente.

3. Implémentation complète de la planification différée des tâches

Examinons maintenant un processus complet de mise en œuvre de la planification différée des tâches Redis.

1. Initialiser la connexion Redis

En Python, nous pouvons utiliser la bibliothèque redis-py pour nous connecter à Redis et faire fonctionner Redis.

import redis
r = redis.Redis(host='localhost', port=6379, db=0)

2. Ajouter des tâches

Nous pouvons ajouter des tâches à zset de la manière suivante :

r.zadd('delay_queue', {'task1': 1630509327})

représente l'ajout de la tâche "task1" à l'ensemble ordonné "delay_queue", et le temps de retard est de 1630509327.

3. Obtenir la tâche

Nous pouvons obtenir la première tâche de la manière suivante :

task = r.zrange('delay_queue', 0, 0, withscores=True)

représente l'obtention du membre avec le plus petit score dans l'ensemble ordonné "delay_queue", c'est-à-dire la première tâche, et renvoie la clé et la valeur du score de la tâche.

4. Exécuter des tâches

Nous pouvons effectuer les actions correspondantes après l'expiration de la tâche :

def do_task(task_key):
    # do your task here
    print('do task', task_key)

# 监听任务
while True:
    task = r.zrange('delay_queue', 0, 0, withscores=True)
    if task:
        task_key, score = task[0]
        # 如果任务时间到了，则执行任务
        if score <= time.time():
            r.zrem('delay_queue', task_key) # 删除已完成的任务
            do_task(task_key) # 执行任务
    time.sleep(0.1) # 避免CPU占用率过高

Dans le code ci-dessus, nous utilisons une boucle while pour supprimer continuellement la première tâche de zset. Si l'heure de la tâche est arrivée, effectuez la tâche. action appropriée et supprimez la tâche de zset.

IV.Résumé

Cet article présente comment utiliser Redis pour implémenter la planification de tâches différées. Grâce à la structure de données d'ensemble ordonné de zset et aux multiples commandes fournies par Redis, un système de planification de tâches différées efficace et fiable peut être facilement mis en œuvre. Bien entendu, ce n’est pas la seule méthode de mise en œuvre. Différentes méthodes peuvent être utilisées dans différents scénarios et doivent être ajustées en fonction des besoins réels de l’entreprise.

Enfin, il convient de mentionner que lorsque le volume de tâches est important, l'utilisation de Redis pour implémenter une planification différée des tâches peut imposer une lourde charge à Redis, entraînant une diminution des performances de Redis. Par conséquent, dans les applications réelles, il est nécessaire de décider s'il convient d'utiliser Redis pour mettre en œuvre une planification différée des tâches en fonction de facteurs tels que les exigences spécifiques de l'entreprise et la charge du système.

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!