Jadual Kandungan
1. Gambaran Keseluruhan Fungsi
2. Jenis acara
3. Konfigurasi
三、案例
代码
新增和修改都是set指令
删除
过期
Rumah pangkalan data Redis Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

May 26, 2023 pm 01:55 PM
redis springboot key

1. Gambaran Keseluruhan Fungsi

Pemberitahuan ruang kekunci membolehkan pelanggan menerima acara yang telah menukar kunci Redis dalam beberapa cara dengan melanggan saluran atau mod.

Semua arahan yang mengubah suai kekunci kekunci.

Semua kunci yang menerima perintah nilai kunci LPUSH [value …].

Semua kunci tamat tempoh dalam pangkalan data db.

Acara diedarkan melalui fungsi langganan dan penerbitan (pub/sub) Redis, jadi semua pelanggan yang menyokong fungsi langganan dan penerbitan boleh menggunakan kekunci secara langsung tanpa sebarang pengubahsuaian fungsi pemberitahuan Space.

Oleh kerana fungsi langganan dan penerbitan semasa Redis menggunakan strategi api dan lupakan, jika program anda memerlukan pemberitahuan peristiwa yang boleh dipercayai, maka pemberitahuan ruang utama semasa mungkin Tidak sesuai untuk anda: Apabila pelanggan melanggan acara pergi luar talian, ia kehilangan semua acara yang telah diedarkan kepadanya semasa pemutusan sambungan.

Pada masa hadapan, pengedaran acara yang lebih andal akan disokong Sokongan ini boleh dicapai dengan menjadikan fungsi langganan dan penerbitan itu sendiri lebih dipercayai, atau dengan melanggan dan menerbitkan mesej dalam skrip Lua untuk mendengar seperti menolak acara ke senarai.

2. Jenis acara

Untuk setiap operasi yang mengubah suai pangkalan data, pemberitahuan ruang kekunci akan menghantar dua jenis acara yang berbeza.

Sebagai contoh, apabila melaksanakan perintah 0 pada kekunci mykey nombor pangkalan data DEL key [key …], sistem akan mengedarkan dua mesej, yang bersamaan dengan melaksanakan dua perintah PUBLISH channel message berikut:

PUBLISH __keyspace@0__:mykey del
PUBLISH __keyevent@0__:del mykey
Salin selepas log masuk

Langgan saluran pertama __keyspace@0__:mykey untuk menerima semua acara kunci mykey yang diubah suai dalam pangkalan data No. 0 dan langgan saluran kedua __keyevent@0__:del untuk menerima semua acara yang melaksanakan del arahan dalam pangkalan data No 0. kunci.

Saluran yang diawali dengan ruang kekunci dipanggil pemberitahuan ruang kekunci dan saluran yang diawali dengan acara utama dipanggil pemberitahuan peristiwa kunci.

Apabila perintah del mykey dilaksanakan:

  • Pelanggan saluran ruang kekunci akan menerima nama acara yang telah dilaksanakan, dalam kes ini, del .

  • Pelanggan saluran acara utama akan menerima nama kunci di mana acara itu dilaksanakan, dalam kes ini, mykey .

3. Konfigurasi

Oleh kerana menghidupkan fungsi pemberitahuan ruang kekunci memerlukan beberapa CPU, jadi dalam konfigurasi lalai, fungsi ini dimatikan.

Anda boleh menghidupkan atau mematikan fungsi pemberitahuan ruang kekunci dengan mengubah suai fail redis.conf, atau terus menggunakan arahan CONFIG SET:

Apabila parameter pilihan notify-keyspace-events adalah rentetan kosong, Fungsi dimatikan.

Sebaliknya, apabila parameter bukan rentetan kosong, fungsi dihidupkan.

Parameter notify-keyspace-events boleh terdiri daripada sebarang kombinasi aksara berikut, yang menentukan jenis pemberitahuan yang harus dihantar oleh pelayan:

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

