Redis開發 —— 過期消息通知實現（Springboot）

實際在我們開發過程中，有一些業務場景需要能夠在一段時間之后能自動變更數據狀態，如優惠券，特價商品，購物車等，這個時候如果實現基於redis，就可以使用下面的方案。

一，在系統添加配置類

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.RedisMessageListenerContainer;

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

 

二，添加對應的業務實現監聽器

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;

import java.io.File;

/**
 * redis 消息過期異步通知監聽器
 *
 * */
@Component
public class RedisMessageListener extends KeyExpirationEventMessageListener {

    private static Logger logger = LoggerFactory.getLogger(RedisMessageListener.class);

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

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

    @Override
    public void onMessage(Message message, byte[] pattern) {
        logger.info("收到 redis 過期異步通知：{}", message.toString());

        String redisKey = (String) redisTemplate.getValueSerializer().deserialize(message.getBody());
        logger.info("redisKey : {}", redisKey);

        //針對特定的key進行處理
        if (redisKey.startsWith("rediskey")){
            try {
              //TODO


            }catch (Exception exp){
                logger.info("業務處理失敗：" + exp.getMessage());
            }
        }
    }
}

 

三，針對業務實現對應過期消息的處理

        在TODO的標識上面，針對不同業務設置的redis key，分成多個業務處理。建議key的設置使用 XXX:XXX:XXX 這種模式 eg：saas:file:key:業務參數，效果如圖所示：

 

 

上述方法若有錯誤問題，請給我留言一下。