MyException - 我的异常网
当前位置:我的异常网» 互联网 » 当地缓存类

当地缓存类

www.MyException.Cn  网友分享于:2018-04-07  浏览:1次
本地缓存类
package com.pingan.haofang.agent.saas.util.cache.daemon;

import java.util.HashMap;
import java.util.concurrent.TimeUnit;
import org.apache.log4j.Logger;

/**
 * 增强型本地缓存
 */
public class DaemonCache<K,V> {

	private static final Logger log = Logger.getLogger(DaemonCache.class);

	/** 对Null类型的值,用户希望设定的过期时间 ,时间单位为秒 */
	private long nullValueExpiredTime = 10;

	/** 对于正常的缓存值,用户希望设定的过期时间,时间单位为秒 */
	private long valueExpiredTime = 10;

	/** 对于通过getDataByKey接口获取数据是报错的情况,用户希望Null在本地缓存的过期时间,时间单位为秒*/
	private long errorValueExpiredTime = 10;

	private static long LOCAL_CACHE_MAX_SIZE=100000l;

	/** 默认本地缓存大小 */
	private long localCacheSize= LOCAL_CACHE_MAX_SIZE;

	/** 本地缓存核心,一个HashMap,最高效率读写*/
	private final HashMap<K,LocalCacheValue<V>> localCache = new HashMap<K,LocalCacheValue<V>>();

	/** DaemonCacheDataCallBack的实现,在创建一个DaemonCache,强制要求用户实现 */
	private DaemonCacheDataCallBack<K,V> callback;

	/** 需要传入daemonCacheDataCallBack构造  */
	public DaemonCache(DaemonCacheDataCallBack<K,V> daemonCacheDataCallBack){
		if(daemonCacheDataCallBack==null){
			throw new IllegalArgumentException("when create a new DaemonCache, please implmement the DaemonCacheDataCallBack first!");
		}
		this.callback=daemonCacheDataCallBack;
	}

	/**
	 * 创建DaemonCache实例 ,默认本地缓存大小为10万
	 * @param nullValueExpiredTime 空数据过期时间
	 * @param valueExpiredTime 正常时间期望过期时间
	 * @param errorValueExpiredTime 数据接口查询错误过期时间
	 */
	public DaemonCache(long valueExpiredTime,long nullValueExpiredTime,long errorValueExpiredTime) {
		this.valueExpiredTime = valueExpiredTime;
		this.nullValueExpiredTime = nullValueExpiredTime;
		this.errorValueExpiredTime = errorValueExpiredTime;
	}

	/**
	 * 创建DaemonCache实例 ,带有数据层逻辑回调实现,默认本地缓存大小为10万
	 * @param valueExpiredTime 空数据过期时间 ,时间单位为"秒"
	 * @param nullValueExpiredTime 正常时间期望过期时间,时间单位为"秒"
	 * @param errorValueExpiredTime 数据接口查询错误过期时间,时间单位为"秒"
	 * @param callback 数据层逻辑回调实现,实现自DaemonCacheDataCallBack<K, V>接口
	 * 例子:
	 *      DaemonCache localCache = new DaemonCache<Integer, List<Item>>(
	60,//nullValueExpiredTime 空数据过期时间
	60 * 60,//valueExpiredTime 正常时间期望过期时间
	60,//errorValueExpiredTime 数据接口查询错误过期时间
	new DaemonCacheDataCallBack<Integer, List<Item>>() {
	@Override
	public List<Item> getDataByKey(Integer key) {
	return getTopItemsImpl(key); //这里为业务逻辑实现
	}
	}
	);

	 */
	public DaemonCache(long valueExpiredTime,long nullValueExpiredTime,
					   long errorValueExpiredTime,DaemonCacheDataCallBack<K, V> callback) {
		if(callback==null){
			throw new IllegalArgumentException("when create a new DaemonCache, please implmement the DaemonCacheDataCallBack first!");
		}
		this.callback=callback;
		this.nullValueExpiredTime = nullValueExpiredTime;
		this.valueExpiredTime = valueExpiredTime;
		this.errorValueExpiredTime = errorValueExpiredTime;
	}


	/**
	 * 获取默认的DaemonCache,过期时间默认为都为10s , 默认本地缓存大小为10万
	 * @param daemonCacheDataCallBack 数据层逻辑回调实现,实现自DaemonCacheDataCallBack<K, V>接口
	 * @return DaemonCache 默认的实例
	 */
	public DaemonCache<K, V> getDefaultDaemonCache(DaemonCacheDataCallBack<K,V> daemonCacheDataCallBack){
		if(daemonCacheDataCallBack==null){
			throw new IllegalArgumentException("when create a new DaemonCache, please implmement the DaemonCacheDataCallBack first!");
		}
		this.callback=daemonCacheDataCallBack;
		return new DaemonCache<K, V>(nullValueExpiredTime,valueExpiredTime,errorValueExpiredTime,daemonCacheDataCallBack);
	}

