package com.ruoyi.web.controller.service;


import org.springframework.beans.factory.annotation.Autowired;
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;

import javax.annotation.PostConstruct;

/**
 * Redis 过期事件监听配置
 */
@Configuration
public class RedisListenerConfig {
    @Autowired
    private VisitorExpireListener visitorExpireListener;

    @Autowired
    private RedisMessageListenerContainer redisMessageListenerContainer;

    /**
     * 订阅 Redis 过期事件
     * 监听所有 Key 的过期事件，在 VisitorExpireListener 中过滤
     */
    @PostConstruct
    public void init() {
        // 订阅 __keyevent@0__:expired 频道（0 表示 db0）
        // 注意：需要根据实际使用的数据库索引修改
        redisMessageListenerContainer.addMessageListener(
                visitorExpireListener,
                new PatternTopic("__keyevent@0__:expired")
        );
    }
}