读取缓存模拟----FIFO

本例是模拟缓存的存储和读取。

存储:使用一个Map来存放,key是文件名,值为缓存对象

读取:返回相应的key对应的缓存。(如果缓存被修改,就重新加载缓存,再从缓存Map中读取相应缓存)

测试类:每2秒去获取一次缓存日期,如果文件更新了,则会返回新的缓存日期

ReloadHandler :
/**
 * 重新加载接口
 *
 */
public interface ReloadHandler {
    /**
     * 分析文件
     * @return 要缓存的内容
     */
    Object processNewCache() throws Exception;
}  

 

FileCache :
/**
 * <pre>
 * final 外部对象操作时:
 * 通过文件名 -- 在map中找到对应 -- 判断是否修改 --否 -- 返回缓存对象
 *                  |
 *                  是
 *                  |
 *          调用reload,根据传入的handler进行reload,更新缓存对象,更新操作时间
 * </pre>
 *
 */
public class FileCache {
    /** 缓存map */
    private static Map<String, CacheElement> cacheMap = new HashMap<String, CacheElement>();
    private static FileCache fileCache;
    private static final int MAX_SIZE = 20;
    private Queue<String> fileQueue = new LinkedList<String>();

    /**
     * 单例,多线程一样自信
     *
     * @return fileCache单例
     */
    public static FileCache getInstance() {
        if (null == fileCache) {
            fileCache = new FileCache();
        }
        return fileCache;
    }

    /**
     * 获取缓存对象 获取缓存,如果文件被修改,则重新加载最近配置,内存中超过20个文件缓存,会自动清理
     *
     * @param fileName
     * @return
     * @throws Exception
     */
    public Object getCache(String fileName, ReloadHandler handler) throws Exception {
        fileName = fileName.trim();
        if (isModified(fileName)) {
            reLoad(fileName, handler);
        }
        return cacheMap.get(fileName).getCache();
    }

    /**
     * 重新加载
     *
     * @param fileName
     * @param handler
     * @throws Exception
     */
    private void reLoad(String fileName, ReloadHandler handler) throws Exception {
        CacheElement ele = cacheMap.get(fileName);
        if (null == ele) {
            // 文件没有加载过
            ele = new CacheElement();
            // 设置File对象
            ele.setFile(new File(fileName));
            cacheMap.put(fileName, ele);
            // 添加新的缓存,记录到队列中
            if (!fileQueue.contains(fileName)) {
                // 如果队列中没记录这个,则试图添加并进行清理
                cacheClean();
                fileQueue.add(fileName);
            }
        }
        // 更新缓存
        ele.setCache(handler.processNewCache());
        // 更新修改时间
        ele.setLastEditTime(ele.getFile().lastModified());

    }

    /**
     * 判断是否已经修改
     *
     * @param fileName
     * @return
     */
    private boolean isModified(String fileName) {

        CacheElement cacheElement = cacheMap.get(fileName);
        if (null == cacheElement) {
            // 配置文件没有被加载过
            return true;
        }
        if (cacheElement.getFile().lastModified() != cacheElement.getLastEditTime()) {
            // 被修改
            return true;
        }
        // 没有变化
        return false;
    }

    /**
     * FIFO 清理缓存,
     */
    private void cacheClean() {
        // 缓存超过限制之后,进行清理
        if (fileQueue.size() >= MAX_SIZE) {
            String fileName = fileQueue.poll();
            cacheMap.put(fileName, null);
            cacheMap.remove(fileName);
        }
    }

    // 私有构造
    private FileCache() {
    }

    /**
     * 缓存元素
     *
     */
    class CacheElement {

        public long lastEditTime;
        public File file;
        public Object cache;

        public long getLastEditTime() {

            return lastEditTime;
        }

        public void setLastEditTime(long lastEditTime) {

            this.lastEditTime = lastEditTime;
        }

        public File getFile() {
            return file;
        }

        public void setFile(File file) {
            this.file = file;
        }

        public Object getCache() {
            return cache;
        }

        public void setCache(Object cache) {
            this.cache = cache;
        }

    }
}

测试类:

/**
 * 每2秒去获取一次缓存日期,如果文件更新了,则会返回新的缓存日期
 */
public class CacheTest {

