Événement déclencheur de clé expirée - Spring data Redis

Question

J'essaie de mettre en place un gestionnaire d'événement d'expiration de clé en utilisant spring data redis mais je n'arrive pas à le faire fonctionner. J'ai fait quelques recherches mais je n'ai pas obtenu les résultats escomptés. Je ne suis pas sûr de savoir ce qui me manque. J'aimerais recevoir un message lorsque la clé sur le cache redis expire.

@Configuration
@EnableRedisRepositories
public class RedisConfig {

    @Bean 
    StringRedisTemplate stringRedisTemplate(){
        StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(jedisConnectionFactory());
        return stringRedisTemplate;
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        RedisMessageListenerContainer container 
          = new RedisMessageListenerContainer(); 
        container.setConnectionFactory(jedisConnectionFactory()); 
        container.addMessageListener(messageListener(), topic()); 
        return container; 
    }

    @Bean
    MessageListenerAdapter messageListener() { 
        return new MessageListenerAdapter(new RedisMessageSubscriber());
    }

    @Bean
    MessagePublisher redisPublisher() { 
        return new RedisMessagePublisher();
    }

    @Bean
    ChannelTopic topic() {
        return new ChannelTopic("messageQueue");
    }
}

public interface MessagePublisher {
    void publish(String message);
}

public class RedisMessagePublisher implements MessagePublisher {

    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    @Autowired
    private ChannelTopic topic;

    public void publish(String message) {
        stringRedisTemplate.convertAndSend(topic.getTopic(), message);
    }
}

@Service
public class RedisMessageSubscriber implements MessageListener {

    private static final Logger LOG = Logger.getLogger(RedisMessageSubscriber.class);

    public static List<String> messageList = new ArrayList<String>();

    @Override
    public void onMessage(Message message, byte[] pattern) {
        messageList.add(message.toString());
    }

}

Quelqu'un peut-il nous aider ? Merci de votre compréhension.

Answer 1

Dans un premier temps, il faut activer la notification de l'espace-clé pour l'événement expire dans redis. Par défaut, les notifications des événements de l'espace-clé sont désactivées car, bien que peu sensible, cette fonctionnalité utilise une partie de la puissance du processeur. Les notifications sont activées en utilisant la fonction notify-keyspace-events du fichier redis.conf ou via la commande CONFIG SET.

notify-keyspace-events "Ex"

Lorsque vous avez terminé avec redis, vous devez configurer votre message listener avec un pattern topic "__keyevent@*__:expired" . Voici l'exemple de code.

Classe d'auditeurs :

@Component
public class ExpirationListener implements MessageListener {
    private static final Logger logger = LoggerFactory.getLogger(ExpirationListener.class);

    @Override
    public void onMessage(Message message, byte[] bytes) {
        String key = new String(message.getBody());
        logger.debug("expired key: {}", key);
    }
}

Configuration :

@Bean
RedisMessageListenerContainer keyExpirationListenerContainer(RedisConnectionFactory connectionFactory, ExpirationListener expirationListener) {
    RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
    listenerContainer.setConnectionFactory(connectionFactory);
    listenerContainer.addMessageListener(expirationListener, new PatternTopic("__keyevent@*__:expired"));
    listenerContainer.setErrorHandler(e -> logger.error("There was an error in redis key expiration listener container", e));
    return listenerContainer;
}