Aplikasi Redis dalam model publish-subscribe

Redis ialah pangkalan data dalam memori sumber terbuka berprestasi tinggi, digunakan terutamanya dalam senario seperti cache data, baris gilir mesej, pembilang dan pemeringkatan. Sebagai tambahan kepada fungsi praktikal ini, Redis juga menyokong model penerbitan-langganan yang berkuasa, yang boleh digunakan pada senario seperti menerbitkan mesej, melanggan mesej dan pengantaraan mesej. Seterusnya kita akan meneroka aplikasi Redis dalam model publish-subscribe.

Konsep corak terbitkan-langganan

Pola Terbit-Langgan ialah corak komunikasi mesej yang biasa digunakan Ia ialah mekanisme pengantaraan mesej yang membenarkan penerbit mesej Dihantar kepada berbilang pendengar. Dalam model ini, tiada hubungan langsung antara penerbit dan pelanggan, mereka berkomunikasi melalui perantara mesej.

Redis melaksanakan mod terbitkan-langganan

Dalam Redis, anda boleh mendaftarkan mesej langganan dengan pelayan Redis melalui arahan LANGGAN. Setiap kali mesej baharu diterbitkan, pelayan Redis akan memberitahu secara automatik semua pelanggan yang melanggan mesej tersebut. Begitu juga, mesej baharu boleh diterbitkan ke pelayan Redis melalui arahan PUBLISH. Mesej ini dihalakan secara automatik kepada semua pelanggan yang melanggan mesej tersebut.

Langkah-langkahnya adalah seperti berikut:

1. Buat klien Redis

Mula-mula anda perlu mencipta klien Redis, kodnya adalah seperti berikut:

import redis

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

di mana , hos mewakili alamat IP pelayan Redis, port mewakili nombor port dan db mewakili nombor pangkalan data yang digunakan.

2. Mesej langganan

Kaedah untuk mendaftarkan mesej langganan dengan pelayan Redis adalah seperti berikut:

redis_pubsub = redis_client.pubsub()
redis_pubsub.subscribe('channel_1') # 订阅名称为channel_1的消息

Dalam kod, kami menggunakan pubsub () kaedah untuk mencipta penerbitan Redis -Langgan objek dan kemudian gunakan kaedah subscribe() untuk mendaftarkan mesej bernama channel_1 dengan pelayan.

3. Terbitkan mesej

Kaedah menerbitkan mesej ke pelayan Redis adalah seperti berikut:

redis_client.publish('channel_1', 'Hello, world!')

Dalam kod, kami menggunakan penerbitan () kaedah untuk menerbitkan mesej Hello, world ! Dihantar kepada semua pelanggan yang melanggan saluran_1.

4. Memproses mesej

Selepas melanggan mesej Redis, anda perlu memproses mesej yang diterima daripada pelayan Redis. Kaedah memproses mesej adalah seperti berikut:

for message in redis_pubsub.listen():
    print(message)

Dalam kod, kami menggunakan kaedah listen() untuk mendengar mesej yang dihantar oleh pelayan Redis Apabila pelayan Redis menghantar mesej baharu kepada klien, kami mencetaknya.

Senario aplikasi

1. Melaksanakan pemberitahuan mesej

Model terbitkan dan langgan boleh digunakan untuk melaksanakan fungsi pemberitahuan mesej, seperti tolak berita, amaran awal , dsb. Sebagai contoh, laman web berita boleh menerbitkan berita yang baru dikeluarkan sebagai mesej kepada pelayan Redis dan memberitahu semua pengguna yang melanggan berita tersebut. Dengan cara ini, pengguna boleh mempelajari maklumat berita terkini tepat pada masanya.

2. Melaksanakan komunikasi sistem teragih

Dalam sistem teragih, komunikasi mesej diperlukan antara nod yang berbeza. Komunikasi antara nod boleh dicapai dengan mudah melalui model publish-subscribe Redis.

Contohnya:

Nod sistem A menerbitkan mesej (topik) ke pelayan Redis, dan nod B dan nod C melanggan mesej. Apabila nod A mengemas kini data, ia memberitahu pelayan Redis untuk mengemas kini data dengan menerbitkan mesej masing-masing memberitahu kemas kini data kepada semua nod yang melanggan mesej tersebut.

3. Melaksanakan pengagihan tugas

Model publish-subscribe Redis juga boleh digunakan untuk pengagihan tugas, seperti sistem penjadualan tugas visual masa nyata. Sebagai contoh, platform e-dagang dalam talian perlu memproses beribu-ribu pesanan dalam masa nyata dan memperuntukkan pesanan kepada nod yang berfungsi dengan sumber pemprosesan terbiar Perkara utama terletak pada cara mengedarkan pesanan ke nod dengan cepat, stabil dan berterusan. Melalui model terbitkan-langganan Redis, sistem pengurusan pesanan menerbitkan pesanan kepada pelayan Redis, dan setiap nod pekerja melanggan jenis pesanan tertentu. Apabila pesanan dikeluarkan, nod pekerja segera menerima dan mula memproses pesanan itu.

Ringkasan

Melalui model terbitkan dan langgan Redis, fungsi seperti pemberitahuan mesej, komunikasi sistem teragih dan peruntukan tugas boleh direalisasikan dengan mudah. Model ini meminimumkan gandingan antara penerbit dan pelanggan dan mencapai penyahgandingan. Pada masa yang sama, Redis mempunyai ciri prestasi tinggi dan keselarasan tinggi dalam penerbitan dan langganan mesej, memastikan kebolehpercayaan dan kecekapan model ini dalam aplikasi praktikal.

Atas ialah kandungan terperinci Aplikasi Redis dalam model publish-subscribe. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!