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-11-15 08:46:12 +08:00
parent 337a2a3038
commit 68f0c1de29
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/org/redkale/source/CacheMemorySource.java
View File

@@ -138,7 +138,7 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
// TODO // TODO
if (this.needStore) { if (this.needStore) {
try { try {
File store = new File(home, "cache/" + resourceName()); File store = home == null ? new File("cache/" + resourceName()) : 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.objValueType == null) this.objValueType = Object.class; if (this.objValueType == null) this.objValueType = Object.class;
@@ -188,7 +188,8 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
} }
} }
} }
/*
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
conf.addValue("node", new AnyValue.DefaultAnyValue().addValue("addr", "127.0.0.1").addValue("port", "6379")); conf.addValue("node", new AnyValue.DefaultAnyValue().addValue("addr", "127.0.0.1").addValue("port", "6379"));
@@ -196,6 +197,7 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
CacheMemorySource source = new CacheMemorySource(); CacheMemorySource source = new CacheMemorySource();
source.defaultConvert = JsonFactory.root().getConvert(); source.defaultConvert = JsonFactory.root().getConvert();
source.initValueType(String.class); //value用String类型 source.initValueType(String.class); //value用String类型
source.initTransient(false);
source.init(conf); source.init(conf);
System.out.println("------------------------------------"); System.out.println("------------------------------------");
@@ -235,8 +237,11 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
System.out.println("newnum 值 : " + source.decr("newnum")); System.out.println("newnum 值 : " + source.decr("newnum"));
System.out.println("------------------------------------"); System.out.println("------------------------------------");
source.destroy(null); source.destroy(null);
source.init(null);
System.out.println("all keys: " + source.queryKeys());
} }
*/
@Override @Override
public void close() throws Exception { //给Application 关闭时调用 public void close() throws Exception { //给Application 关闭时调用
destroy(null); destroy(null);
@@ -245,7 +250,7 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
@Override @Override
public String resourceName() { public String resourceName() {
Resource res = this.getClass().getAnnotation(Resource.class); Resource res = this.getClass().getAnnotation(Resource.class);
return res == null ? null : res.name(); return res == null ? "cachememory" : res.name();
} }
@Override @Override