快捷導(dǎo)航

使用redis實(shí)現(xiàn)延遲通知功能(Redis過(guò)期鍵通知)

更新時(shí)間：2021年09月03日 16:32:55 作者：爪哇_克勞德

這篇文章主要介紹了使用redis實(shí)現(xiàn)延遲通知功能(Redis過(guò)期鍵通知)的相關(guān)知識(shí)，本文通過(guò)實(shí)例代碼圖文相結(jié)合給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友參考下吧

Redis 過(guò)期監(jiān)聽(tīng)場(chǎng)景

業(yè)務(wù)中有類(lèi)似等待一定時(shí)間之后執(zhí)行某種行為的需求 , 比如 30 分鐘之后關(guān)閉訂單 . 網(wǎng)上有很多使用 Redis 過(guò)期監(jiān)聽(tīng)的 Demo

redis配置

把notify-keyspace-events Ex 這一行的注釋打開(kāi)

在這里插入圖片描述

項(xiàng)目demo工程

項(xiàng)目結(jié)構(gòu)如下圖

在這里插入圖片描述

maven依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>kim-redis</artifactId>
        <groupId>com.kim</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>kim-redis-expiration-notice</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

    </dependencies>
</project>

配置文件

server:
  port: 20103

spring:
  redis:
    #數(shù)據(jù)庫(kù)索引
    database: 0
    host: 127.0.0.1
    port: 6379
    password: 123456
    lettuce:
      pool:
        #最大連接數(shù)
        max-active: 8
        #最大阻塞等待時(shí)間(負(fù)數(shù)表示沒(méi)限制)
        max-wait: -1
        #最大空閑
        max-idle: 8
        #最小空閑
        min-idle: 0
    #連接超時(shí)時(shí)間
    timeout: 10000

啟動(dòng)類(lèi)

/**
 * @Project: kim-redis
 * @PackageName: com.kim.redis.expiration.notice
 * @FileName: NoticeApplication.java
 * @Description: The NoticeApplication is...
 * @Author: kimwu
 * @Time: 2020-12-19 14:01:56
 */
@SpringBootApplication
public class NoticeApplication {

    public static void main(String[] args) {
        SpringApplication.run(NoticeApplication.class, args);
    }

}

配置類(lèi)

@Configuration
public class RedisTimeoutConfiguration {

    @Autowired
    private RedisConnectionFactory redisConnectionFactory;

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer() {
        RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
        redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
        return redisMessageListenerContainer;
    }

    @Bean
    public KeyExpiredListener keyExpiredListener() {
        return new KeyExpiredListener(this.redisMessageListenerContainer());
    }
}

監(jiān)聽(tīng)類(lèi)

@Slf4j
public class KeyExpiredListener extends KeyExpirationEventMessageListener {


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

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String channel = new String(message.getChannel(), StandardCharsets.UTF_8);
        //過(guò)期的key
        String key = new String(message.getBody(), StandardCharsets.UTF_8);
        log.info("redis key 過(guò)期：pattern={},channel={},key={}", new String(pattern), channel, key);
    }
}

異常情況測(cè)試

當(dāng)key過(guò)期時(shí)，項(xiàng)目宕機(jī)了
①寫(xiě)入redis的key
②手動(dòng)關(guān)停服務(wù)，等待redis的key過(guò)期
③確認(rèn)redis的key過(guò)期后，重啟服務(wù)。服務(wù)不會(huì)收到通知

當(dāng)key過(guò)期時(shí)，redis服務(wù)宕機(jī)了
①寫(xiě)入redis的key
②關(guān)停redis服務(wù)，等待redis的key過(guò)期
③啟動(dòng)redis服務(wù)，發(fā)現(xiàn)redis的過(guò)期key已經(jīng)不存在了，服務(wù)沒(méi)有收到通知

結(jié)論

redis的鍵過(guò)期本身不可靠，并不像rabbitmq一樣保證了可靠性。
當(dāng)服務(wù)本身宕機(jī)或者redis宕機(jī)時(shí)，將無(wú)法保證過(guò)期的key能夠被消費(fèi)。

當(dāng)使用場(chǎng)景對(duì)數(shù)據(jù)完整性不那么精確時(shí)，可以使用redis的鍵過(guò)期策略。否則不太建議使用redis的鍵過(guò)期策略。

到此這篇關(guān)于使用redis實(shí)現(xiàn)延遲通知功能(Redis過(guò)期鍵通知)的文章就介紹到這了,更多相關(guān)Redis過(guò)期鍵通知內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: