如何監(jiān)聽Redis中Key值的變化(SpringBoot整合)

更新時間：2024年03月29日 08:48:00 作者：Z灝

測試過程中我們有一部分常量值放入redis,共大部分應用調用,但在測試過程中經常有人會清空redis,回歸測試,下面這篇文章主要給大家介紹了關于如何監(jiān)聽Redis中Key值變化的相關資料,需要的朋友可以參考下

一、概念

當Redis中的值發(fā)生改變時，通過配置來監(jiān)聽key值的變化。

事件通過 Redis 的訂閱與發(fā)布功能（pub/sub）來進行分發(fā)，因此所有支持訂閱與發(fā)布功能的客戶端都可以在無須做任何修改的情況下，直接使用鍵空間通知功能。

二、配置

因為開啟鍵空間通知功能需要消耗一些 CPU ，所以在默認配置下，該功能處于關閉狀態(tài)。

可以通過修改 redis.conf 文件，或者直接使用 CONFIG SET 命令來開啟或關閉鍵空間通知功能。
notify-keyspace-events 的參數可以是以下字符的任意組合，它指定了服務器該發(fā)送哪些類型的通知：

第一種方式：直接使用命令

第一步：開啟

config set notify-keyspace-events KEA

第二步：訂閱

另起一個窗口，用于監(jiān)聽。

psubscribe '__key*__:*'                   #對所有庫鍵空間通知
psubscribe '__keyspace@5__:*'             #是對db5數據庫鍵空間通知
psubscribe '__keyspace@5__:order*'        #是對db5數據庫，key前綴為order所有鍵的鍵空間通知

出現以上形式表明訂閱成功。

第三步：添加數據

set k1 v1

這就是配置成功了。

【推薦】第二種方式：修改配置文件

如果使用第一種方式的話，當關閉窗口時，再次使用的話，還需要重新輸入，而修改配置文件則不用重復操作。

第一步：找配置文件

在安裝的路徑中找到redis.windows.conf

點擊快捷鍵"ctrl+F"，輸入：notify-keyspace-events

第二步：修改配置文件

改為：notify-keyspace-events KEA

點擊"ctrl+S"保存并關閉

第三步：使用命令啟動Redis

將Redis注冊成一個服務啟動，這樣就不用每次開機手動啟動了，而且不用一直用黑窗口打開了。

找到Redis的安裝路徑，然后進入，輸入cmd

輸入命令：

redis-server.exe --service-install redis.windows.conf

這樣在服務中就可以找到了。

三、整合SpringBoot

1.加入依賴

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.配置文件

spring:
    redis:
        # Redis服務器地址
        host: 127.0.0.1
        # Redis服務器端口號
        port: 6379
        # 使用的數據庫索引，默認是0
        database: 0
        # 連接超時時間
        timeout: 1800000
        # 設置密碼
        password: 
        lettuce:
            pool:
                # 最大阻塞等待時間，負數表示沒有限制
                max-wait: -1
                # 連接池中的最大空閑連接
                max-idle: 5
                # 連接池中的最小空閑連接
                min-idle: 0
                # 連接池中最大連接數，負數表示沒有限制
                max-active: 20

3.配置類

package com.redisDemo.config;

import com.example.redisDemo.controller.RedisReceiver;
import com.example.redisDemo.listener.*;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.net.UnknownHostException;

/**
 * @author lenovo
 */
@Configuration
public class RedisConfig {
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Autowired
    private RedisUpdateAndAddListener redisUpdateAndAddListener;

    @Autowired
    private RedisDeleteListener redisDeleteListener;

    @Autowired
    private RedisHashUpdateAndAddListener redisHashUpdateAndAddListener;

    @Autowired
    private RedisListUpdateAndAddListener redisListUpdateAndAddListener;

    @Autowired
    private RedisSetUpdateAndAddListener redisSetUpdateAndAddListener;

    @Autowired
    private RedisSortUpdateAndAddListener redisSortUpdateAndAddListener;


    @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());
        container.addMessageListener(redisHashUpdateAndAddListener,redisHashUpdateAndAddListener.getTopic());
        container.addMessageListener(redisListUpdateAndAddListener,redisListUpdateAndAddListener.getTopic());
        container.addMessageListener(redisSetUpdateAndAddListener,redisSetUpdateAndAddListener.getTopic());
        container.addMessageListener(redisSortUpdateAndAddListener,redisSortUpdateAndAddListener.getTopic());
        //監(jiān)聽所有key的過期事件
