JAVA缓存模版代码,Java代码库,德仔网

代码语言

代码分类

【Java】 JAVA缓存模版

作者:吐哈分享 / 发布于2015/1/4/ 391

公司内部手动控制缓存框架觉得好的点个赞-所谓创新其实就是把常用的自己的奇思妙想总结出来而已。没有其他了。


	package com.tfoll.tcache.template;
	
	import java.util.concurrent.locks.Lock;
	
	import com.tfoll.web.util.Utils;
	
	/**
	* TCache缓存回调方法:如果不存在或者过期则创建
	*/
	public abstract class CacheCallBack {
	 private CacheContext cacheContext = null;
	
	 /**
	 * 缓存的参数初始化:将读写锁和缓存的key值绑定在一起
	 *
	 * @param key
	 * 缓存的key值
	 * @param loseEffectivenessInterval
	 * 失效间隔
	 * @param timeType
	 * 时间类型
	 */
	 public CacheCallBack(String key, long loseEffectivenessInterval, long timeType) {
	 if (Utils.isNullOrEmptyString(key)) {
	 throw new NullPointerException("key is Null Or EmptyString ");
	 }
	 if (loseEffectivenessInterval <= 0) {
	 throw new NullPointerException("loseEffectivenessInterval<=0");
	 }
	 if (timeType <= 0) {
	 throw new NullPointerException("timeType<=0");
	 }
	 /**
	 * 首先从Cache_Context_Map里面获取,不存在则放入到map里面
	 */
	 CacheContext cacheContext = CacheContext.Cache_Context_Map.get(key);
	 if (cacheContext == null) {
	 /**
	 * 生成这个对象的时候里面是含有一把读写锁
	 */
	 cacheContext = new CacheContext(loseEffectivenessInterval, timeType);
	 CacheContext.Cache_Context_Map.put(key, cacheContext);
	 }
	 this.cacheContext = cacheContext;
	
	 }
	
	 /**
	 * 定义写的方法
	 */
	 public abstract Object doWrite();
	
	 public Object doWriteAndGet() {
	 CacheContext cacheContext = this.cacheContext;// 只是好看一点
	 long now = System.currentTimeMillis();
	 if (cacheContext.getStart_time_long_or_update_cache_time() == 0l || //
	 now - cacheContext.getStart_time_long_or_update_cache_time() >= cacheContext.getLose_effectiveness_interval()) {
	 Lock lock = cacheContext.getLock().writeLock();
	 lock.lock();
	 try {
	 Object object = doWrite();
	 cacheContext.setObject(object);
	 cacheContext.setStart_time_long_or_update_cache_time(now);
	 return cacheContext.getObject();
	 } catch (Exception e) {
	 throw new RuntimeException(e);
	 } finally {
	 lock.unlock();
	 }
	
	 } else {
	 Lock lock = cacheContext.getLock().readLock();
	 lock.lock();
	 try {
	 return cacheContext.getObject();
	 } finally {
	 lock.unlock();
	 }
	 }
	
	 }
	}

	

	CacheContext.java

	package com.tfoll.tcache.template;
	
	import java.util.concurrent.ConcurrentHashMap;
	import java.util.concurrent.locks.ReadWriteLock;
	import java.util.concurrent.locks.ReentrantReadWriteLock;
	
	/**
	* TCache缓存上下文,记录缓存的开始的时间,失效时间
	*/
	public class CacheContext {
	 public static final ConcurrentHashMap<String, CacheContext> Cache_Context_Map = new ConcurrentHashMap<String, CacheContext>(1000);
	
	 public static final long Second = 1000;
	 public static final long Minute = Second * 60;
	 public static final long Hour = Minute * 60;
	 public static final long Day = Hour * 24;
	
	 private long start_time_long_or_update_cache_time = 0;
	 private long lose_effectiveness_interval = 0;
	 /**
	 * 支持读写锁
	 */
	 private ReadWriteLock lock = new ReentrantReadWriteLock();
	 private Object object = null;
	
	 /**
	 *
	 * @param loseEffectivenessInterval
	 * 失效时间间隔单位数
	 * @param timeType
	 * 时间类型
	 */
	 public CacheContext(long loseEffectivenessInterval, long timeType) {
	 this.lose_effectiveness_interval = loseEffectivenessInterval * timeType;
	 }
	
	 public long getStart_time_long_or_update_cache_time() {
	 return start_time_long_or_update_cache_time;
	 }
	
	 public void setStart_time_long_or_update_cache_time(long startTimeLongOrUpdateCacheTime) {
	 start_time_long_or_update_cache_time = startTimeLongOrUpdateCacheTime;
	 }
	
	 public long getLose_effectiveness_interval() {
	 return lose_effectiveness_interval;
	 }
	
	 public void setLose_effectiveness_interval(long loseEffectivenessInterval) {
	 lose_effectiveness_interval = loseEffectivenessInterval;
	 }
	
	 public ReadWriteLock getLock() {
	 return lock;
	 }
	
	 public void setLock(ReadWriteLock lock) {
	 this.lock = lock;
	 }
	
	 public void setObject(Object object) {
	 this.object = object;
	 }
	
	 public Object getObject() {
	 return object;
	 }
	
	}

	

	CacheCaseTest.java

	package common.test;
	
	import com.tfoll.tcache.template.CacheCallBack;
	import com.tfoll.tcache.template.CacheContext;
	
	public class CacheCaseTest {
	
	 public static void main(String[] args) {
	 String msg = null;
	 for (int i = 0; i <10000000; i++) {
	 final int j=i;
	 msg = (String) new CacheCallBack("1", 1, CacheContext.Second) {
	 /**
	 * 定义读写更新操作
	 */
	 @Override
	 public Object doWrite() {
	 return "1";
	 }
	 }.doWriteAndGet();
	 System.err.println(msg);
	 }
	 }
	
	}

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

　缓存模版　　缓存　

同语言下

可能有用的

吐哈分享贡献的其它代码(1)

.JAVA缓存模版