Analisis ringkas tentang cara menggunakan baris gilir mesej dalam Redis

Artikel ini akan membawa anda melalui penggunaan lanjutan Redis - baris gilir mesej, dan memperkenalkan baris gilir kelewatan dalam Redis, saya harap ia akan membantu anda!

Bercakap tentang perisian tengah baris gilir mesej, kita semua memikirkan RabbitMQ, RocketMQ dan Kafka untuk melaksanakan fungsi pemesejan tak segerak untuk aplikasi. Ini ialah perisian tengah baris gilir mesej khusus dengan lebih banyak ciri daripada yang kita boleh fahami.

Penggunaan perisian tengah mesej ini adalah rumit, seperti RabbitMQ Sebelum menghantar mesej, anda perlu membuat Exchange dan Queue, dan kemudian mengikat Exchange dan Queue melalui beberapa peraturan juga perlu merumuskan kunci penghalaan dan mesej pengepala kawalan. Ini hanya untuk pengeluar. Pengguna juga perlu melalui siri langkah-langkah rumit di atas sekali lagi sebelum menggunakan mesej.

Jadi bagi mereka yang tidak memerlukan 100% kebolehpercayaan dan ingin melaksanakan keperluan baris gilir mesej yang mudah, kami boleh menggunakan Redis untuk membebaskan kami daripada langkah rumit perisian tengah baris gilir mesej.

Baris gilir mesej Redis bukan baris gilir mesej profesional Ia tidak mempunyai banyak ciri lanjutan dalam baris gilir mesej, dan juga tidak mempunyai jaminan ack. Jika anda mempunyai usaha terbaik untuk kebolehpercayaan mesej, sila beralih kepada perisian tengah MQ profesional. [Cadangan berkaitan: Tutorial Video Redis]

Baris Gilir Mesej Asynchronous

Bermula daripada baris gilir mesej tak segerak yang paling mudah, struktur data senarai Redis biasanya digunakan Sebagai baris gilir mesej tak segerak, lrpush/lpush digunakan untuk beratur, dan rpop/lpop digunakan untuk dequeue.

Masalah 1: Baris kosong

Untuk operasi pop, apabila baris gilir mesej kosong, pelanggan akan jatuh ke dalam The infinite loop of pop menyebabkan banyak pengundian terbiar yang membazirkan nyawa, menyebabkan CPU pelanggan meningkat, dan pada masa yang sama, QPS Redis juga meningkat.

Penyelesaian kepada masalah di atas ialah menggunakan blpop/brpop struktur senarai untuk menyah gilir, di mana awalan b mewakili menyekat, menyekat bacaan. Untuk menyekat bacaan, ia akan memasuki keadaan tidur apabila tiada data dalam baris gilir, dan akan bangun sebaik sahaja data tiba. Selesaikan masalah di atas dengan sempurna.

Masalah 2: Sambungan melahu diputuskan

Penyelesaian bacaan menyekat kelihatan sempurna, tetapi ia serta-merta membawa kepada masalah lain: sambungan melahu. Jika benang terus menyekat di suatu tempat, sambungan klien Redis menjadi sambungan terbiar. Jika masa melahu terlalu lama, pelayan Redis akan memutuskan sambungan secara aktif untuk mengurangkan penggunaan sumber terbiar. Pada masa ini, blpop/brpop akan membuang pengecualian.

Jadi, kita perlu berhati-hati semasa menulis pelanggan (aplikasi) pengguna, memberi perhatian untuk menangkap pengecualian dan mencuba semula.

Aplikasi 1: Gilir Kelewatan

Dalam kunci yang diedarkan Redis, secara amnya terdapat tiga strategi untuk menangani kegagalan penguncian:

• Melemparkan pengecualian secara langsung, dan bahagian hadapan mengingatkan pengguna sama ada untuk meneruskan operasi; > akan Letakkan permintaan dalam baris gilir kelewatan dan cuba lagi selepas beberapa ketika; Kami menyerikan mesej sebagai rentetan sebagai nilai zse, dan masa pemprosesan tamat tempoh (masa tunda) mesej sebagai skor. Kemudian undi zset untuk mendapatkan masa tamat untuk pemprosesan, dan keluarkan kunci dari zset melalui zrem untuk mewakili penggunaan yang berjaya, dan kemudian proses tugas.

Kod teras adalah seperti berikut:

• Kod di atas digunakan dalam multi-threading untuk mengelakkan situasi di mana tugas yang sama dipertandingkan oleh berbilang benang Walaupun ia boleh diproses selepas zrem untuk mengelakkan tugasan digunakan beberapa kali. Tetapi bagi utas yang memperoleh tugas tetapi gagal menggunakannya dengan jayanya, adalah membuang masa untuk mendapatkan tugas itu. Oleh itu, anda boleh mempertimbangkan untuk mengoptimumkan logik ini melalui skrip lua. Memindahkan zrangeByScore dan zrem bersama-sama ke pelayan untuk operasi atom akan menyelesaikan masalah dengan sempurna.
• Untuk lebih banyak pengetahuan berkaitan pengaturcaraan, sila lawati:

  Pengenalan kepada Pengaturcaraan

  ! !

Atas ialah kandungan terperinci Analisis ringkas tentang cara menggunakan baris gilir mesej dalam Redis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!