固定大小的先进先出FIFO临时缓存

晓岩 发表于:2018-07-27 15:20 阅读: 215次

今天要实现一个实时设备状态的监控,但是设备状态数据,存入数据库不删除时间长了数据量会太大,不仅浪费空间,还会影响今后的查询。

其实考虑到数据占用空间不大,又是临时数据不需要持久化,,最后写了一个先进先出,固定大小的临时缓存,来存储实时数据。下面记录下代码以备以后使用:

固定大小 FIFO临时缓存实现类

package com.xiangxun.atms.framework.util;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;
/**
 * 固定大小 FIFO临时缓存
 * @author YanTao
 */
public class FIFOMAPS<K, V> {
    private final int MAX_CACHE_SIZE;
    private final float DEFAULT_LOAD_FACTORY = 0.75f;

    LinkedHashMap<K, V> map;

    public FIFOMAPS(int cacheSize) {
        MAX_CACHE_SIZE = cacheSize;
        int capacity = (int)Math.ceil(MAX_CACHE_SIZE / DEFAULT_LOAD_FACTORY) + 1;
        /*
         * 第三个参数设置为true,代表linkedlist按访问顺序排序,可作为LRU缓存
         * 第三个参数设置为false,代表按插入顺序排序,可作为FIFO缓存
         */
        map = new LinkedHashMap<K, V>(capacity, DEFAULT_LOAD_FACTORY, false) {
            @Override
            protected boolean removeEldestEntry(Map.Entry<K, V> eldest) {
                return size() > MAX_CACHE_SIZE;
            }
        };
    }

    public synchronized void put(K key, V value) {
        map.put(key, value);
    }

    public synchronized V get(K key) {
        return map.get(key);
    }

    public synchronized void remove(K key) {
        map.remove(key);
    }

    public synchronized Set<Map.Entry<K, V>> getAll() {
        return map.entrySet();
    }

    @Override
    public String toString() {
        StringBuilder stringBuilder = new StringBuilder();
        for (Map.Entry<K, V> entry : map.entrySet()) {
            stringBuilder.append(String.format("%s: %s  ", entry.getKey(), entry.getValue()));
        }
        return stringBuilder.toString();
    }

}

业务类调用

直接在类级别,初始化这个实现类对象:

public static FIFOMAPS<String, StorageStatusVo> fifomap = new FIFOMAPS<>(60);

我这里是要固定存储60条最新数据,所以参数传入60;然后再业务类接收到数据后,直接使用对象PUT进入临时数据即可;经过测试没任何问题:

fifomap.put(currentDate, vo);
酷码派 [KuMaPai.COM] - 陕ICP备案证 18010024号-2