如何使用Java實現一個簡單的內存緩存

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

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

1. 場景

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

2. 方案

基于 JSR107 規范自研。
基于 ConcurrentHashMap 實現數據緩存。

3. JSR107 規范

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

目標

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

核心概念

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

4. 使用 Map 實現一個簡單緩存

package com.study.cache.java;

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

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

    // 使用 ConcurrentHashMap，線程安全的要求。
    // 使用 SoftReference<Object> 作為映射值，因為軟引用可以保證在拋出 OutOfMemory 之前，如果缺少內存，將刪除引用的對象。
    // 在構造函數中，我創建了一個守護程序線程，每 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 秒后數據自動清除了
    }
}

到此，相信大家對“如何使用 Java 實現一個簡單的內存緩存”有了更深的了解，不妨來實際操作一番吧！這里是創新互聯網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！

分享題目：如何使用Java實現一個簡單的內存緩存
URL鏈接：http://m.newbst.com/article36/jeiesg.html

成都網站建設公司_創新互聯，為您提供App設計、品牌網站制作、外貿網站建設、營銷型網站建設、企業建站、微信小程序

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

猜你還喜歡下面的內容