以太坊MPT树的持久化层是采用了leveldb数据库,然而在抽取MPT树代码运行过程当中,进行get和write操做时却发生了错误:java
Caused by: org.fusesource.leveldbjni.internal.NativeDB$DBException: IO error: C:\data\trie\000785.sst: Could not create random access file. at org.fusesource.leveldbjni.internal.NativeDB.checkStatus(NativeDB.java:200) at org.fusesource.leveldbjni.internal.NativeDB.get(NativeDB.java:307) at org.fusesource.leveldbjni.internal.NativeDB.get(NativeDB.java:300) at org.fusesource.leveldbjni.internal.NativeDB.get(NativeDB.java:293) at org.fusesource.leveldbjni.internal.JniDB.get(JniDB.java:73)
查了一些资料才把这个问题解决,参考:https://github.com/fusesource/leveldbjni/issues/28git
1. 首先增长maxOpenFiles的数量,经过观察数据库sst文件数量的变化发现,文件在50个左右,而原来maxOpenFiles=32,所以改成(datasource/LevelDbDataSource.java line75)github
//options.maxOpenFiles(32); options.maxOpenFiles(100);
2. 对get和write方法进行异常处理数据库
异常形成的缘由是:因为leveldb内部的compaction algorithm将一个level的sst文件合并到下一个level的sst文件中,所以在get或write方法就会出现找不到当前sst文件的状况,解决方法是从新get或write一次(虽然这种处理方法不太优雅,可是确实有用)。修改代码(datasource/LevelDbDataSource.java line139)dom
try {
byte[] ret = db.get(key); if (logger.isTraceEnabled()) logger.trace("<~ LevelDbDataSource.get(): " + name + ", key: " + Hex.toHexString(key) + ", " + (ret == null ? "null" : ret.length)); return ret; } catch (DBException e) { logger.error("Exception. Retrying again...", e); byte[] ret = db.get(key); if (logger.isTraceEnabled()) logger.trace("<~ LevelDbDataSource.get(): " + name + ", key: " + Hex.toHexString(key) + ", " + (ret == null ? "null" : ret.length)); return ret; }
以及(datasource/LevelDbDataSource.java line209)spa
try{//add 08-23 18:32 db.write(batch); } catch (DBException e) { logger.error("Exception. Retrying again...", e); db.write(batch); }//end add 08-23 18:32
这要就修复了这个bug!!code