Bagaimana untuk menetapkan peta masa tamat tempoh di Jawa

1. Latar belakang teknikal

Dalam pembangunan projek sebenar, kami sering menggunakan caching middleware (seperti redis, MemCache, dll.) untuk membantu kami meningkatkan ketersediaan dan keteguhan sistem.

Tetapi dalam banyak kes, jika projek itu agak mudah, tidak perlu memperkenalkan perisian tengah secara khusus seperti Redis untuk meningkatkan kerumitan sistem untuk menggunakan caching. Jadi adakah Java sendiri mempunyai komponen caching ringan yang berguna?

Jawapannya sudah tentu ya, dan terdapat lebih daripada satu cara. Penyelesaian biasa termasuk: ExpiringMap, LoadingCache dan pembungkusan berasaskan HashMap.

2. Kesan teknikal

• Melaksanakan fungsi biasa cache, seperti strategi pemadaman lapuk

• Memanaskan data tempat liputan

3. ExpiringMap

3.1 Pengenalan Fungsi

• Anda boleh menetapkan Entri dalam Peta untuk tamat tempoh secara automatik selepas tempoh masa.

• boleh menetapkan nilai kapasiti maksimum Peta Apabila saiz Maksimum dicapai, memasukkan nilai sekali lagi akan menyebabkan nilai pertama dalam Peta tamat tempoh.

• Anda boleh menambah acara mendengar dan menghantar fungsi mendengar apabila Entri tamat tempoh.

• Anda boleh menetapkan pemuatan malas untuk mencipta objek apabila kaedah get() dipanggil.

3.2 Kod sumber

alamat github

3.3 Contoh

Tambah kebergantungan (Maven)

<dependency> 
    <groupId>net.jodah</groupId> 
    <artifactId>expiringmap</artifactId> 
    <version>0.5.8</version> 
</dependency>

Contoh kod sumber

public class ExpiringMapApp {