Input parameter Mesti ada sekurang-kurangnya satu K atau E dalam , jika tidak, tidak kira apa parameter lain, tiada pemberitahuan akan diedarkan.

Sebagai contoh, jika anda hanya mahu melanggan pemberitahuan yang berkaitan dengan senarai dalam ruang kekunci, maka parameter hendaklah ditetapkan kepada Kl dan seterusnya.

Tetapkan parameter kepada rentetan "AKE" untuk menghantar semua jenis pemberitahuan.

Janakan pemberitahuan expired apabila kunci dipadamkan kerana tamat tempoh.

Menghasilkan pemberitahuan maxmemory apabila kunci dipadamkan disebabkan oleh dasar evicted untuk menuntut semula memori.

Semua arahan hanya akan menjana pemberitahuan selepas kunci sebenarnya telah ditukar.

Sebagai contoh, apabila SREM key member [member …] cuba memadamkan elemen yang tidak wujud dalam koleksi, operasi pemadaman akan gagal kerana tiada kunci perubahan sebenar, jadi tiada pemberitahuan akan dihantar untuk operasi ini.

Jika anda mempunyai sebarang soalan tentang pemberitahuan yang dijana oleh arahan itu, sebaiknya gunakan arahan berikut untuk mengesahkannya sendiri:

Redis menggunakan dua kaedah berikut untuk memadamkan kunci tamat tempoh:

Apabila kunci diakses, program akan menyemak kunci Jika kunci telah tamat tempoh, kunci akan dipadamkan.

Sistem asas akan mencari dan memadamkan kunci tamat tempoh secara berperingkat di latar belakang untuk memproses kunci yang telah tamat tempoh tetapi tidak akan diakses.
Apabila kunci tamat tempoh ditemui oleh salah satu daripada dua program di atas dan kunci dipadamkan daripada pangkalan data, Redis akan menjana pemberitahuan tamat tempoh.

Redis tidak menjamin bahawa kunci yang masa hidup (TTL)nya menjadi 0 akan dipadamkan serta-merta: Jika program tidak mengakses kunci tamat tempoh ini, atau terdapat terlalu banyak kunci dengan masa kelangsungan hidup, kemudian kunci Jangka hayat menjadi 0, dan mungkin terdapat selang masa yang ketara antara apabila kunci itu sebenarnya dipadamkan.

因此, Redis 产生expired通知的时间为过期键被删除的时候, 而不是键的生存时间变为 0 的时候。

三、案例

按上文内容,我们先将redis的键空间通知开启,我们开启所有的通知,在可以端中测试后没问题再到代码中测试。

连接到redis 输入一下命令

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

config set notify-keyspace-events KEA
Salin selepas log masuk

订阅键空间和键事件的主题

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

psubscribe '__key*__:*'#对所有库键空间通知
 
psubscribe '__keyspace@2__:*' #是对db2数据库键空间通知
 
psubscribe '__keyspace@2__:order*' #是对db2数据库,key前缀为order所有键的键空间通知
Salin selepas log masuk

创建一个 key :name valus:zhangsan

set name wsl
Salin selepas log masuk
Salin selepas log masuk

观察订阅的窗口 会受到两个消息,第一个是:键空间 第二个是键事件,键空间是内容是操作指令,主题中包含有key,键事件主题中包含了指令,内容是key。

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

到这里说明已经开启了键空间通知

代码

以下代码采用string类型演示

在配置一下MessageListenerContainer类,将我们写好的监听类添加到该类中即可,删除和过期都是需要添加,我这里就一起添加了后面就不做演示。

@Configuration
public class RedisConfig {
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    @Autowired
    private RedisUpdateAndAddListener redisUpdateAndAddListener;
 
    @Autowired
    private RedisDeleteListener redisDeleteListener;
 