    @Test
    public void getFileContent() {

        int count = 10;
        while (count-- > 0) {
            try {
                getCache();
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    private void getCache() throws Exception {

        Date date = (Date) FileCache.getInstance().getCache("d:/1.txt", new ReloadHandler() {
            @Override
            public Object processNewCache() {
                System.out.print("find change  ");
                return new Date();
            }
        });
        System.out.println("cacheData:" + date);
    }
}

测试方法:

在D盘新建一个1.txt,启动测试类,在程序运行中去更改1.txt中的内容,将得到如下结果:

find change cacheData:Thu Dec 25 15:15:12 CST 2014
cacheData:Thu Dec 25 15:15:12 CST 2014
cacheData:Thu Dec 25 15:15:12 CST 2014
cacheData:Thu Dec 25 15:15:12 CST 2014
find change cacheData:Thu Dec 25 15:15:20 CST 2014
cacheData:Thu Dec 25 15:15:20 CST 2014
cacheData:Thu Dec 25 15:15:20 CST 2014
cacheData:Thu Dec 25 15:15:20 CST 2014
cacheData:Thu Dec 25 15:15:20 CST 2014
cacheData:Thu Dec 25 15:15:20 CST 2014

<转:http://qihigh-hotmail-com.iteye.com/blog/1329702>

时间: 2024-10-13 15:29:17

读取缓存模拟----FIFO的相关文章

Java实现缓存(LRU,FIFO)

吹吹牛逼,晒晒太阳.不如来写点东西,哈哈哈哈哈....今天来说说,如何用java实现缓存,这个话题很多面试的也会被问到.今天就来说说. 1.为什么要java实现缓存的? 由于目前软件或网页的并发量增加很大,大量请求直接操作数据库,会对数据造成很大的压力.处理大量请求和连接时间会很长.而我们知道数据库中70%的数据是不需要修改的,那就可以引入缓存来进行读取,减少数据库的压力. 常用的缓存有Redis和memcached,但是有时候一些小场景就可以直接使用Java实现缓存,就可以满足这部分服务的需求

PHP 开发 APP 接口 学习笔记与总结 - APP 接口实例 [3] 首页 APP 接口开发方案 ② 读取缓存方式

以静态缓存为例. 修改 file.php line:11 去掉 path 参数(方便),加上缓存时间参数: public function cacheData($k,$v = '',$cacheTime = 0){ //文件名 $filename = $this->_dir.$k.'.'.self::EXT; ..... line:25 把缓存时间设置为 11 位的数字,如果不满 11 位,则在时间前面补 0.再把缓存时间和缓存内容进行拼接: $cacheTime = sprintf('%011

云计算之路-阿里云上:读取缓存时的“黑色0.1秒”

看到标题中的"0.1秒",你也许会呲之以鼻:不会吧,0.1秒也要计较,不是吃饱撑着,是没吃饱也撑着. 依然没撑着!在memcached应用场景中,响应速度是处于1ms级别的,0.1s可是比1ms慢了100倍啊. 如果你不相信1ms级别,请看这篇文章(微博CacheService架构浅析)中的一段话: 目前微博平台部分业务子系统的Cache服务已经迁移到了CacheService之上,它在实际的运行过程中也取得了良好的性能表现,目前整个集群在线上每天支撑着超过300W的QPS,平均响应耗

小蚂蚁学习APP接口开发(7)—— APP接口实例——读取缓存方式开发APP接口的代码案例

从数据库中直接读取数据,虽然时效性很强,但是对数据库造成很大压力,尤其是在高访问量的情况下.这时候可以通过缓存,来有效的缓解了这一压力,虽然时效性有些不足,但是服务器的抗压能力却达到了很大的提高. 读取缓存方式的中心思想: 当请求进来时,先查看是否有缓存,如果有并且缓存还在有效时间内,不再查询数据库,直接返回缓存即可:如果没有或者已经过了有效时间,查询数据库,返回数据,同时生成一份新的缓存,供以后使用. 代码案例,还是在前几天的代码基础上进行改造完善. File静态缓存类    (原来的代码请参

数据缓存器FIFO IP核调取及应用

写在前面的话 在项目设计中,我们通常需要在两个模块之间传输数据,如果两个模块的数据处理速率相同,那么自然没有任何问题,直接数据对接就可以.但是,如果两个模块的数据处理速度不同呢?数据接收模块和数据发送模块的速度不一致,必然会导致采集数据的遗漏或错误.那么,该如何解决这个问题呢?梦翼师兄的办法是在他们之间加一个数据缓存器,所有数据先经过缓存器缓存,然后再输入到数据接收模块.那么本节,梦翼师兄和大家一起学习用做数据缓存的存储IP核-FIFO的设计. 项目需求 创建两个模块,一个作为数据发送模块,另一

webservice缓存服务器数据到本地,提供服务接口读取缓存的文件

遇到的问题:1.缓存到本地的文件写入一次,不能读取,不能二次写入.程序报异常:文件被占用 解决办法: FileStream fs = new FileStream(appPath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);                           StreamReader sr = new StreamReader(fs, System.Text.Encoding.UTF8); 设置文件FileShar

AutoMapper小技巧:通过特性配置读取缓存

在项目开发中经常会遇到这样的场景:查询一个复杂实体,其中一部分字段数据从数据库中直接查出,另一部字段数据从缓存中取出.这里通过AutoMapper和特性,提供一种优雅的编码方法. 这种方法的大概思路是:在成员的特性中配置好[缓存字典的key].[与缓存字典关联的外键名称]和[缓存字典里目标字段的名称].然后根据上述参数从缓存里取出需要的数据,最后通过配置AutoMapper的Profile来将数据映射到要查询的list里. 可能这样说会让人有点摸不着头脑,接下来就开始一步一步讲解如何编码. 1.

在meta标签添加代码实现每次请求都要求重新加载页面而不是读取缓存

<!-- 禁止浏览器从本地缓存中调阅页面.--> <meta http-equiv="pragram" content="no-cache"> <!--网页不保存在缓存中,每次访问都刷新页面.--> <meta http-equiv="cache-control" content="no-cache, must-revalidate"> <!--同上面意思差不多,必须重新加

webbrowser 防止读取 缓存

http://bbs.csdn.net/topics/240011502 引用 3 楼 kelei0017 的回复: Delphi(Pascal) codeprocedure TInformationCenterFm.WebBrowserBeforeNavigate2(Sender: TObject;  const pDisp: IDispatch; var URL, Flags, TargetFrameName, PostData,  Headers: OleVariant; var Canc