Redis は期限切れのキーをどのように監視しますか?

最初に質問を見てみましょう:

注文が 30 ドル支払われない場合に注文ステータスを自動的に変更するなど、期限切れによる注文の自動キャンセルを処理する方法分？

解決策:

Redis のナチュラル キーの自動有効期限メカニズムを使用できます。注文するときに、注文 ID を Redis に書き込みます。有効期限は 30 分です。 30 分後の注文ステータス。支払いが行われていない場合は処理されますが、キーの有効期限が切れています。redis から通知はありますか?答えは「はい」です。

redis キーの有効期限リマインダーを有効にする

redis 関連のイベント構成を変更します。 Redis設定ファイルredis.confを見つけて、「notify-keyspace-events」の設定項目を確認します。ない場合は「notify-keyspace-events Ex」を追加します。値がある場合はExを追加します。関連するパラメータは次のように説明されています次のとおりです:

K：keyspace事件，事件以__keyspace@<db>__为前缀进行发布；         
E：keyevent事件，事件以__keyevent@<db>__为前缀进行发布；         
g：一般性的，非特定类型的命令，比如del，expire，rename等；        
$：字符串特定命令；         
l：列表特定命令；         
s：集合特定命令；         
h：哈希特定命令；         
z：有序集合特定命令；         
x：过期事件，当某个键过期并删除时会产生该事件；         
e：驱逐事件，当某个键因maxmemore策略而被删除时，产生该事件；         
A：g$lshzxe的别名，因此”AKE”意味着所有事件。

redis テスト:

redis-cli を開き、db0のキー有効期限イベントを監視します

127.0.0.1:6379> PSUBSCRIBE __keyevent@0__:expired
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "__keyevent@0__:expired"
3) (integer) 1

別の redis-cli を開き、スケジュールされた有効期限キーを送信します

127.0.0.1:6379> setex test_key 3 test_value

前の redis-cli を観察すると、期限切れの keytest_key を受信して​​いることがわかりますが、期限切れの値 test_value

127.0.0.1:6379> PSUBSCRIBE __keyevent@0__:expired
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "__keyevent@0__:expired"
3) (integer) 1
1) "pmessage"
2) "__keyevent@0__:expired"
3) "__keyevent@0__:expired"
4) "test_key"

Use in springboot

依存関係を pom に追加します

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

構成 RedisListenerConfig

import edu.zut.ding.listener.RedisExpiredListener;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.listener.PatternTopic;import org.springframework.data.redis.listener.RedisMessageListenerContainer;/**
 * @Author lsm
 * @Date 2018/10/27 20:56
 */@Configurationpublic class RedisListenerConfig {    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);//        container.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired"));
        return container;
    }
}

定義しますリスナーを定義し、KeyExpirationEventMessageListener インターフェイスを実装します。ソース コードを確認して、このインターフェイスが存在することを確認します。すべての DB 有効期限イベントを監視します keyevent@*:expired"

import edu.zut.ding.constants.SystemConstant;import edu.zut.ding.enums.OrderState;import edu.zut.ding.service.OrderService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.connection.Message;import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;import org.springframework.data.redis.listener.RedisMessageListenerContainer;import org.springframework.stereotype.Component;/**
 * 监听所有db的过期事件__keyevent@*__:expired"
 * @author lsm
 */@Componentpublic class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {        super(listenerContainer);
    }    /**
     * 针对redis数据失效事件，进行数据处理
     * @param message
     * @param pattern
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {        // 用户做自己的业务处理即可,注意message.toString()可以获取失效的key
        String expiredKey = message.toString();        if(expiredKey.startsWith("Order:")){            //如果是Order:开头的key，进行处理
        }
    }
}

または、RedisListenerConfig のcontainer.addMessageListener(new RedisExpiredListener(), new PatternTopic("__keyevent@0__:expired")); コメントを開き、リスナーを作成し、db0 有効期限イベントである __keyevent@0__:expired イベントを監視します。この場所の定義は比較的柔軟で、監視するイベントを定義できます。

以上がRedis は期限切れのキーをどのように監視しますか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。