val kvlist = ssdb.hscan(ExprivateSql.REALBIGDATA,"","",max)
kvlist?.forEach { kv->
val json = JSONObject.parseObject(kv.keyString)
val name = json.getString("name")
var realdb = map[name]
if (realdb == null)
{
realdb = Class.forName(name).newInstance() as RealDb
map[name] = realdb
println("$name ${kv.keyString} ${kv.value.size}")
val datamap = Tool.kryoCompressBytesUnSerialize(kv.value) as ConcurrentHashMap<String, Row>
realdb.plus(datamap)
}
}
写入代码
读取代码
发现写入时 byte 长度是167。读取时 bs 长度时270。导致无法正确序列化。 不知道是我哪里使用有问题,请帮看一下。