RedisMessageListenerContainer 监听redis的key的变化

在Spring中，你可以使用RedisMessageListenerContainer来监听Redis中key的变化。以下是一个基本的例子，展示了如何配置RedisMessageListenerContainer来监听特定的key。

首先，你需要配置一个JedisConnectionFactory和RedisMessageListenerContainer。

@Configuration
public class RedisConfig {
 
    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        return new JedisConnectionFactory();
    }
 
    @Bean
    RedisMessageListenerContainer redisContainer() {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(jedisConnectionFactory());
        return container;
    }
}

然后，你需要实现一个MessageListener接口来处理key变化事件。

@Component
public class MyMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 这里可以根据message和pattern来处理key的变化
        String receivedMessage = new String(message.getBody());
        System.out.println("Received Message: " + receivedMessage);
    }
}

最后，你需要将你的MessageListener注册到RedisMessageListenerContainer。

@Autowired
private RedisMessageListenerContainer redisContainer;
 
@Autowired
private MessageListener myMessageListener;
 
@PostConstruct
public void postConstruct() {
    // 这里假设你想监听所有的key变化
    redisContainer.addMessageListener(myMessageListener, new PatternTopic("__keyevent@0__:set"));
}

在这个例子中，我们监听了所有数据库（这里是数据库0）中key被设置时的事件（set）。你可以根据需要监听其他类型的事件，如delete、expired等。