Apakah pub/sub di redis 7?

Pub/sub di Redis 7 meningkatkan pub/sub skalabiliti dengan mengedarkan trafik mesej di pelbagai benang. Tradisional Redis Pub/Sub adalah terhad oleh model tunggal yang boleh menjadi kesesakan di bawah beban tinggi. Dengan pub/sub sharded, saluran dibahagikan kepada shard yang diberikan kepada benang I/O tertentu; Setiap thread mengendalikan penghantaran mesej untuk shard yang diberikan, mengurangkan pertengkaran dan peningkatan prestasi. Mata utama termasuk: 1) pemetaan saluran ke-mata melalui hashing; 2) bilangan shard yang boleh dikonfigurasikan; 3) penggunaan ssubscribe untuk langganan sharded; 4) Sharding automatik semasa penerbitan. Ia sesuai untuk aplikasi dengan banyak saluran, seperti sistem sembang masa nyata atau platform IoT. Untuk menggunakannya, gantikan Langgan dengan SSUBScribe, sementara Publish tetap tidak berubah. Pelanggan mestilah secara eksplisit memilih untuk bersuara, dan kedua-dua mod boleh wujud bersama semasa penghijrahan.

Sharded Pub/Sub di Redis 7 adalah ciri baru yang menangani salah satu batasan sistem pub/sub sistem tradisional - skalabilitas. Jika anda menggunakan REDIS untuk pemesejan masa nyata dan mempunyai pelbagai saluran atau corak, terutamanya di bawah beban tinggi, anda mungkin telah memukul masalah prestasi sebelum ini. Pub/sub sharded membantu dengan menyebarkan trafik pub/sub di semua gelung acara yang ada (atau benang), bukannya mengarahkan segala -galanya melalui benang utama.

Mengapa Ia Diperlukan

Redis sentiasa menggunakan model tunggal untuk mengendalikan arahan, yang menjadikan perkara mudah tetapi boleh menjadi kesesakan ketika mengendalikan jumlah besar pub/sub mesej. Dalam versi terdahulu, walaupun Redis disusun dengan diaktifkan I/O, semua operasi pub/sub masih melalui benang utama. Ini bermakna menerbitkan atau menyampaikan mesej kepada banyak pelanggan boleh menghalang operasi lain.

Dengan Redis 7, perubahan ini.

Bagaimana kerja pub/sub sharded?

Idea teras di belakang pub/sub sharded adalah sharding - mengedarkan tanggungjawab penghantaran mesej merentasi pelbagai benang. Inilah cara ia berfungsi:

• Redis membahagikan saluran ke dalam kumpulan logik yang dipanggil "Shards."
• Setiap shard diberikan kepada benang I/O tertentu.
• Apabila pelanggan melanggan saluran, langganan itu didaftarkan dengan shard (dan dengan itu benang) yang bertanggungjawab untuk saluran itu.
• Mesej yang diterbitkan ke saluran diproses dan disampaikan oleh benang yang sama, mengelakkan overhead penyegerakan silang.

Dengan cara ini, Redis boleh skala prestasi pub/sub lebih berkesan kerana bilangan teras CPU meningkat.

Beberapa perkara utama:

• Nama saluran dipetakan ke Shards menggunakan fungsi hashing.
• Bilangan shard boleh dikonfigurasi melalui redis.conf ( pubsub_shard_streams_per_node ).
• Pelanggan hanya menerima mesej dari saluran yang mereka telah dilanggar-langganan -ada perintah yang berasingan untuk itu: SSUBSCRIBE .

Bilakah anda harus menggunakannya?

Anda harus mempertimbangkan menggunakan pub/sub sharded ketika:

• Aplikasi anda menggunakan sejumlah besar saluran.
• Anda mengalami kesesakan prestasi kerana penggunaan pub/sub.
• Anda mahu skala redis secara mendatar tanpa menambah lebih banyak contoh hanya untuk pengedaran mesej.

Ia amat berguna dalam aplikasi seperti:

• Sistem sembang masa nyata dengan banyak bilik atau topik.
• Perkhidmatan Pemberitahuan Kemas kini penyiaran kepada banyak pengguna.
• Platform IoT di mana setiap peranti menerbitkan kemas kini status ke salurannya sendiri.

Jika kes penggunaan anda hanya melibatkan beberapa saluran dengan banyak pelanggan, pub/sub standard mungkin masih baik. Tetapi sebaik sahaja anda mula mengukur bilangan saluran atau memerlukan latensi yang lebih rendah setiap mesej, sharding menjadi lebih baik.

Cara Menggunakan Pub/Sub Sharded

Menggunakan pub / sub sharded adalah mudah, tetapi berbeza dari aliran SUBSCRIBE / PUBLISH klasik. Inilah yang perlu anda lakukan:

• Untuk melanggan saluran dengan cara yang sharded, gunakan SSUBSCRIBE dan bukannya SUBSCRIBE .
• Untuk menerbitkan ke saluran sharded, Gunakan PUBLISH - Sharding ditangani secara automatik berdasarkan nama saluran.
• Untuk berhenti berlangganan, gunakan SUNSUBSCRIBE .

Contoh:

 # Langgan Saluran Sharded
client1> sSubscribe myChannel

# Menerbitkan mesej - dikendalikan oleh utas yang betul
pelanggan2> menerbitkan myChannel "Hello Sharded World"

Perlu diingat:

• Pelanggan mestilah menggunakan SSUBSCRIBE untuk mengambil kesempatan daripada sharding.
• SUBSCRIBE klasik dan SSUBSCRIBE tidak boleh dicampur dalam sambungan yang sama.
• Alat atau pelanggan yang tidak dikemas kini untuk Redis 7 tidak akan menggunakan pub/sub sharded kecuali diubahsuai.

Juga, kerana Redis 7 menyokong kedua -dua mod, anda secara beransur -ansur boleh memindahkan bahagian aplikasi anda untuk menggunakan langganan sharded sambil mengekalkan orang lain pada model tradisional.

Pemikiran terakhir

Pub/sub di Redis 7 membawa peningkatan skalabiliti yang sangat diperlukan kepada keupayaan pemesejan masa nyata Redis. Dengan menyerahkan saluran ke benang yang berbeza, Redis boleh mengendalikan output yang lebih tinggi tanpa mengorbankan kesederhanaan atau kebolehpercayaan.

Jika anda bekerja dengan Redis pada skala, terutamanya dalam persekitaran pub/sub-berat, ia bernilai menaik taraf dan mencuba ciri ini.

Itu pada dasarnya - tidak terlalu rumit, tetapi pasti satu langkah besar ke hadapan untuk Redis sebagai platform pemesejan.

Atas ialah kandungan terperinci Apakah pub/sub di redis 7?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!