############################# EVENT NOTIFICATION ##############################

# 鍵空間通知使得客戶(hù)端可以通過(guò)訂閱頻道或模式，來(lái)接收那些以某種方式改動(dòng)了 Redis 數(shù)據(jù)集的事件。
# 因?yàn)殚_(kāi)啟鍵空間通知功能需要消耗一些 CPU ，所以在默認(rèn)配置下，該功能處于關(guān)閉狀態(tài)。
# notify-keyspace-events 的參數(shù)可以是以下字符的任意組合，
# 它指定了服務(wù)器該發(fā)送哪些類(lèi)型的通知：
# K 鍵空間通知，所有通知以 __keyspace@__ 為前綴
# E 鍵事件通知，所有通知以 __keyevent@__ 為前綴
# g DEL 、 EXPIRE 、 RENAME 等類(lèi)型無(wú)關(guān)的通用命令的通知
# $ 字符串命令的通知
# l 列表命令的通知
# s 集合命令的通知
# h 哈希命令的通知
# z 有序集合命令的通知
# x 過(guò)期事件：每當(dāng)有過(guò)期鍵被刪除時(shí)發(fā)送
# e 驅(qū)逐(evict)事件：每當(dāng)有鍵因?yàn)?maxmemory 政策而被刪除時(shí)發(fā)送
# A 參數(shù) g$lshzxe 的別名
# 輸入的參數(shù)中至少要有一個(gè) K 或者 E，否則的話(huà)，不管其余的參數(shù)是什么，都不會(huì)有任何 通知被分發(fā)。

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

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.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;

/**
 * @ClassName RedisListenerConfig
 * @Description redis監(jiān)聽(tīng)配置
 * @Author cl
 * @Date 2021-09-09 10:45
 */
@Configuration
public class RedisListenerConfig {
    @Autowired
    RedisListen redisListen;

    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory factory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        container.addMessageListener(redisListen, new PatternTopic("__keyevent@*__:expired"));
        return container;
    }
}

import com.tanghe.common.constant.RedisConstants;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.stereotype.Component;

/**
 * @ClassName RedisListen
 * @Description RedisListen
 * @Author cl
 * @Date 2021-09-09 10:46
 */
@Slf4j
@Component
public class RedisListen implements MessageListener {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String expiredKey = message.toString();

        log.info("失效的redis是:"+expiredKey);
        RedisSerializer<?> serializer = redisTemplate.getValueSerializer();
        String channel = String.valueOf(serializer.deserialize(message.getChannel()));
        String body = String.valueOf(serializer.deserialize(message.getBody()));
        log.info("channel==="+channel+"-----------------"+"body === "+body);
        //key過(guò)期監(jiān)聽(tīng),在處理業(yè)務(wù)之前校驗(yàn)下自己業(yè)務(wù)的key和監(jiān)聽(tīng)的key以及庫(kù)號(hào)
        if("__keyevent@0__:expired".equals(channel) && body.indexOf(“自己業(yè)務(wù)的key”) != -1){
            log.info("進(jìn)來(lái)了哈");
            //這里寫(xiě)需要處理的業(yè)務(wù)

        }

    }
}