快捷導(dǎo)航

詳解Redis緩存預(yù)熱的實現(xiàn)方法

更新時間：2023年10月10日 11:11:00 作者：vker

緩存預(yù)熱是一種在程序啟動或緩存失效之后,主動將熱點數(shù)據(jù)加載到緩存中的策略,本文將給大家分享一下如何實現(xiàn)Redis的緩存預(yù)熱,文中有詳細(xì)的實現(xiàn)代碼,需要的朋友可以參考下

什么是緩存預(yù)熱？

緩存預(yù)熱是一種在程序啟動或緩存失效之后，主動將熱點數(shù)據(jù)加載到緩存中的策略。這樣，在實際請求到達(dá)程序時，熱點數(shù)據(jù)已經(jīng)存在于緩存中，從而減少了緩存穿透和緩存擊穿的情況，也緩解了SQL服務(wù)器的壓力。

實現(xiàn)

緩存抽象類

首先我們先來實現(xiàn)一個緩存抽象類，這個抽象類的作用就是在將來我們需要將某個模塊的數(shù)據(jù)需要提前加載到緩存中的時候，我們可以創(chuàng)建一個它的實現(xiàn)類，來進(jìn)行數(shù)據(jù)的緩存與加載，具體使用方式請看后邊我寫的例子。

public abstract class AbstractCache {
    /**
     * 緩存
     */
    protected abstract void init();
    /**
     * 獲取緩存
     *
     * @param <T>
     * @return
     */
    public abstract <T> T get();
    /**
     * 清理緩存
     */
    public abstract void clear();
    /**
     * 重新加載
     */
    public void reload() {
        clear();
        init();
    }
}

Spring上下文工具類

接下來我們實現(xiàn)一個Spring的上下文工具類，這個工具類需要實現(xiàn)ApplicationContextAware，作用就是負(fù)責(zé)管理bean的加載與實例化的，具體如何使用，請往下繼續(xù)閱讀。

@Component
public class ApplicationContextUtil implements ApplicationContextAware {
    private static ApplicationContext applicationContext;
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        ApplicationContextUtil.applicationContext = applicationContext;
    }
    /**
     * 獲取上下文
     * @return
     */
    public static ApplicationContext getContext() {
        return applicationContext;
    }
}

緩存預(yù)熱

然后我們來實現(xiàn)，在程序啟動后，直接進(jìn)行數(shù)據(jù)的緩存加載，這個類需要實現(xiàn)CommandLineRunner接口，這個接口提供的方法作用就是在程序啟動后自動運行。這個實現(xiàn)類里，我們使用ApplicationContextUtil工具類來獲取上下文，然后通過getBeansOfType方法獲取實現(xiàn)AbstractCache抽象類的子類，返回的是一個Map類型的集合，接下來通過getBean方法以多態(tài)的方式實例化子類，最后我們調(diào)用抽象類的init方法即可。如果有多個實現(xiàn)類，使用@Order注解標(biāo)注先后運行就可以了。

@Component
@ConditionalOnProperty(name = {"cache.init.enable"}, havingValue = "true", matchIfMissing = false)
public class CachePreheatHandler implements CommandLineRunner {
    /**
     * 緩存預(yù)熱
     * @param args
     * @throws Exception
     */
    @Override
    public void run(String... args) throws Exception {
        ApplicationContext context = ApplicationContextUtil.getContext();
        Map<String, AbstractCache> beansOfType = context.getBeansOfType(AbstractCache.class);
        for (Map.Entry<String, AbstractCache> cacheEntry : beansOfType.entrySet()) {
            AbstractCache cache = context.getBean(cacheEntry.getValue().getClass());
            cache.init();
        }
    }
}

解釋：

@ConditionalOnProperty這個注解在這里的作用是，需要在配置文件開啟cache.init.enable，理想值是true，默認(rèn)值是false。

cache.init.enable=true

使用

我們就以新聞熱點為例，數(shù)據(jù)庫中有一張tb_news新聞表，均為微博熱搜體育榜內(nèi)容。

接下來創(chuàng)建一個AbstractCache的實現(xiàn)類，來實現(xiàn)具體的實現(xiàn)

@Component
@RequiredArgsConstructor
public class NewsCache extends AbstractCache {
    private static final String NEWS_KEY = "news";
    private final RedisTemplate<String, Object> redisTemplate;
    private final NewsService newsService;
    @Override
    protected void init() {
        if (Boolean.FALSE.equals(redisTemplate.hasKey(NEWS_KEY))) {
            redisTemplate.opsForValue().set(NEWS_KEY, newsService.list(), 30, TimeUnit.MINUTES);
        }
    }
    @Override
    public <T> T get() {
        if (Boolean.FALSE.equals(redisTemplate.hasKey(NEWS_KEY))) {
            reload();
        }
        return (T) redisTemplate.opsForValue().get(NEWS_KEY);
    }
    @Override
    public void clear() {
        redisTemplate.delete(NEWS_KEY);
    }
}

然后啟動項目，我們就發(fā)現(xiàn)，Redis中已經(jīng)存好了熱點數(shù)據(jù)

最后可以通過get方法獲取數(shù)據(jù)了，也不用擔(dān)心數(shù)據(jù)過期了。

@RestController
@RequestMapping("/news")
@RequiredArgsConstructor
public class NewsController {
    private final NewsCache newsCache;
    @GetMapping("/cache")
    public List<News> list() {
        return newsCache.get();
    }
}

好了，小伙伴們，今天的分享就到此結(jié)束了，歡迎留出建議，如果覺得內(nèi)容可以，還請來個點贊和關(guān)注吧！

以上就是詳解Redis緩存預(yù)熱的實現(xiàn)方法的詳細(xì)內(nèi)容，更多關(guān)于Redis緩存預(yù)熱的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: