【redis】spring boot利用redis的Keyspace Notifications实现消息通知

前言

  需求：当redis中的某个key失效的时候，更新key对应数据在数据库的状态

一、修改redis.conf

  安装的redis服务默认是: notify-keyspace-events ""，修改为 notify-keyspace-events Ex;

  位置：redis安装目下的redis.windows-service.conf 或 redis.windows.conf。(具体看redis服务加载的哪一个配置, 貌似要redis 2.8+才支持)

  能够在redis.conf中找到对应的描述

# K    键空间通知，以__keyspace@<db>__为前缀
# E    键事件通知，以__keysevent@<db>__为前缀
# g    del , expipre , rename 等类型无关的通用命令的通知, ...
# $    String命令
# l    List命令
# s    Set命令
# h    Hash命令
# z    有序集合命令
# x    过时事件（每次key过时时生成）
# e    驱逐事件（当key在内存满了被清除时生成）
# A    g$lshzxe的别名，所以”AKE”意味着全部的事件

二、配置服务端

pom.xml

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-redis</artifactId>
            <version>1.4.2.RELEASE</version>
        </dependency>

RedisConfig.java

/**
     * redis监听器
     */
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        log.info("***************************redis监听器初始化***************************");
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        /// container.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired"));
        return container;
    }

 

RedisKeyExpirationListener.java

/**
 * 监听全部db的过时事件__keyevent@*__:expired"
 *
 * @author lsm
 */
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

    private static final Logger log = LoggerFactory.getLogger(RedisKeyExpirationListener.class);

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    /**
     * 针对redis数据失效事件，进行数据处理
     * redis.conf 设置 notify-keyspace-events "Ex"
     *
     * @param message
     * @param pattern
     */
    @Override
    public synchronized void onMessage(Message message, byte[] pattern) {
        // 用户作本身的业务处理便可,注意message.toString()能够获取失效的key
        String expiredKey = message.toString();
        log.info("redis失效key通知:expiredKey={}", expiredKey);
        //若是xxx:开头的key，进行处理
        if (expiredKey.startsWith("orderId")) {
           
        }
    }
}