	/**
	 * 通过key从Cache中获取对应的Value l
	 * @param key <K>
	 * @return V value
	 */
	public V get(K key){

		if(localCache.size()>LOCAL_CACHE_MAX_SIZE){
			log.debug("0-cache已经满了,直接返回业务数据");
			//判断是否cache已经满了, 如果已近满了,那么直接返回结果
			try {
				V callBackResult = callback.getDataByKey(key);
				return callBackResult;
			} catch (DaemonCacheDataCallBackException e) {
				e.printStackTrace();
				return null;
			}
		}

		LocalCacheValue<V> localCacheValueResult = localCache.get(key);
		if (localCacheValueResult != null) {
			if (!localCacheValueResult.isExpired()) {
				// ->返回正常的业务数据,此时业务数据在本地缓存中不仅存在而且没有过期
				//如果Value是NUll,并且没有过期,将直接返回Null
				log.debug("1-返回正常的业务数据,此时业务数据在本地缓存中不仅存在而且没有过期");
				return localCacheValueResult.getValue();
			}
			//->数据有,但是过期
			log.debug("数据有,但是过期,调用数据查询接口(下层Memcache和DB的查询逻辑)");
			try {
				//先调用数据查询接口(下层Memcache和DB的查询逻辑)
				V callBackResult = callback.getDataByKey(key);
				if(callBackResult==null){
					//没有数据,向Cache中回写Null,并设定过期时间(这里的时间可能偏长)
					log.debug("2-没有数据,向Cache中回写Null,并设定过期时间(这里的时间可能偏长)");
					putNULL(key, this.nullValueExpiredTime);
					return null;
				}else {
					//有数据,填充数据并设定时间(业务数据过期时间)
					log.debug("3-有数据,填充数据并设定时间(业务数据过期时间)");
					put(key, new LocalCacheValue<V>(callBackResult), this.valueExpiredTime);
					return callBackResult;
				}
			} catch (DaemonCacheDataCallBackException e) {
				e.printStackTrace();
				//数据查询报错,向Cache中回写Null,并设定过期时间(这里的时间可能偏短)
				log.debug("4-数据查询报错,向Cache中回写老数据,并设定过期时间(这里的时间可能偏短)");
				put(key, localCacheValueResult, this.errorValueExpiredTime);
				return localCacheValueResult.getValue();
			}
		}

		// -> 没有数据,或者为NULL(NULL数据已经过期)
		log.debug("没有数据,或者为NULL(NULL数据已经过期)");
		try {
			// 先调用数据查询接口(下层Memcache和DB的查询逻辑)
			V callBackResult = callback.getDataByKey(key);
			if (callBackResult == null) {
				// 没有数据,向Cache中回写Null,并设定过期时间(这里的时间可能偏长)
				log.debug("5-无数据,向Cache中回写Null,并设定过期时间(这里的时间可能偏长)");
				putNULL(key, this.nullValueExpiredTime);
				return null;
			} else {
				// 有数据,填充数据并设定时间(业务数据过期时间)
				log.debug("6-有数据,填充数据并设定时间(业务数据过期时间)");
				put(key, new LocalCacheValue<V>(callBackResult),this.valueExpiredTime);
				return callBackResult;
			}
		} catch (DaemonCacheDataCallBackException e) {
			e.printStackTrace();
			// 数据查询报错,向Cache中回写Null,并设定过期时间(这里的时间可能偏短)
			log.debug("7-数据查询报错,向Cache中回写Null,并设定过期时间(这里的时间可能偏短)");
			putNULL(key, this.errorValueExpiredTime);
			return null;
		}
	}

	/**
	 * 向localcache中放入Null值
	 * @param key cache的Key
	 * @param expiredTime Null 值的过期时间
	 */
	private void putNULL(K key, long expiredTime) {
		LocalCacheValue<V> nullValue = new LocalCacheValue<V>();
		nullValue.setNullValue(true);
		put(key, nullValue , expiredTime);
	}

	/**
	 * 向Cache中放入key和Value,需要指定过期时间
	 * @param key
	 * @param value
	 * @param expiredTime
	 */
	private void put(K key, LocalCacheValue<V> value , long expiredTime) {

		expiredTime = TimeUnit.NANOSECONDS.convert(expiredTime,TimeUnit.SECONDS );
		value.setExpiredTime(expiredTime);
		value.setExpiredStartTime(System.nanoTime());
		localCache.put(key, value);

	}

