package lhm.hcy.guge.frameset.cache;

import java.util.*;

/**

*

Title:

*

*

Description: 管理缓存

* Deep blue 2008-11-28 think

* 可扩展的功能：当chche到内存溢出时必须清除掉最早期的一些缓存对象，这就要求对每个缓存对象保存创建时间

*

Copyright: Copyright (c) 2008

*

*

Company:

*

* @author Deepblue 2008-11-11

* @version 1.0

*/

public class CacheManager {

private static HashMap cacheMap = new HashMap();

//单实例构造方法

private CacheManager() {

super();

}

//获取布尔值的缓存

public static boolean getSimpleFlag(String key){

try{

return (Boolean) cacheMap.get(key);

}catch(NullPointerException e){

return false;

}

}

public static long getServerStartdt(String key){

try {

return (Long)cacheMap.get(key);

} catch (Exception ex) {

return 0;

}

}

//设置布尔值的缓存

public synchronized static boolean setSimpleFlag(String key,boolean flag){

if (flag && getSimpleFlag(key)) {//假如为真不允许被覆盖

return false;

}else{

cacheMap.put(key, flag);

return true;

}

}

public synchronized static boolean setSimpleFlag(String key,long serverbegrundt){

if (cacheMap.get(key) == null) {

cacheMap.put(key,serverbegrundt);

return true;

}else{

return false;

}

}

//得到缓存。同步静态方法

private synchronized static Cache getCache(String key) {

return (Cache) cacheMap.get(key);

}

//判断是否存在一个缓存

private synchronized static boolean hasCache(String key) {

return cacheMap.containsKey(key);

}

//清除所有缓存

public synchronized static void clearAll() {

cacheMap.clear();

}

//清除某一类特定缓存,通过遍历HASHMAP下的所有对象，来判断它的KEY与传入的TYPE是否匹配

public synchronized static void clearAll(String type) {

Iterator i = cacheMap.entrySet().iterator();

String key;

ArrayList arr = new ArrayList();

try {

while (i.hasNext()) {

java.util.Map.Entry entry = (java.util.Map.Entry) i.next();

key = (String) entry.getKey();

if (key.startsWith(type)) { //如果匹配则删除掉

arr.add(key);

}

}

for (int k = 0; k < arr.size(); k++) {

clearOnly(arr.get(k));

}

} catch (Exception ex) {

ex.printStackTrace();

}

}

//清除指定的缓存

public synchronized static void clearOnly(String key) {

cacheMap.remove(key);

}

//载入缓存

public synchronized static void putCache(String key, Cache obj) {

cacheMap.put(key, obj);

}

//获取缓存信息

public static Cache getCacheInfo(String key) {

if (hasCache(key)) {

Cache cache = getCache(key);

if (cacheExpired(cache)) { //调用判断是否终止方法

cache.setExpired(true);

}

return cache;

}else

return null;

}

//载入缓存信息

public static void putCacheInfo(String key, Cache obj, long dt,boolean expired) {

Cache cache = new Cache();

cache.setKey(key);

cache.setTimeOut(dt + System.currentTimeMillis()); //设置多久后更新缓存

cache.setValue(obj);

cache.setExpired(expired); //缓存默认载入时，终止状态为FALSE

cacheMap.put(key, cache);

}

//重写载入缓存信息方法

public static void putCacheInfo(String key,Cache obj,long dt){

Cache cache = new Cache();

cache.setKey(key);

cache.setTimeOut(dt+System.currentTimeMillis());

cache.setValue(obj);

cache.setExpired(false);

cacheMap.put(key,cache);

}

//判断缓存是否终止

public static boolean cacheExpired(Cache cache) {

if (null == cache) { //传入的缓存不存在

return false;

}

long nowDt = System.currentTimeMillis(); //系统当前的毫秒数

long cacheDt = cache.getTimeOut(); //缓存内的过期毫秒数

if (cacheDt <= 0||cacheDt>nowDt) { //过期时间小于等于零时,或者过期时间大于当前时间时，则为FALSE

return false;

} else { //大于过期时间 即过期

return true;

}

}

//获取缓存中的大小

public static int getCacheSize() {

return cacheMap.size();

}

//获取指定的类型的大小

public static int getCacheSize(String type) {

int k = 0;

Iterator i = cacheMap.entrySet().iterator();

String key;

try {

while (i.hasNext()) {

java.util.Map.Entry entry = (java.util.Map.Entry) i.next();

key = (String) entry.getKey();

if (key.indexOf(type) != -1) { //如果匹配则删除掉

k++;

}

}

} catch (Exception ex) {

ex.printStackTrace();

}

return k;

}

//获取缓存对象中的所有键值名称

public static ArrayList getCacheAllkey() {

ArrayList a = new ArrayList();

try {

Iterator i = cacheMap.entrySet().iterator();

while (i.hasNext()) {

java.util.Map.Entry entry = (java.util.Map.Entry) i.next();

a.add((String) entry.getKey());

}

} catch (Exception ex) {} finally {

return a;

}

}

//获取缓存对象中指定类型 的键值名称

public static ArrayList getCacheListkey(String type) {

ArrayList a = new ArrayList();

String key;

try {

Iterator i = cacheMap.entrySet().iterator();

while (i.hasNext()) {

java.util.Map.Entry entry = (java.util.Map.Entry) i.next();

key = (String) entry.getKey();

if (key.indexOf(type) != -1) {

a.add(key);

}

}

} catch (Exception ex) {} finally {

return a;

}

}

}

