Dalam artikel ini, kami akan memperkenalkan kaedah pengagihan tugas teragih Redis dan menunjukkannya dengan contoh aplikasi. Tujuan artikel ini adalah untuk membantu pembaca lebih memahami dan menggunakan kelebihan Redis dalam sistem teragih.
Dalam Redis, kita boleh menggunakan mekanisme pub/sub (terbit/langgan) yang disediakannya untuk mencapai pengagihan tugas. Kaedah pelaksanaan khusus adalah seperti berikut:
2.1 Tambah tugasan pada baris gilir
Kita boleh menambah tugasan baharu pada baris gilir melalui arahan LPUSH Redis. Contohnya:
LPUSH task_queue "task1"
2.2 Terbitkan tugasan
Selepas menambah tugas pada baris gilir, kami boleh menerbitkan maklumat tugasan melalui perintah PUBLISH Redis dan lulus saluran untuk menyiarkan maklumat ini ke nod lain. Contohnya:
TERBITKAN saluran_tugas "task1 tersedia"
2.3 Tugasan langganan
Dalam nod, kami boleh melanggan maklumat saluran melalui arahan LANGGAN Redis. Dengan cara ini, sebaik sahaja tugasan baharu diterbitkan ke saluran, pelanggan boleh mendapatkannya tepat pada masanya dan mula melaksanakan tugas itu. Contohnya:
SUBSCRIBE task_channel
Kami mula-mula melaksanakan kod untuk tugasan penerbitan (penerbit) melalui bahasa Python:
import redis redis_client = redis.Redis(host='localhost', port=6379, db=0) task_queue = ['task1', 'task2', 'task3', 'task4', 'task5'] for task in task_queue: redis_client.lpush('task_queue', task) redis_client.publish('task_channel', f'{task} is added to task_queue.')
Dalam kod ini, kami menambah 5 tugasan pada baris gilir melalui arahan LPUSH Redis , dan menerbitkan maklumat tugas ke saluran melalui arahan PUBLISH.
Seterusnya, kami menggunakan bahasa Python untuk melaksanakan kod untuk tugas langganan (pelanggan):
import redis import time redis_client = redis.Redis(host='localhost', port=6379, db=0) task_channel = redis_client.pubsub() task_channel.subscribe('task_channel') while True: for task in task_channel.listen(): if task['type'] == 'message': task_info = task['data'] print(f'Received new task: {task_info}') task_name = str(task_info).split(''')[1] print(f'Starting to process task: {task_name}') time.sleep(2) redis_client.unsubscribe('task_channel')
Dalam kod ini, kami melanggan saluran melalui arahan LANGGAN Redis dan mendengar cara maklumat saluran untuk mendapatkan tugasan terkini. Setiap kali pelanggan mendapat tugasan baharu, ia akan mula melaksanakan tugas itu.
Untuk mensimulasikan masa pemprosesan tugasan dalam situasi sebenar, kami menambah kaedah time.sleep() apabila memproses tugasan Setiap pemprosesan tugasan mengambil masa 2 saat.
Akhir sekali, kami menjalankan kod pelanggan dan tidak lama selepas dijalankan, kod penerbit mula menambah tugasan pada baris gilir dan menghantarnya ke saluran.
Sudah tentu, kaedah pengagihan tugas yang diedarkan Redis tidak mahakuasa. Dalam aplikasi praktikal, kita juga perlu memilih penyelesaian pengagihan tugas teragih yang sesuai berdasarkan keperluan sebenar dan struktur sistem.
Atas ialah kandungan terperinci Kaedah Redis dan contoh aplikasi untuk melaksanakan pengagihan tugas teragih. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!