如何使用Java實現(xiàn)一個簡單的內(nèi)存緩存

本篇內(nèi)容主要講解“如何使用 Java 實現(xiàn)一個簡單的內(nèi)存緩存”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“如何使用 Java 實現(xiàn)一個簡單的內(nèi)存緩存”吧!

10年積累的成都做網(wǎng)站、成都網(wǎng)站制作經(jīng)驗，可以快速應對客戶對網(wǎng)站的新想法和需求。提供各種問題對應的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認識你，你也不認識我。但先網(wǎng)站設(shè)計后付款的網(wǎng)站建設(shè)流程，更有南康免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

1. 場景

在 Java 應用中，對于訪問頻率高，更新少的數(shù)據(jù)，通常的方案是將這類數(shù)據(jù)加入緩存中。相對從數(shù)據(jù)庫中讀取來說，讀緩存效率會有很大提升。
在集群環(huán)境下，常用的分布式緩存有 redis、Memcached 等。但在某些業(yè)務(wù)場景上，可能不需要去搭建一套復雜的分布式緩存系統(tǒng)，在單機環(huán)境下，通常是會希望使用內(nèi)部的緩存（LocalCache）。

2. 方案

基于 JSR107 規(guī)范自研。
基于 ConcurrentHashMap 實現(xiàn)數(shù)據(jù)緩存。

3. JSR107 規(guī)范

文檔：https://jcp.org/en/jsr/detail?id=107（了解一下就行，沒太大的應用）

目標

為應用程序提供緩存 Java 對象的功能。
定義了一套通用的緩存概念和工具。
最小化開發(fā)人員使用緩存的學習成本。
最大化應用程序在使用不同緩存實現(xiàn)之間的可移植性。
支持進程內(nèi)和分布式的緩存實現(xiàn)。

核心概念

Java Caching 定義了 5 個核心接口，分別是 CachingProvider、CacheManager、Cache、Entry 和 Expiry。
CachingProvider 定義了創(chuàng)建、配置、獲取、管理和控制多個 CacheManager。一個應用可以在運行期間訪問多個 CachingProvider。
CacheManager 定義了創(chuàng)建、配置、獲取、管理和控制多個唯一命名的 Cache，這些 Cache 存在于 CacheManager 的上下文中。一個 CacheManager 僅被一個 CachingProvider 所擁有。
Cache 是一個類似 Map 的數(shù)據(jù)結(jié)構(gòu)并臨時存儲以 key 為索引的值。一個 Cache 僅被一個 CacheManager 所擁有。
Entry 是一個存儲在 Cache 中的 key-value 對。
每一個存儲在 Cache 中的條目有一個定義的有效期，即 Expiry Duration。一旦超過這個時間，條目為過期的狀態(tài)。一旦過期，條目將不可訪問、更新和刪除。緩存有效期可以通過 ExpiryPolicy 設(shè)置。

4. 使用 Map 實現(xiàn)一個簡單緩存

package com.study.cache.java;

import java.lang.ref.SoftReference;
import java.util.Optional;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 使用 Map 實現(xiàn)一個簡單的緩存功能
 * @author 華夏紫穹
 */
public class MapCacheDemo {

    // 使用 ConcurrentHashMap，線程安全的要求。
    // 使用 SoftReference<Object> 作為映射值，因為軟引用可以保證在拋出 OutOfMemory 之前，如果缺少內(nèi)存，將刪除引用的對象。
    // 在構(gòu)造函數(shù)中，我創(chuàng)建了一個守護程序線程，每 5 秒掃描一次并清理過期的對象。

    private static final int CLEAN_UP_PERIOD_IN_SEC = 5;

    private final ConcurrentHashMap<String, SoftReference<CacheObject>> cache = new ConcurrentHashMap<>();

    public MapCacheDemo() {
        Thread cleanerThread = new Thread(() -> {
            while (! Thread.currentThread().isInterrupted()) {
                try {
                    Thread.sleep(CLEAN_UP_PERIOD_IN_SEC * 1000);
                    cache.entrySet().removeIf(entry -> Optional.ofNullable(entry.getValue()).map(SoftReference::get).map(CacheObject::isExpired).orElse(false));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        cleanerThread.setDaemon(true);
        cleanerThread.start();
    }

    public void add(String key, Object value, long periodInMillis) {
        if (key == null) { return; }
        if (value == null) { cache.remove(key); }
        long expireTime = System.currentTimeMillis() + periodInMillis;
        cache.put(key, new SoftReference<>(new CacheObject(value, expireTime)));
    }

    public void remove(String key) {
        cache.remove(key);
    }

    public Object get(String key) {
        return Optional.ofNullable(cache.get(key)).map(SoftReference::get).filter(cacheObject -> ! cacheObject.isExpired()).map(CacheObject::getValue).orElse(null);
    }

    public void clear() {
        cache.clear();
    }

    public long size() {
        return cache.entrySet().stream().filter(entry -> Optional.ofNullable(entry.getValue()).map(SoftReference::get).map(cacheObject -> ! cacheObject.isExpired()).orElse(false)).count();
    }


    // 緩存對象 value
    private static class CacheObject {
        private Object value;
        private long expiryTime;

        private CacheObject(Object value, long expiryTime) {
            this.value = value;
            this.expiryTime = expiryTime;
        }

        boolean isExpired() {
            return System.currentTimeMillis() > expiryTime;
        }

        public Object getValue() {
            return value;
        }

        public void setValue(Object value) {
            this.value = value;
        }
    }

}

package com.study.cache.java;

/**
 * MapCache 測試類
 * @author 華夏紫穹
 */
public class MapCacheDemoTests {
    public static void main(String[] args) throws InterruptedException {
        MapCacheDemo mapCacheDemo = new MapCacheDemo();
        mapCacheDemo.add("uid_10001", "{1}", 5 * 1000);
        mapCacheDemo.add("uid_10002", "{2}", 5 * 1000);
        mapCacheDemo.add("uid_10003", "{3}", 5 * 1000);
        System.out.println("從緩存中取出值：" + mapCacheDemo.get("uid_10001"));
        Thread.sleep(5000L);
        System.out.println("5 秒鐘過后");
        System.out.println("從緩存中取出值：" + mapCacheDemo.get("uid_10001"));
        // 5 秒后數(shù)據(jù)自動清除了
    }
}

到此，相信大家對“如何使用 Java 實現(xiàn)一個簡單的內(nèi)存緩存”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學習！

分享題目：如何使用Java實現(xiàn)一個簡單的內(nèi)存緩存
URL鏈接：http://chinadenli.net/article36/jeiesg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計、品牌網(wǎng)站制作、外貿(mào)網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)、企業(yè)建站、微信小程序

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容