Penjelasan terperinci tentang penjadualan tugas yang tertunda dalam Redis

Dengan pembangunan berterusan Internet dan teknologi pengkomputeran awan, penjadualan tugas yang tertunda menjadi semakin biasa dalam kerja pembangunan harian, seperti menghantar e-mel secara berkala, membuat sandaran pangkalan data dengan kerap dan sebagainya. Memandangkan kerumitan dan magnitud tugas terus meningkat, banyak kaedah penjadualan tradisional tidak lagi dapat memenuhi keperluan, jadi sistem penjadualan tugas tertangguh yang cekap dan boleh dipercayai diperlukan. Sebagai pangkalan data dalam memori berprestasi tinggi, Redis secara semula jadi menjadi alat yang berkuasa untuk melaksanakan penjadualan tugas yang tertangguh.

Artikel ini akan memperkenalkan secara terperinci langkah-langkah dan butiran teknikal yang berkaitan menggunakan Redis untuk melaksanakan penjadualan tugas yang tertunda.

1. Struktur data Redis

Sebelum memahami cara Redis melaksanakan penjadualan tugas tertunda, anda perlu memahami struktur data asasnya terlebih dahulu. Redis menyokong lima jenis data asas, iaitu rentetan, senarai, cincang, set dan zset. Antaranya, zset (set tersusun) ialah struktur data teras untuk melaksanakan penjadualan tugas tertunda.

zset ialah set tertib dalam Redis Setiap ahlinya mempunyai nilai skor yang boleh digunakan untuk mengisih. Dalam zset, setiap ahli mempunyai kunci unik dan skor yang sepadan. zset menyediakan operasi set yang sama seperti yang ditetapkan, dan juga menyokong mendapatkan ahli mengikut julat skor atau kedudukan.

2. Laksanakan penjadualan tugas tertunda

Idea teras untuk melaksanakan penjadualan tugas tertunda dalam Redis adalah untuk memasukkan tugasan yang akan dilaksanakan ke dalam zset dan menetapkan masa pelaksanaan tugas sebagai skor. Bahagian pelayan Redis menyediakan berbilang arahan untuk mengendalikan koleksi tersusun Arahan ini boleh melaksanakan penjadualan tugas tertunda dengan mudah.

1. Tambah tugasan

Gunakan perintah zadd untuk menambah tugasan pada zset dan tentukan masa pelaksanaan tugas sebagai markah. Jika tugasan sudah wujud, nilai skornya akan dikemas kini.

Contohnya: zadd delay_queue 1630509327 "task1"

Apabila masa kelewatan mencecah 1630509327, Redis akan mengalihkan tugasan "task1" secara automatik daripada set yang dipesan delay_queue dan meletakkannya di tempat lain untuk pemprosesan.

2. Dapatkan tugasan

Gunakan perintah zrange untuk mendapatkan ahli zset yang markahnya berada dalam julat tertentu.

Contohnya: zrange delay_queue 0 0

Arahan ini akan mengembalikan ahli dengan markah terkecil dalam set tertib delay_queue, yang merupakan tugas terawal.

3. Padam tugasan

Gunakan perintah zrem untuk memadamkan ahli zset.

Contohnya: zrem delay_queue "task1"

Arahan ini akan mengalih keluar tugas "task1" daripada set delay_queue yang dipesan.

4. Tugas mendengar

Gunakan perintah blpop untuk melaksanakan fungsi baris gilir menyekat Redis Perintah ini akan menyekat sehingga tugas itu dibatalkan.

Contohnya: blpop delay_queue 0

Arahan ini akan menyekat sehingga ahli set delay_queue yang dipesan dibatalkan.

3. Selesaikan pelaksanaan penjadualan tugas tertunda

Sekarang, mari lihat proses pelaksanaan lengkap penjadualan tugas tertunda Redis.

1. Memulakan sambungan Redis

Dalam Python, kita boleh menggunakan perpustakaan redis-py untuk menyambung ke Redis dan mengendalikan Redis.

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

2. Tambah tugas

Kita boleh menambah tugasan ke zset dengan cara berikut:

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

bermaksud menambah tugasan "task1" kepada "delay_queue" Dalam urutan yang ditetapkan, masa tunda ialah 1630509327.

3. Dapatkan tugasan

Kita boleh mendapatkan tugasan terawal dengan cara berikut:

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

mewakili mendapat markah terkecil dalam "delay_queue" yang dipesan ahli tetapkan, iaitu tugasan terawal, dan mengembalikan nilai kunci dan skor tugasan itu.

4. Laksanakan tugas

Kami boleh melakukan tindakan yang sepadan selepas tugasan tamat:

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占用率过高

Dalam kod di atas, kami menggunakan gelung sementara untuk secara berterusan Alih keluar tugasan terawal daripada zset Jika masa tugasan telah tamat, lakukan tindakan yang sepadan dan padamkan tugasan daripada zset.

4. Ringkasan

Artikel ini memperkenalkan cara menggunakan Redis untuk melaksanakan penjadualan tugas tertunda Melalui struktur data set tersusun dan berbilang arahan yang disediakan oleh Redis, anda boleh melaksanakan dengan mudah dan sistem penjadualan tugas tertunda yang boleh dipercayai. Sudah tentu, ini bukan satu-satunya kaedah pelaksanaan. Kaedah yang berbeza mungkin digunakan dalam senario yang berbeza dan perlu diselaraskan mengikut keperluan perniagaan sebenar.

Akhir sekali, perlu dinyatakan bahawa apabila volum tugasan adalah besar, menggunakan Redis untuk melaksanakan penjadualan tugas yang tertunda mungkin memberi beban yang besar kepada Redis, yang membawa kepada penurunan prestasi Redis. Oleh itu, dalam aplikasi sebenar, adalah perlu untuk memutuskan sama ada untuk menggunakan Redis untuk melaksanakan penjadualan tugas tertunda berdasarkan faktor seperti keperluan perniagaan khusus dan beban sistem.

Atas ialah kandungan terperinci Penjelasan terperinci tentang penjadualan tugas yang tertunda dalam Redis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!