    @Autowired
    private RedisExpiredListener redisExpiredListener;
 
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        //监听所有的key的set事件
        container.addMessageListener(redisUpdateAndAddListener, redisUpdateAndAddListener.getTopic());
        //监听所有key的删除事件
        container.addMessageListener(redisDeleteListener,redisDeleteListener.getTopic());
        //监听所有key的过期事件
        container.addMessageListener(redisExpiredListener,redisExpiredListener.getTopic());
        return container;
    }
 
 
}
Salin selepas log masuk

新增和修改都是set指令

所以监听的主题都一样,实现MessageListener接口,重写onMessage这里就是收到消息的处理逻辑

@Component
@Data
public class RedisUpdateAndAddListener implements MessageListener {
	//监听的主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:set");
 
    @Override
    public void onMessage(Message message,byte[] pattern){
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key更新或修改,消息主题是:"+ topic+",消息内容是:"+msg);
    }
 
}
Salin selepas log masuk

在redis中对name这个key进行set操作

set name wsl
Salin selepas log masuk
Salin selepas log masuk

在控制台就可以看到name这个key被操作了

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

删除

跟上面的更新监听一样,只需要把订阅主题更改一下即可。同样需要添加到这个RedisMessageListenerContainer,上面已经添加,这里不做演示

@Component
@Data
public class RedisDeleteListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:del");
 
    /**
     *
     * @param message 消息
     * @param pattern 主题
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的删除,消息主题是:"+ topic+",消息内容是:"+msg);
    }
}
Salin selepas log masuk

在redis输入命令,del name 在控制台可以看到已经收到消息了。

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

过期

如上面的操作方式一样

@Data
@Component
public class RedisExpiredListener implements MessageListener {
 
    //监听主题
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:expired");
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String topic = new String(pattern);
        String msg = new String(message.getBody());
        System.out.println("收到key的过期,消息主题是:"+ topic+",消息内容是:"+msg);
    }
}
Salin selepas log masuk

 在redis中写一个定时删除的keySETEX age 18 3三秒后就可以控制台打印了相关信息

Bagaimana SpringBoot memantau peristiwa perubahan kunci redis

Atas ialah kandungan terperinci Bagaimana SpringBoot memantau peristiwa perubahan kunci redis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

AI Hentai Generator

AI Hentai Generator

Menjana ai hentai secara percuma.

Artikel Panas

R.E.P.O. Kristal tenaga dijelaskan dan apa yang mereka lakukan (kristal kuning)
4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Tetapan grafik terbaik
4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Cara Memperbaiki Audio Jika anda tidak dapat mendengar sesiapa
4 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
WWE 2K25: Cara Membuka Segala -galanya Di Myrise
1 bulan yang lalu By 尊渡假赌尊渡假赌尊渡假赌

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Cara Membina Mod Kluster Redis Cara Membina Mod Kluster Redis Apr 10, 2025 pm 10:15 PM

Mod Redis cluster menyebarkan contoh Redis ke pelbagai pelayan melalui sharding, meningkatkan skalabilitas dan ketersediaan. Langkah -langkah pembinaan adalah seperti berikut: Buat contoh Redis ganjil dengan pelabuhan yang berbeza; Buat 3 contoh sentinel, memantau contoh redis dan failover; Konfigurasi fail konfigurasi sentinel, tambahkan pemantauan maklumat contoh dan tetapan failover; Konfigurasi fail konfigurasi contoh Redis, aktifkan mod kluster dan tentukan laluan fail maklumat kluster; Buat fail nodes.conf, yang mengandungi maklumat setiap contoh Redis; Mulakan kluster, laksanakan perintah Buat untuk membuat kluster dan tentukan bilangan replika; Log masuk ke kluster untuk melaksanakan perintah maklumat kluster untuk mengesahkan status kluster; buat

Cara menggunakan perintah redis Cara menggunakan perintah redis Apr 10, 2025 pm 08:45 PM

Menggunakan Arahan Redis memerlukan langkah -langkah berikut: Buka klien Redis. Masukkan arahan (nilai kunci kata kerja). Menyediakan parameter yang diperlukan (berbeza dari arahan ke arahan). Tekan Enter untuk melaksanakan arahan. Redis mengembalikan tindak balas yang menunjukkan hasil operasi (biasanya OK atau -r).

Cara menggunakan redis berulir tunggal Cara menggunakan redis berulir tunggal Apr 10, 2025 pm 07:12 PM

Redis menggunakan satu seni bina berulir untuk memberikan prestasi tinggi, kesederhanaan, dan konsistensi. Ia menggunakan I/O multiplexing, gelung acara, I/O yang tidak menyekat, dan memori bersama untuk meningkatkan keserasian, tetapi dengan batasan batasan konkurensi, satu titik kegagalan, dan tidak sesuai untuk beban kerja yang berintensifkan.

Cara membaca kod sumber redis Cara membaca kod sumber redis Apr 10, 2025 pm 08:27 PM

Cara terbaik untuk memahami kod sumber REDIS adalah dengan langkah demi langkah: Dapatkan akrab dengan asas -asas Redis. Pilih modul atau fungsi tertentu sebagai titik permulaan. Mulakan dengan titik masuk modul atau fungsi dan lihat baris kod mengikut baris. Lihat kod melalui rantaian panggilan fungsi. Berhati -hati dengan struktur data asas yang digunakan oleh REDIS. Kenal pasti algoritma yang digunakan oleh Redis.

Cara membersihkan data redis Cara membersihkan data redis Apr 10, 2025 pm 10:06 PM

Cara Mengosongkan Data Redis: Gunakan perintah Flushall untuk membersihkan semua nilai utama. Gunakan perintah flushdb untuk membersihkan nilai utama pangkalan data yang dipilih sekarang. Gunakan Pilih untuk menukar pangkalan data, dan kemudian gunakan FlushDB untuk membersihkan pelbagai pangkalan data. Gunakan perintah DEL untuk memadam kunci tertentu. Gunakan alat REDIS-CLI untuk membersihkan data.

Cara Melihat Semua Kekunci di Redis Cara Melihat Semua Kekunci di Redis Apr 10, 2025 pm 07:15 PM

Untuk melihat semua kunci di Redis, terdapat tiga cara: Gunakan perintah kunci untuk mengembalikan semua kunci yang sepadan dengan corak yang ditentukan; Gunakan perintah imbasan untuk melangkah ke atas kunci dan kembalikan satu set kunci; Gunakan arahan maklumat untuk mendapatkan jumlah kunci.

Cara Membaca Gilir Redis Cara Membaca Gilir Redis Apr 10, 2025 pm 10:12 PM

Untuk membaca giliran dari Redis, anda perlu mendapatkan nama giliran, membaca unsur -unsur menggunakan arahan LPOP, dan memproses barisan kosong. Langkah-langkah khusus adalah seperti berikut: Dapatkan nama giliran: Namakannya dengan awalan "giliran:" seperti "giliran: my-queue". Gunakan arahan LPOP: Keluarkan elemen dari kepala barisan dan kembalikan nilainya, seperti LPOP Queue: My-Queue. Memproses Baris kosong: Jika barisan kosong, LPOP mengembalikan nihil, dan anda boleh menyemak sama ada barisan wujud sebelum membaca elemen.

Cara memulakan pelayan dengan redis Cara memulakan pelayan dengan redis Apr 10, 2025 pm 08:12 PM

Langkah -langkah untuk memulakan pelayan Redis termasuk: Pasang Redis mengikut sistem operasi. Mulakan perkhidmatan Redis melalui Redis-server (Linux/macOS) atau redis-server.exe (Windows). Gunakan redis-cli ping (linux/macOS) atau redis-cli.exe ping (windows) perintah untuk memeriksa status perkhidmatan. Gunakan klien Redis, seperti redis-cli, python, atau node.js untuk mengakses pelayan.

See all articles