package lhm.hcy.guge.frameset.cache;

/**

*

Title:

*

*

Description: 缓存DTO

*

*

Copyright: Copyright (c) 2008

*

*

Company:

*

* @author Deepblue 2008-11-11

* @version 1.0

*/

public class Cache {

private String key;//缓存ID

private Object value;//缓存数据

private long timeOut;//更新时间

private boolean expired; //是否终止

public Cache() {

super();

}

public Cache(String key, Object value, long timeOut, boolean expired) {

this.key = key;

this.value = value;

this.timeOut = timeOut;

this.expired = expired;

}

public String getKey() {

return key;

}

public long getTimeOut() {

return timeOut;

}

public Object getValue() {

return value;

}

public void setKey(String string) {

key = string;

}

public void setTimeOut(long l) {

timeOut = l;

}

public void setValue(Object object) {

value = object;

}

public boolean isExpired() {

return expired;

}

public void setExpired(boolean b) {

expired = b;

}

}

//测试类，

class Test {

public static void main(String[] args) {

System.out.println(CacheManager.getSimpleFlag("alksd"));

// CacheManager.putCache("abc", new Cache());

// CacheManager.putCache("def", new Cache());

// CacheManager.putCache("ccc", new Cache());

// CacheManager.clearOnly("");

// Cache c = new Cache();

// for (int i = 0; i < 10; i++) {

// CacheManager.putCache("" + i, c);

// }

// CacheManager.putCache("aaaaaaaa", c);

// CacheManager.putCache("abchcy;alskd", c);

// CacheManager.putCache("cccccccc", c);

// CacheManager.putCache("abcoqiwhcy", c);

// System.out.println("删除前的大小："+CacheManager.getCacheSize());

// CacheManager.getCacheAllkey();

// CacheManager.clearAll("aaaa");

// System.out.println("删除后的大小："+CacheManager.getCacheSize());

// CacheManager.getCacheAllkey();

}

}

分享到：

2009-12-08 13:38

浏览 3720

论坛回复 / 浏览 (20 / 28988)

评论

21 楼

hzxlb910

2014-03-16

很不错，学习了。

20 楼

chinayuanao

2009-12-11

对，在对链表、Hash表等表结构进循环操作的时候，最好不好在循环体内对表结构进行删除或增加操作，否则会很容易出问题的。

19 楼

yuyee

2009-12-10

hashmap迭代的时候注意点，你这样写会出错

18 楼

xiaobin0530

2009-12-10

HashMap---->ConcurrentHashMap

17 楼

wujiazhao88

2009-12-10

说小一点，其实一个数组buf都可以是缓存，比如在文件读写的时候。。

Map用来做缓存是非常不错的，想一些需要单例模式的也可以用map来实现的

16 楼

J-catTeam

2009-12-09

icanfly 写道

个人见解。。。此缓存的作用是先从缓存中取中，如果取出为空，则。。。(查询数据库或是其它的来源)。缓存只是一个高速查询的地方。没太必要做同步控制。如果你已经在查询缓存了，那已经说明这个数据了实时性已经不是那么重要。同步控制可以适当省略一些以提高并发读写。

但是如果我查询的数据和数据库的数据不一致怎么办？不管么?

所以建议

在update或者delete得时候··删除掉缓存中的值

15 楼

prowl

2009-12-09

高并发可选择ConcurrentHashMap，效率是Hashtable、Collections.synchronizedMap的1倍

另外推荐楼主看看HashMap的原理，前2天好像还有人发来着，有助于你重构现在的代码

14 楼

nishizhutoua

2009-12-09

Java中做缓存

1.考虑并发要用ConcurrentHashMap

2.缓存的值尽量要用WeakReference包装.

13 楼

kekeemx

2009-12-09

之前有用过apache的lrumap做的缓存.目前看来还是不错的.

详细见这里:www.iteye.com/topic/355396

不过毕竟是jvm中使用,速度快是快,但是量不能太大,而且也不利于分布式应用,

对之后系统扩展来说也是个问题,毕竟要考虑到多个节点的同步问题,所以现在比较倾向于使用外置的缓存系统.比如memcached

12 楼

putonyuer

2009-12-09

倒是 可以看看  weakhashmap   java api号称这个可以做缓存存储， 但也没看见实际应用中 用这个

11 楼

putonyuer

2009-12-09

vvggsky 写道

