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.
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 menyediakan beberapa struktur data dan arahan yang boleh menyokong tugas berjadual teragih, seperti:
#🎜🎜 #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})
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中。
为了避免过期任务一直存在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中删除任务。
在检查过期任务时,我们同时也要执行这些过期任务。下面是一个示例代码:
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
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.
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!