	/**
	 * 注入对应的业务回调实例
	 * @param callback 数据层逻辑回调实现,实现自DaemonCacheDataCallBack<K, V>接口
	 */
	public void setCallback(DaemonCacheDataCallBack<K, V> callback) {
		if (callback == null) {
			throw new IllegalArgumentException(
					"the callback is null here , please check !");
		}
		this.callback = callback;
	}

	/**
	 * 清空本地缓存
	 */
	public void clearLocalCache(){
		this.localCache.clear();
	}

	/**
	 * 设置本地cache大小,本地cache的最大值不得高于10万,默认本地缓存大小为10万
	 * @param localCacheSize
	 */
	public void setLocalCacheSize(long localCacheSize) {
		if (localCacheSize<=0||localCacheSize>LOCAL_CACHE_MAX_SIZE) {
			throw new IllegalArgumentException(
					"the local cache size must be less then the max :"+LOCAL_CACHE_MAX_SIZE);
		}
		this.localCacheSize = localCacheSize;
	}

}

文章评论

Java 与 .NET 的平台发展之争
Java 与 .NET 的平台发展之争
“懒”出效率是程序员的美德
“懒”出效率是程序员的美德
2013年中国软件开发者薪资调查报告
2013年中国软件开发者薪资调查报告
程序员和编码员之间的区别
程序员和编码员之间的区别
2013年美国开发者薪资调查报告
2013年美国开发者薪资调查报告
鲜为人知的编程真相
鲜为人知的编程真相
我的丈夫是个程序员
我的丈夫是个程序员
做程序猿的老婆应该注意的一些事情
做程序猿的老婆应该注意的一些事情
亲爱的项目经理,我恨你
亲爱的项目经理,我恨你
10个帮程序员减压放松的网站
10个帮程序员减压放松的网站
科技史上最臭名昭著的13大罪犯
科技史上最臭名昭著的13大罪犯
程序员的鄙视链
程序员的鄙视链
总结2014中国互联网十大段子
总结2014中国互联网十大段子
Google伦敦新总部 犹如星级庄园
Google伦敦新总部 犹如星级庄园
漫画:程序员的工作
漫画:程序员的工作
程序员应该关注的一些事儿
程序员应该关注的一些事儿
如何区分一个程序员是“老手“还是“新手“?
如何区分一个程序员是“老手“还是“新手“?
一个程序员的时间管理
一个程序员的时间管理
10个调试和排错的小建议
10个调试和排错的小建议
程序员都该阅读的书
程序员都该阅读的书
旅行,写作,编程
旅行,写作,编程
每天工作4小时的程序员
每天工作4小时的程序员
Web开发人员为什么越来越懒了?
Web开发人员为什么越来越懒了?
那些争议最大的编程观点
那些争议最大的编程观点
“肮脏的”IT工作排行榜
“肮脏的”IT工作排行榜
聊聊HTTPS和SSL/TLS协议
聊聊HTTPS和SSL/TLS协议
5款最佳正则表达式编辑调试器
5款最佳正则表达式编辑调试器
程序员的一天:一寸光阴一寸金
程序员的一天:一寸光阴一寸金
编程语言是女人
编程语言是女人
那些性感的让人尖叫的程序员
那些性感的让人尖叫的程序员
为啥Android手机总会越用越慢?
为啥Android手机总会越用越慢?
程序员眼里IE浏览器是什么样的
程序员眼里IE浏览器是什么样的
Web开发者需具备的8个好习惯
Web开发者需具备的8个好习惯
 程序员的样子
程序员的样子
什么才是优秀的用户界面设计
什么才是优秀的用户界面设计
程序员必看的十大电影
程序员必看的十大电影
程序猿的崛起——Growth Hacker
程序猿的崛起——Growth Hacker
代码女神横空出世
代码女神横空出世
当下全球最炙手可热的八位少年创业者
当下全球最炙手可热的八位少年创业者
看13位CEO、创始人和高管如何提高工作效率
看13位CEO、创始人和高管如何提高工作效率
Java程序员必看电影
Java程序员必看电影
写给自己也写给你 自己到底该何去何从
写给自己也写给你 自己到底该何去何从
要嫁就嫁程序猿—钱多话少死的早
要嫁就嫁程序猿—钱多话少死的早
我跳槽是因为他们的显示器更大
我跳槽是因为他们的显示器更大
如何成为一名黑客
如何成为一名黑客
不懂技术不要对懂技术的人说这很容易实现
不懂技术不要对懂技术的人说这很容易实现
十大编程算法助程序员走上高手之路
十大编程算法助程序员走上高手之路
程序员周末都喜欢做什么?
程序员周末都喜欢做什么?
中美印日四国程序员比较
中美印日四国程序员比较
软件开发程序错误异常ExceptionCopyright © 2009-2015 MyException 版权所有