Redisキャッシュの有効期限切れイベントのリスニング

多くのビジネスシーンでは、受注が期限切れになると自動的に削除され、受注が数日後に自動的に評価されます.これらの一般的な操作は、タイミングタスク、データベースポーリングで行うことができますが、受注量が大きい場合はデータベースに大きな圧力をかける可能性があります.
そこで今日紹介するのがredisキャッシュの期限切れ通知です.
1.イベントはRedisのサブスクリプションとパブリケーション機能(pub/sub)によって配布されるため、redisのイベントリスニングとパブリケーションを開く必要がある
2.redisを修正する.confファイル
notify-keyspace-events Exのコメントを開き、期限切れ通知機能を開く

#           
notify-keyspace-events Ex

3.redisを再起動すると、失効イベントのトリガをテストでき、傍受で取得した値はkey
redis-clientに入り、リスニングに入ります

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

redis-clientをもう1つ開き、期限切れのデータを送信します.

127.0.0.1:6379> setex test 2 2
OK

 
前のclientを返し、期限切れのイベントをリスニングします.

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

これでredis環境の構成が完了しました.
次に、サービス・エンド・コンフィギュレーションのリスニング・イベントを示します.

/**
 * Description: Redis     
 * User: zhouzhou
 * Date: 2019-04-07
 * Time: 9:02 PM
 */
@Service
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {


    private static Logger log = LoggerFactory.getLogger(RedisKeyExpirationListener.class);

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

    @Override
    public void onMessage(Message message, byte[] pattern) {
        //     key
        String expireKey = message.toString();
        System.out.println("     ");
        log.debug("key is:"+ expireKey);
        System.out.println(expireKey);

    }
}

Redisリモートリスニング構成の構成:

/**
 * Description: redis     
 * User: zhouzhou
 * Date: 2019-04-17
 * Time: 3:04 PM
 */
@Configuration
public class RedisListenerConfig {


    @Bean
    RedisMessageListenerContainer listenerContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
        listenerContainer.setConnectionFactory(connectionFactory);
        return listenerContainer;
    }

    @Bean
    KeyExpirationEventMessageListener redisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        return new RedisKeyExpirationListener(listenerContainer);
    }

    
}

redis接続の構成はもう出しません.
プロジェクトを開始し、redis-clientに再合格してテストします.コンソールがログを印刷するのを見ることができます.

     
test