lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-03-26 15:02:54 +08:00
parent 41aadf33f3
commit 1e871cbee5
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/org/redkale/service/CacheSourceService.java
View File

@@ -30,7 +30,7 @@ import org.redkale.util.*;
*/ */
@AutoLoad(false) @AutoLoad(false)
@ResourceType({CacheSourceService.class, CacheSource.class}) @ResourceType({CacheSourceService.class, CacheSource.class})
public class CacheSourceService<K extends Serializable, V extends Object> implements CacheSource<K, V>, Service, AutoCloseable { public class CacheSourceService<K extends Serializable, V extends Object> implements CacheSource<K, V>, Service, AutoCloseable, Resourcable {
@Resource(name = "APP_HOME") @Resource(name = "APP_HOME")
private File home; private File home;
@@ -116,7 +116,7 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
if (expireHandler != null && entry != null) expireHandler.accept(entry); if (expireHandler != null && entry != null) expireHandler.accept(entry);
} }
}, 10, 10, TimeUnit.SECONDS); }, 10, 10, TimeUnit.SECONDS);
logger.finest(self.getClass().getSimpleName() + ":" + self.name() + " start schedule expire executor"); logger.finest(self.getClass().getSimpleName() + ":" + self.resourceName() + " start schedule expire executor");
} }
if (Sncp.isRemote(self)) return; if (Sncp.isRemote(self)) return;
@@ -125,7 +125,7 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
// TODO // TODO
if (!this.needStore) return; if (!this.needStore) return;
try { try {
File store = new File(home, "cache/" + name()); File store = new File(home, "cache/" + resourceName());
if (!store.isFile() || !store.canRead()) return; if (!store.isFile() || !store.canRead()) return;
LineNumberReader reader = new LineNumberReader(new FileReader(store)); LineNumberReader reader = new LineNumberReader(new FileReader(store));
if (this.keyType == null) this.keyType = Serializable.class; if (this.keyType == null) this.keyType = Serializable.class;
@@ -148,7 +148,7 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
reader.close(); reader.close();
store.delete(); store.delete();
} catch (Exception e) { } catch (Exception e) {
logger.log(Level.SEVERE, CacheSource.class.getSimpleName() + "(" + name() + ") load store file error ", e); logger.log(Level.SEVERE, CacheSource.class.getSimpleName() + "(" + resourceName() + ") load store file error ", e);
} }
} }
@@ -157,8 +157,10 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
destroy(null); destroy(null);
} }
public String name() { @Override
return this.getClass().getAnnotation(Resource.class).name(); public String resourceName() {
Resource res = this.getClass().getAnnotation(Resource.class);
return res == null ? null : res.name();
} }
@Override @Override
@@ -166,7 +168,7 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
if (scheduler != null) scheduler.shutdownNow(); if (scheduler != null) scheduler.shutdownNow();
if (!this.needStore || Sncp.isRemote(this) || container.isEmpty()) return; if (!this.needStore || Sncp.isRemote(this) || container.isEmpty()) return;
try { try {
File store = new File(home, "cache/" + name()); File store = new File(home, "cache/" + resourceName());
store.getParentFile().mkdirs(); store.getParentFile().mkdirs();
PrintStream stream = new PrintStream(store, "UTF-8"); PrintStream stream = new PrintStream(store, "UTF-8");
final Type storeObjType = TypeToken.createParameterizedType(null, CacheEntry.class, keyType, objValueType); final Type storeObjType = TypeToken.createParameterizedType(null, CacheEntry.class, keyType, objValueType);
@@ -179,7 +181,7 @@ public class CacheSourceService<K extends Serializable, V extends Object> implem
container.clear(); container.clear();
stream.close(); stream.close();
} catch (Exception e) { } catch (Exception e) {
logger.log(Level.SEVERE, CacheSource.class.getSimpleName() + "(" + name() + ") store to file error ", e); logger.log(Level.SEVERE, CacheSource.class.getSimpleName() + "(" + resourceName() + ") store to file error ", e);
} }
} }