//        container.addMessageListener(redisExpiredListener,redisExpiredListener.getTopic());
        return container;
    }

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
        // 創(chuàng)建模板
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        // 設置連接工廠
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        // 設置序列化工具
        GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        // key和 hashKey采用 string序列化
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());

        // value和 hashValue采用 JSON序列化
        redisTemplate.setValueSerializer(RedisSerializer.string());
        redisTemplate.setHashValueSerializer(RedisSerializer.string());
        return redisTemplate;
    }
}

4.監(jiān)聽類

監(jiān)聽所有類型的刪除操作：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@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+",消息內容是："+msg);
    }
}

監(jiān)聽hash類型新增/修改：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@Component
@Data
public class RedisHashUpdateAndAddListener implements MessageListener {
	//監(jiān)聽的主題
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:hset");
 
    @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);
    }
 
}

監(jiān)聽list類型的添加/修改：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@Component
@Data
public class RedisListUpdateAndAddListener implements MessageListener {
	//監(jiān)聽的主題
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:lpush");
 
    @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);
    }
 
}

監(jiān)聽set類型新增/修改：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@Component
@Data
public class RedisSetUpdateAndAddListener implements MessageListener {
	//監(jiān)聽的主題
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:sadd");
 
    @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);
    }
 
}

監(jiān)聽zset類型新增/修改：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@Component
@Data
public class RedisSortUpdateAndAddListener implements MessageListener {
	//監(jiān)聽的主題
    private  final PatternTopic topic = new PatternTopic("__keyevent@*__:zadd");
 
    @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);
    }
 
}

監(jiān)聽string類型新增/修改：

package com.redisDemo.listener;

import lombok.Data;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.stereotype.Component;

@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+",消息內容是："+msg);
    }
 
}

5.啟動項目

在Redis圖形化界面添加一個數據

這下就成功監(jiān)聽到了。

如果沒有監(jiān)聽到，請確保Redis正常啟動了。

總結

到此這篇關于如何監(jiān)聽Redis中Key值的變化的文章就介紹到這了,更多相關監(jiān)聽Redis中Key值變化內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

redis在php中常用的語法【推薦】
string是redis最基本的類型，而且string類型是二進制安全的。這篇文章主要介紹了redis在php中常用的語法,需要的朋友可以參考下
2018-08-08
Redis分布式鎖的使用和實現原理詳解
這篇文章主要給大家介紹了關于Redis分布式鎖的使用和實現原理的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2020-11-11
Redis Cluster原理及配置詳解
這篇文章主要為大家介紹了Redis Cluster原理及配置詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2022-11-11
Redis分布式鎖的幾種實現方法
本文主要介紹了Redis分布式鎖的幾種實現方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
2025-04-04
Redis?key-value亂碼的解決
本文主要介紹了Redis?key-value亂碼的解決，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2022-06-06
Redisson如何解決redis分布式鎖過期時間到了業(yè)務沒執(zhí)行完問題
這篇文章主要介紹了Redisson如何解決redis分布式鎖過期時間到了業(yè)務沒執(zhí)行完問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-01-01
Redis配置文件redis.conf詳細配置說明
本文列出了Redis的配置文件redis.conf的各配置項的詳細說明,簡單易懂
2018-03-03
詳解Redis中的BigKey如何發(fā)現和處理
這篇文章主要為大家詳細介紹了Redis中的BigKey如何發(fā)現和處理,文中給大家詳細講解了BigKey危害和如何解決這些問題,文章通過代碼示例和圖文介紹的非常詳細,需要的朋友可以參考下
2023-10-10
Redis基本數據類型Set常用操作命令
這篇文章主要為大家介紹了Redis基本數據類型Set常用操作命令，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2022-05-05
為什么RedisCluster設計成16384個槽
本文主要介紹了為什么RedisCluster設計成16384個槽，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2021-09-09

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

如何監(jiān)聽Redis中Key值的變化(SpringBoot整合)

目錄

一、概念

二、配置

第一種方式：直接使用命令

第一步：開啟

第二步：訂閱

第三步：添加數據

【推薦】第二種方式：修改配置文件

第一步：找配置文件

第二步：修改配置文件

第三步：使用命令啟動Redis

三、整合SpringBoot

1.加入依賴

2.配置文件

3.配置類

4.監(jiān)聽類

5.啟動項目

總結

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

如何監(jiān)聽Redis中Key值的變化(SpringBoot整合)

目錄

一、概念

二、配置

第一種方式：直接使用命令

第一步：開啟

第二步：訂閱

第三步：添加數據

【推薦】第二種方式：修改配置文件

第一步：找配置文件

第二步：修改配置文件

第三步：使用命令啟動Redis

三、整合SpringBoot

1.加入依賴

2.配置文件

3.配置類

4.監(jiān)聽類

5.啟動項目

總結

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

一、概念

三、整合SpringBoot