Cara menggunakan Redis untuk melaksanakan tugas berjadual teragih

Redis ialah sistem storan nilai kunci yang sangat baik yang mempunyai banyak kegunaan lain selain digunakan sebagai cache. Salah satunya adalah sebagai alat pelaksanaan untuk tugas berjadual yang diedarkan. Dalam artikel ini, kami akan memperkenalkan cara menggunakan Redis untuk melaksanakan tugas berjadual teragih dan menyediakan contoh kod yang sepadan.

Apakah tugas berjadual yang diedarkan?

Dalam persekitaran yang berdiri sendiri, kita boleh menggunakan tugas berjadual untuk menjalankan fungsi atau tugas tertentu dengan kerap. Dalam persekitaran yang diedarkan, setiap nod akan mempunyai tugas berjadual sendiri, dan masalah seperti pelaksanaan berulang dan pelaksanaan terlepas mungkin berlaku. Oleh itu, tugas berjadual yang diagihkan perlu mempertimbangkan isu seperti kebolehpercayaan pelaksanaan tugas, pengagihan tugas dan penyelarasan.

Redis sebagai alat pelaksanaan untuk tugas berjadual teragih

Redis menyediakan beberapa struktur data dan arahan yang boleh menyokong tugas berjadual teragih, seperti:

#🎜🎜 #

Set Diisih: Anda boleh mengisih mengikut skor dan merekodkan masa pelaksanaan tugas melalui markah. Perintah
• expire: Anda boleh menetapkan masa tamat tempoh untuk kunci tertentu.
• Skrip Lua: Berbilang arahan boleh dilaksanakan dalam operasi atom untuk memastikan atomicity dan kebolehpercayaan operasi.

Seterusnya, kami akan memperkenalkan cara menggunakan Redis untuk melaksanakan tugas berjadual teragih dan menyediakan contoh kod.

Langkah pelaksanaan

1 Simpan maklumat tugasan dalam Set Isih Redis

Pertama, kita perlu menyimpan maklumat tugasan dalam Isih. daripada Set Redis. Di sini, kita boleh mempunyai masa pelaksanaan tugasan (cap masa) sebagai skor dan ID tugasan sebagai ahli. Berikut ialah contoh kod:

import redis

# Connect to Redis
redis_conn = redis.Redis(host='localhost', port=6379, db=0)

# Add task to Sorted Set
task_id = "task_001"
execute_time = 1600000000  # timestamp (in seconds)
redis_conn.zadd("tasks", {task_id: execute_time})

Dalam kod di atas, kami melaksanakan tugas bernama task_001, dengan masa pelaksanaan 1600000000 (di sini Diwakili oleh cap masa, ia sebenarnya boleh dinyatakan dengan cara lain). Simpannya dalam Set Isih bernama tasks.

task_001的任务，执行时间为1600000000 （这里是用时间戳来表示的，实际上也可以使用其他方式来表示）。将它存入名为tasks的Sorted Set中。

2. 设置过期时间

为了避免过期任务一直存在Redis中占用空间，我们需要设置过期时间，并在过期后从Sorted Set中删除。下面是一个示例代码：

import time

# Check for expired tasks every 10 seconds
while True:
    # Get all tasks with score less than current time
    tasks = redis_conn.zrangebyscore("tasks", 0, int(time.time()))

    # Delete expired tasks
    for task in tasks:
        redis_conn.zrem("tasks", task)

以上代码中，我们每隔10秒检查一次过期任务并删除。为此，我们使用了zrangebyscore命令，获取分数在0（即当前时间） 至 time.time()（当前时间戳）之间的任务。在获取到任务后，我们使用了zrem命令，从Sorted set中删除任务。

3. 执行任务

在检查过期任务时，我们同时也要执行这些过期任务。下面是一个示例代码：

import uuid

# Consume tasks every 10 seconds
while True:
    # Get all tasks with score less than current time
    tasks = redis_conn.zrangebyscore("tasks", 0, int(time.time()))

    # Execute tasks
    for task in tasks:
        # Check if task is already being executed by another worker
        lock_id = redis_conn.get("lock_" + task)
        if lock_id is None:
            # Lock task using Lua script
            lock_id = str(uuid.uuid4())
            lua_script = """
                if redis.call("get", ARGV[1]) == false then
                    redis.call("set", ARGV[1], ARGV[2])
                    redis.call("expire", ARGV[1], 60)
                    return true
                else
                    return false
                end
            """
            if redis_conn.eval(lua_script, 0, "lock_" + task, lock_id) is True:
                # Execute task
                print("Executing task " + task)
                # task.execute()
                # ...

                # Remove task from Sorted Set and unlock
                redis_conn.zrem("tasks", task)
                redis_conn.delete("lock_" + task)

以上代码中，我们每隔10秒检查一次过期任务并执行。为此，我们使用了zrangebyscore命令，获取分数在0（即当前时间） 至 time.time()2. Tetapkan masa tamat tempoh

Untuk mengelakkan tugas yang telah tamat tempoh daripada sentiasa mengambil ruang dalam Redis, kita perlu menetapkan masa tamat tempoh dan memadamkannya daripada Set Diisih selepas tamat tempoh. Berikut ialah contoh kod:

rrreee

Dalam kod di atas, kami menyemak tugas tamat tempoh setiap 10 saat dan memadamkannya. Untuk melakukan ini, kami menggunakan perintah zrangebyscore untuk mendapatkan skor antara 0 (iaitu masa semasa) hingga time.time() (the cap masa semasa) antara tugas. Selepas mendapat tugasan, kami menggunakan perintah zrem untuk memadamkan tugasan daripada set Diisih.

#🎜🎜#3. Laksanakan tugasan #🎜🎜##🎜🎜#Apabila menyemak tugasan yang telah tamat tempoh, kita juga perlu melaksanakan tugasan yang telah tamat tempoh ini pada masa yang sama. Berikut ialah contoh kod: #🎜🎜#rrreee#🎜🎜#Dalam kod di atas, kami menyemak dan melaksanakan tugas yang telah tamat tempoh setiap 10 saat. Untuk melakukan ini, kami menggunakan perintah zrangebyscore untuk mendapatkan skor antara 0 (iaitu masa semasa) hingga time.time() (the cap masa semasa) antara tugas. Selepas mendapat tugasan, kami mula-mula menyemak sama ada tugasan sedang dilaksanakan oleh proses lain. Untuk mengelakkan berbilang proses melaksanakan tugas yang sama pada masa yang sama, kami menggunakan lock_id untuk mengenal pasti sama ada tugas itu telah dikunci. Jika tugas tidak dikunci, kami menggunakan skrip Lua untuk memperoleh kunci. Selepas memperoleh kunci, kami melakukan operasi tugasan yang sepadan, memadamkan tugasan daripada Set Diisih, dan akhirnya melepaskan kunci. #🎜🎜##🎜🎜#Ringkasan#🎜🎜##🎜🎜#Artikel ini memperkenalkan cara menggunakan Redis untuk melaksanakan tugas berjadual teragih dan menyediakan contoh kod yang sepadan. Dengan menggunakan fungsi Redis seperti Set Diisih, perintah tamat tempoh dan skrip Lua, kami boleh melaksanakan sistem tugas berjadual teragih yang sangat boleh dipercayai dan cekap. Sudah tentu, kod di atas masih perlu diperbaiki dan dioptimumkan untuk memenuhi keperluan dan senario yang berbeza. #🎜🎜#

Atas ialah kandungan terperinci Cara menggunakan Redis untuk melaksanakan tugas berjadual teragih. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!