14 如何监听key过期时间并触发后置逻辑

@Configuration
public class RedisConfig {
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory factory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        return container;
    }
}

@Configuration
public class RedisConfig {
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory factory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        // 订阅特定Key的过期事件（数据库0）
        container.addMessageListener((message, pattern) -> {
            String key = new String(message.getBody());
            if (key.equals("mykey")) {
                // 触发后置逻辑
            }
        }, new PatternTopic("__keyspace@0__:mykey"));
        // 订阅所有数据库的过期事件
        // container.addMessageListener(listener, new PatternTopic("__keyevent@*__:expired"));
        return container;
    }
}

@Component
public class KeyExpiredListener extends KeyExpirationEventMessageListener {
    public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String expiredKey = message.toString();
        // 触发后置逻辑（如订单关闭、资源清理）
        handleExpiredKey(expiredKey);

        // if ("mykey".equals(expiredKey)) {  // 仅处理目标Key
        //     handleExpiredKey(expiredKey);
        // }
    }
}