SpringBoot 監(jiān)聽Redis鍵過(guò)期事件(過(guò)期監(jiān)聽)

更新時(shí)間：2024年12月24日 10:54:03 作者：生產(chǎn)隊(duì)的驢.

Redis鍵過(guò)期事件是SpringBoot中常用的緩存失效通知方式,通過(guò)配置可以監(jiān)聽特定鍵的過(guò)期事件,具有一定的參考價(jià)值,感興趣的可以了解一下

介紹

Redis 鍵過(guò)期事件是 Redis 中非常有用的功能，可以在鍵過(guò)期時(shí)觸發(fā)事件通知。這對(duì)于緩存失效、會(huì)話管理、定時(shí)任務(wù)等場(chǎng)景非常有用。

Redis配置

Redis 默認(rèn)是沒(méi)有啟用鍵過(guò)期事件通知的，你需要通過(guò)配置來(lái)啟用這個(gè)功能。可以通過(guò)修改 redis.conf 文件或者使用 CONFIG SET 命令來(lái)啟用鍵過(guò)期事件通知。

notify-keyspace-events Ex

依賴

<!--        操作redis-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置文件

spring:
  redis:
    host: localhost
    port: 6379
    #password: 用的本機(jī)的redis，并且我沒(méi)有設(shè)置redis密碼
    database: 0
    lettuce:
      pool:
        # 最大阻塞等待時(shí)間，負(fù)數(shù)表示沒(méi)有限制
        max-wait: -1
        # 連接池中的最大空閑連接
        max-idle: 5
        # 連接池中的最小空閑連接
        min-idle: 0
        # 連接池中最大連接數(shù)，負(fù)數(shù)表示沒(méi)有限制

寫入鍵

@RestController
@RequiredArgsConstructor
public class BasicController {
    private final StringRedisTemplate stringRedisTemplate;
    @GetMapping("/hello")
    public String hello() {
        // 設(shè)置鍵值對(duì)，并指定過(guò)期時(shí)間為 10 秒
        stringRedisTemplate.opsForValue().set("product:123", "dpc", Duration.ofSeconds(5));
        // 獲取值
        String str = stringRedisTemplate.opsForValue().get("name");
        System.out.println("Value: " + str);
        return str;
    }
}

配置監(jiān)聽器

@Configuration
public class RedisListenerConfig {

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }

    @Bean
    public OrderKeyExpirationListener orderKeyExpirationListener(RedisMessageListenerContainer container) {
        // 配置監(jiān)聽器只監(jiān)聽 `order:*` 鍵
        OrderKeyExpirationListener listener = new OrderKeyExpirationListener(container);
        container.addMessageListener(listener, new ChannelTopic("__keyevent@0__:expired"));
        return listener;
    }

    @Bean
    public SessionKeyExpirationListener sessionKeyExpirationListener(RedisMessageListenerContainer container) {
        // 配置監(jiān)聽器只監(jiān)聽 `session:*` 鍵
        SessionKeyExpirationListener listener = new SessionKeyExpirationListener(container);
        container.addMessageListener(listener, new ChannelTopic("__keyevent@0__:expired"));
        return listener;
    }

    @Bean
    public ProductKeyExpirationListener productKeyExpirationListener(RedisMessageListenerContainer container) {
        // 配置監(jiān)聽器只監(jiān)聽 `product:*` 鍵
        ProductKeyExpirationListener listener = new ProductKeyExpirationListener(container);
        container.addMessageListener(listener, new ChannelTopic("__keyevent@0__:expired"));
        return listener;
    }


}

按KEY監(jiān)聽

監(jiān)聽session鍵

@Slf4j
public class SessionKeyExpirationListener extends KeyExpirationEventMessageListener {

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

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String key = message.toString();
        if (key.startsWith("session:")) {
            log.info("會(huì)話【" + key + "】已過(guò)期");
            // 處理會(huì)話超時(shí)的邏輯
        }
    }
}

監(jiān)聽product鍵

@Slf4j
public class ProductKeyExpirationListener extends KeyExpirationEventMessageListener {
    public ProductKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String key = message.toString();
        if (key.startsWith("product:")) {
            log.info("產(chǎn)品【" + key + "】已過(guò)期");
            // 處理產(chǎn)品相關(guān)的超時(shí)邏輯
        }
    }
}

監(jiān)聽order鍵

public class OrderKeyExpirationListener extends KeyExpirationEventMessageListener {

    public OrderKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    @Override
    public void onMessage(Message message, byte[] pattern) {
        String key = message.toString();
        System.out.println(123);
        if (key.startsWith("order:")) {
            // 處理訂單相關(guān)的超時(shí)邏輯
        }
    }
}

到此這篇關(guān)于SpringBoot 監(jiān)聽Redis鍵過(guò)期事件(過(guò)期監(jiān)聽)的文章就介紹到這了,更多相關(guān)SpringBoot 監(jiān)聽Redis過(guò)期內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: