SpringBoot监听Redis Key过期事件的几种方式

# 开启过期事件监听，也可按需指定（如只监听过期+驱逐：KxKe）
127.0.0.1:6379> config set notify-keyspace-events Ex

K：keyspace 事件，事件以 keyspace@ 为前缀进行发布
E：keyevent 事件，事件以 keyevent@ 为前缀进行发布
g：一般性的，非特定类型的命令，比如del，expire，rename等
$：字符串特定命令
l：列表特定命令
s：集合特定命令
h：哈希特定命令
z：有序集合特定命令
x：过期事件，当某个键过期并删除时会产生该事件
e：驱逐事件，当某个键键因Redis内存达到maxmemory上限，被淘汰策略删除时触发
A：g$lshzxe的别名，因此”AKE”意味着所有事件

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

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.RedisMessageListenerContainer;
@Configuration
public class RedisListenerConfig {
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }
}

/**
 * 监听所有db的过期事件__keyevent@*__:expired"
 */
@Component
@Slf4j
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

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

    /**
     * 针对 redis 数据失效事件，进行数据处理
     * @param message
     * @param pattern
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 获取到失效的 key，进行取消订单业务处理
        String expiredKey = message.toString();
        log.info("失效的Key:{}", expiredKey);
    }
}

/**
 * 过期事件异步处理线程池配置
 */
@Configuration
@EnableAsync // 开启异步注解支持
public class RedisEventExecutorConfig {

    /**
     * 自定义线程池，处理过期事件的业务逻辑
     */
    @Bean("redisExpireEventExecutor")
    public Executor redisExpireEventExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心线程数（根据业务压力调整）
        executor.setCorePoolSize(5);
        // 最大线程数
        executor.setMaxPoolSize(20);
        // 队列容量（缓冲待处理的任务）
        executor.setQueueCapacity(1000);
        // 线程名前缀（便于日志排查）
        executor.setThreadNamePrefix("redis-expire-event-");
        // 拒绝策略：队列满+线程数到最大时，由提交任务的线程执行（避免任务丢失）
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 线程空闲超时时间
        executor.setKeepAliveSeconds(60);
        // 初始化线程池
        executor.initialize();
        return executor;
    }
}

// 在监听类中调用
@Component
public class RedisExpireBusinessService {
    
    @Async("redisExpireEventExecutor")
    public void handleExpiredKeyAsync(String expiredKey) {
        try {
            System.out.println("异步处理过期key：" + expiredKey + "，线程：" + Thread.currentThread().getName());
        } catch (Exception e) {
            System.err.println("处理过期key失败：" + expiredKey + "，异常：" + e.getMessage());
        }
    }
}

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    // 设置监听线程池的核心参数（默认线程数可能不足）
    container.setTaskExecutor(new ThreadPoolTaskExecutor() {{
        setCorePoolSize(3); // 监听线程数，根据事件量调整
        setMaxPoolSize(5);
        setThreadNamePrefix("redis-listener-");
        initialize();
    }});
    return container;
}