有些地方同步没用，隐患

是的

二、内存缓存，也就是实现一个类中静态Map,对这个Map进行常规的增删查.

==================================

ehcache是用的hashtable 解决同步， 自己控制是否回收

从来没看见过实际应用  用hashmap的

楼主 有点幻想情节了。

10 楼

J-catTeam

2009-12-09

楼主你好

java做缓存的想法

1.内存利用，在windows上2g的大概只能用到1.6g，在Linux上最大的似乎可以用到4g(似乎用不到3g吧)，这就注定了内存这一块java做并不合适(32位，64位倒是几乎没有限制)

2.你的内存只是放进去了，可以全部清空，可以根据key清空==，但是放在一个大型的应用里面，难道你需要让所有的程序员都必须知道key，并且在调用dao的方法的时候都要知道那个key先去get(String key)一下么？ 这样子不友好吧。

3.在存放形式里面实际上内存还有一个方式是将对象序列化后持久化，也就是说不管什么对象，把它变成二进制，放在库里面，这里面有个好处就是不会涉及到任何的表关联，对库的压力并不大(实际上任何的库，只能切分以后能才会好(大型数据量))，cache的数据库压力肯定比实际数据的数据库压力小。

4.在缓存这一块实际上还有两个小问题-数据同步，你缓存有一个test，但是这个时候数据库被修改了，但是你缓存没变，用户拿出来的就是一个错误的数据，-value可能重复，任何一个重复的value都是无意义的。

5.单机缓存的意义并不大，同理memcached这个单机也米意义，因为他的hashmap每秒响应大概是几万还是多少，但是在本地hashmap可以达到几百万。

6.加油加油，呵呵

9 楼

mwmw

2009-12-09

luckaway 写道

mwmw 写道

1. Map -> ConcurrentMap 会好很多吧

2. Synz太多了吧，性能能好吗？

3. 内存缓存实现太多了，Hashmap实现估计是最差的吧。

4. 现在memory缓存更多的都在讨论memcached，有优势。

5. 如果是文件缓存的话，其实用数据库也就蛮好了，或者是用一些nosql的东西(如mongodb，couchdb等)

楼主写了很多，很不错，以上自己的一点愚见。

memcached最大的优势就是：内存大，不受java虚拟机限制。

事情上大多缓存对象根本不需要很大的内存，存放在JVM里足矣，更省去了对象序列化的一步

yap, 一些比较经常用的又不是很大的东西肯定是放在本地最好了。用内存也不多，实惠...

8 楼

luckaway

2009-12-09

mwmw 写道

1. Map -> ConcurrentMap 会好很多吧

2. Synz太多了吧，性能能好吗？

3. 内存缓存实现太多了，Hashmap实现估计是最差的吧。

4. 现在memory缓存更多的都在讨论memcached，有优势。

5. 如果是文件缓存的话，其实用数据库也就蛮好了，或者是用一些nosql的东西(如mongodb，couchdb等)

楼主写了很多，很不错，以上自己的一点愚见。

memcached最大的优势就是：内存大，不受java虚拟机限制。

事情上大多缓存对象根本不需要很大的内存，存放在JVM里足矣，更省去了对象序列化的一步

7 楼

luckaway

2009-12-08

lijie250 写道

弱弱的问一句private static HashMap cacheMap = new HashMap();  就可以让cache长期驻留内存，GC不会回收了？

static，静态常量或者静态变量都是不会被GC！

因为不会被GC,所以要防止内存溢出！最好限制一个最大对象数

6 楼

freesky110

2009-12-08

如果是一个比较成熟的cache的话，我觉得你可能还需要考虑下面的几点：

1.synchronized太多，建议用ConcurrentHashMap

2.提供控制cache内存消耗的阀值，并实现LRU淘汰策略

3.统计cache命中率

5 楼

潜心修炼

2009-12-08

harbey 写道

要是做双机呢？一台服务器挂了，另外一台是否能共享缓存呢？

这个只支持一个应用！

也不能武断的说支持一个应用。

只要加上适当的缓存版本校验机制，也可以分布式使用的。

4 楼

mwmw

2009-12-08

1. Map -> ConcurrentMap 会好很多吧

2. Synz太多了吧，性能能好吗？

3. 内存缓存实现太多了，Hashmap实现估计是最差的吧。

4. 现在memory缓存更多的都在讨论memcached，有优势。

5. 如果是文件缓存的话，其实用数据库也就蛮好了，或者是用一些nosql的东西(如mongodb，couchdb等)

楼主写了很多，很不错，以上自己的一点愚见。

3 楼

harbey

2009-12-08

要是做双机呢？一台服务器挂了，另外一台是否能共享缓存呢？

这个只支持一个应用！

2 楼

lijie250

2009-12-08

弱弱的问一句private static HashMap cacheMap = new HashMap();  就可以让cache长期驻留内存，GC不会回收了？

« 上一页 1 2 下一页 »