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

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:

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 產(chǎn)生expired通知的時(shí)間為過期鍵被刪除的時(shí)候， 而不是鍵的生存時(shí)間變?yōu)?0 的時(shí)候。

三、案例

按上文內(nèi)容，我們先將redis的鍵空間通知開啟,我們開啟所有的通知，在可以端中測(cè)試后沒問題再到代碼中測(cè)試。

連接到redis 輸入一下命令

config set notify-keyspace-events KEA

訂閱鍵空間和鍵事件的主題

psubscribe '__key*__:*'#對(duì)所有庫(kù)鍵空間通知
 
psubscribe '__keyspace@2__:*' #是對(duì)db2數(shù)據(jù)庫(kù)鍵空間通知
 
psubscribe '__keyspace@2__:order*' #是對(duì)db2數(shù)據(jù)庫(kù)，key前綴為order所有鍵的鍵空間通知

創(chuàng)建一個(gè) key :name valus:zhangsan

set name wsl

觀察訂閱的窗口 會(huì)受到兩個(gè)消息，第一個(gè)是：鍵空間 第二個(gè)是鍵事件，鍵空間是內(nèi)容是操作指令，主題中包含有key，鍵事件主題中包含了指令，內(nèi)容是key。

到這里說明已經(jīng)開啟了鍵空間通知

代碼

以下代碼采用string類型演示

在配置一下MessageListenerContainer類，將我們寫好的監(jiān)聽類添加到該類中即可,刪除和過期都是需要添加，我這里就一起添加了后面就不做演示。

@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);
        //監(jiān)聽所有的key的set事件
        container.addMessageListener(redisUpdateAndAddListener, redisUpdateAndAddListener.getTopic());
        //監(jiān)聽所有key的刪除事件
        container.addMessageListener(redisDeleteListener,redisDeleteListener.getTopic());
        //監(jiān)聽所有key的過期事件
        container.addMessageListener(redisExpiredListener,redisExpiredListener.getTopic());
        return container;
    }
 
 
}

新增和修改都是set指令

所以監(jiān)聽的主題都一樣,實(shí)現(xiàn)MessageListener接口，重寫onMessage這里就是收到消息的處理邏輯

@Component
@Data
public class RedisUpdateAndAddListener implements MessageListener {
	//監(jiān)聽的主題
    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+",消息內(nèi)容是："+msg);
    }
 
}

在redis中對(duì)name這個(gè)key進(jìn)行set操作

set name wsl

在控制臺(tái)就可以看到name這個(gè)key被操作了

刪除

跟上面的更新監(jiān)聽一樣，只需要把訂閱主題更改一下即可。同樣需要添加到這個(gè)RedisMessageListenerContainer，上面已經(jīng)添加，這里不做演示

@Component
@Data
public class RedisDeleteListener implements MessageListener {
 
    //監(jiān)聽主題
    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+",消息內(nèi)容是："+msg);
    }
}

在redis輸入命令，del name 在控制臺(tái)可以看到已經(jīng)收到消息了。

過期

如上面的操作方式一樣

@Data
@Component
public class RedisExpiredListener implements MessageListener {
 
    //監(jiān)聽主題
    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+",消息內(nèi)容是："+msg);
    }
}

?在redis中寫一個(gè)定時(shí)刪除的keySETEX age 18 3三秒后就可以控制臺(tái)打印了相關(guān)信息

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