真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

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

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

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

1. 場景

  • 在 Java 應(yīng)用中，對于訪問頻率高，更新少的數(shù)據(jù)，通常的方案是將這類數(shù)據(jù)加入緩存中。相對從數(shù)據(jù)庫中讀取來說，讀緩存效率會有很大提升。

  • 在集群環(huán)境下，常用的分布式緩存有 redis、Memcached 等。但在某些業(yè)務(wù)場景上，可能不需要去搭建一套復(fù)雜的分布式緩存系統(tǒng)，在單機(jī)環(huán)境下，通常是會希望使用內(nèi)部的緩存（LocalCache）。

2. 方案

  • 基于 JSR107 規(guī)范自研。

  • 基于 ConcurrentHashMap 實現(xiàn)數(shù)據(jù)緩存。

3. JSR107 規(guī)范

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

目標(biāo)

  • 為應(yīng)用程序提供緩存 Java 對象的功能。

  • 定義了一套通用的緩存概念和工具。

  • 最小化開發(fā)人員使用緩存的學(xué)習(xí)成本。

  • 最大化應(yīng)用程序在使用不同緩存實現(xiàn)之間的可移植性。

  • 支持進(jìn)程內(nèi)和分布式的緩存實現(xiàn)。

核心概念

  • Java Caching 定義了 5 個核心接口，分別是 CachingProvider、CacheManager、Cache、Entry 和 Expiry。

  • CachingProvider 定義了創(chuàng)建、配置、獲取、管理和控制多個 CacheManager。一個應(yīng)用可以在運(yùn)行期間訪問多個 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 作為映射值，因為軟引用可以保證在拋出 OutOfMemory 之前，如果缺少內(nèi)存，將刪除引用的對象。
    // 在構(gòu)造函數(shù)中，我創(chuàng)建了一個守護(hù)程序線程，每 5 秒掃描一次并清理過期的對象。

    private static final int CLEAN_UP_PERIOD_IN_SEC = 5;

    private final ConcurrentHashMap> 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)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！
            
            
                        

            分享標(biāo)題：如何使用Java實現(xiàn)一個簡單的內(nèi)存緩存            

            鏈接地址：http://weahome.cn/article/jeiesg.html
        
    






    

        

            
                
                
在線咨詢

            
        

    

    

        
微信咨詢

        

    

    

        
電話咨詢

        

            
028-86922220（工作日）

            
18980820575（7×24）

        

    

    

        

            
                
提交需求

            
        

    

    

        

            
                
返回頂部