# 開啟過期事件監(jiān)聽，也可按需指定（如只監(jiān)聽過期+驅(qū)逐：KxKe）
127.0.0.1:6379> config set notify-keyspace-events Ex

K：keyspace 事件，事件以 keyspace@ 為前綴進(jìn)行發(fā)布
E：keyevent 事件，事件以 keyevent@ 為前綴進(jìn)行發(fā)布
g：一般性的，非特定類型的命令，比如del，expire，rename等
$：字符串特定命令
l：列表特定命令
s：集合特定命令
h：哈希特定命令
z：有序集合特定命令
x：過期事件，當(dāng)某個鍵過期并刪除時會產(chǎn)生該事件
e：驅(qū)逐事件，當(dāng)某個鍵鍵因Redis內(nèi)存達(dá)到maxmemory上限，被淘汰策略刪除時觸發(fā)
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;
    }
}

/**
 * 監(jiān)聽所有db的過期事件__keyevent@*__:expired"
 */
@Component
@Slf4j
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

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

    /**
     * 針對 redis 數(shù)據(jù)失效事件，進(jìn)行數(shù)據(jù)處理
     * @param message
     * @param pattern
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 獲取到失效的 key，進(jìn)行取消訂單業(yè)務(wù)處理
        String expiredKey = message.toString();
        log.info("失效的Key:{}", expiredKey);
    }
}

/**
 * 過期事件異步處理線程池配置
 */
@Configuration
@EnableAsync // 開啟異步注解支持
public class RedisEventExecutorConfig {

    /**
     * 自定義線程池，處理過期事件的業(yè)務(wù)邏輯
     */
    @Bean("redisExpireEventExecutor")
    public Executor redisExpireEventExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心線程數(shù)（根據(jù)業(yè)務(wù)壓力調(diào)整）
        executor.setCorePoolSize(5);
        // 最大線程數(shù)
        executor.setMaxPoolSize(20);
        // 隊列容量（緩沖待處理的任務(wù)）
        executor.setQueueCapacity(1000);
        // 線程名前綴（便于日志排查）
        executor.setThreadNamePrefix("redis-expire-event-");
        // 拒絕策略：隊列滿+線程數(shù)到最大時，由提交任務(wù)的線程執(zhí)行（避免任務(wù)丟失）
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 線程空閑超時時間
        executor.setKeepAliveSeconds(60);
        // 初始化線程池
        executor.initialize();
        return executor;
    }
}

// 在監(jiān)聽類中調(diào)用
@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);
    // 設(shè)置監(jiān)聽線程池的核心參數(shù)（默認(rèn)線程數(shù)可能不足）
    container.setTaskExecutor(new ThreadPoolTaskExecutor() {{
        setCorePoolSize(3); // 監(jiān)聽線程數(shù)，根據(jù)事件量調(diào)整
        setMaxPoolSize(5);
        setThreadNamePrefix("redis-listener-");
        initialize();
    }});
    return container;
}