    public static void main(String[] args) {
        // maxSize: 设置最大值,添加第11个entry时，会导致第1个立马过期(即使没到过期时间)
        // expiration：设置每个key有效时间10s, 如果key不设置过期时间，key永久有效。
        // variableExpiration: 允许更新过期时间值,如果不设置variableExpiration，不允许后面更改过期时间,一旦执行更改过期时间操作会抛异常UnsupportedOperationException
        // policy:
        //        CREATED: 只在put和replace方法清零过期时间
        //        ACCESSED: 在CREATED策略基础上增加, 在还没过期时get方法清零过期时间。
        //        清零过期时间也就是重置过期时间，重新计算过期时间.
        ExpiringMap<String, String> map = ExpiringMap.builder()
            .maxSize(10)
            .expiration(10, TimeUnit.SECONDS)
            .variableExpiration().expirationPolicy(ExpirationPolicy.CREATED).build();

        map.put("token", "lkj2412lj1412412nmlkjl2n34l23n4");
        map.put("name", "管理员", 20000, TimeUnit.SECONDS);

        // 模拟线程等待...
        try {
            Thread.sleep(15000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("token ===> " + map.get("token"));
        System.out.println("name ===> " + map.get("name"));

        // 注意： 在创建map时，指定的那些参数如过期时间和过期策略都是全局的, 对map中添加的每一个entry都适用.
        //        在put一个entry键值对时可以对当前entry 单独设置 过期时间、过期策略,只对当前这个entry有效.
    }
}

Hasil berjalan

token ===> null
nama ===> Pentadbir

Nota
Apabila membuat peta, parameter yang ditentukan seperti masa tamat tempoh dan dasar tamat tempoh adalah global dan digunakan pada setiap entri yang ditambahkan pada peta.
Apabila meletakkan pasangan nilai kunci masukan, anda boleh menetapkan masa tamat tempoh dan dasar tamat tempoh secara berasingan untuk entri semasa, yang hanya sah untuk entri semasa.

4 >4.1 Pengenalan Fungsi

Penyelesaian cache tempatan selamat benang yang bersumberkan terbuka oleh Google.

Ciri: Menyediakan mekanisme kitar semula cache, memantau pemuatan cache/status hit, fungsi yang fleksibel dan berkuasa, API yang ringkas dan mudah digunakan.

Contoh 4.2

Kod sumber

public class LoadingCacheApp {

    public static void main(String[] args) throws Exception {
        // maximumSize: 缓存池大小，在缓存项接近该大小时， Guava开始回收旧的缓存项
        // expireAfterAccess: 设置时间对象没有被读/写访问则对象从内存中删除(在另外的线程里面不定期维护)
        // removalListener: 移除监听器,缓存项被移除时会触发的钩子
        // recordStats: 开启Guava Cache的统计功能
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
            .maximumSize(100)
            .expireAfterAccess(10, TimeUnit.SECONDS)
            .removalListener(new RemovalListener<String, String>() {
                @Override
                public void onRemoval(RemovalNotification<String, String> removalNotification) {
                    System.out.println("过时删除的钩子触发了... key ===> " + removalNotification.getKey());
                }
            })
            .recordStats()
            .build(new CacheLoader<String, String>() {
                // 处理缓存键不存在缓存值时的处理逻辑
                @Override
                public String load(String key) throws Exception {
                    return "不存在的key";
                }
            });

        cache.put("name", "小明");
        cache.put("pwd", "112345");

        // 模拟线程等待...
        try {
            Thread.sleep(15000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("token ===> " + cache.get("name"));
        System.out.println("name ===> " + cache.get("pwd"));
    }
}

Hasil berjalan

Kait pemadaman yang lapuk dicetuskan... kekunci ===> 🎜>token ===> Kunci tidak wujud

Cangkuk pemadaman usang dicetuskan... kunci ===> pwd

nama ===>Kunci tidak wujud


4.3 Mekanisme Penyingkiran

Apabila jambu batu menyimpan data cache, terdapat dua jenis penyingkiran data: penyingkiran pasif dan penyingkiran aktif.

Penyingkiran pasif

Penyingkiran berdasarkan saiz: Apabila nombor mencapai saiz yang ditentukan, nilai kunci yang jarang digunakan akan dialih keluar

• Pengalihan keluar berdasarkan masa: expireAfterAccess(long, TimeUnit) mengalih keluar pasangan nilai kunci berdasarkan masa selepas akses terakhir. expireAfterWrite(long, TimeUnit) Alih keluar berdasarkan masa selepas pasangan nilai kunci dibuat atau nilai diganti

• Penyingkiran berasaskan rujukan: terutamanya berdasarkan mekanisme pengumpulan sampah Java pengalihan keluar berdasarkan hubungan rujukan kunci atau nilai

• Pengalihan aktif

Alih keluar secara individu: Cache.invalidate(key)

• Alih keluar kelompok: Cache.invalidateAll(keys)

• Alih keluar semua: Cache.invalidateAll()

• Jika pendengar pengalihan keluar RemovalListener dikonfigurasikan, logik di bawah pendengar ini akan dilaksanakan secara serentak semasa semua tindakan pengalihan keluar.

Jika anda perlu menukar kepada tak segerak, gunakan: RemovalListeners.asynchronous(RemovalListener, Executor).

4.4 Lain

Sebelum operasi letak, jika ia mempunyai Dengan nilai kunci ini, removeListener akan dicetuskan dahulu untuk mengalih keluar pendengar, dan kemudian menambah

• dikonfigurasikan dengan expireAfterAccess dan expireAfterWrite, tetapi ia tidak dialih keluar selepas masa yang ditentukan.

• Logik strategi pemadaman:

• Cache yang dibina oleh CacheBuilder tidak akan melakukan kerja pembersihan dan kitar semula secara automatik pada masa tertentu, begitu juga dilaksanakan pada masa tertentu Item cache dikosongkan serta-merta selepas ia tamat tempoh. Ia tidak memulakan benang untuk penyelenggaraan cache, kerana pertama benang agak berat, dan kedua beberapa persekitaran mengehadkan penciptaan benang.

Ia akan melakukan sedikit kerja penyelenggaraan secara kebetulan semasa operasi tulis, atau sekali-sekala semasa operasi baca. Sudah tentu, anda juga boleh mencipta benang penyelenggaraan anda sendiri dan memanggil Cache.cleanUp() pada selang masa tetap.

Atas ialah kandungan terperinci Bagaimana untuk menetapkan peta masa tamat tempoh di Jawa. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!