Exception in thread "pool-4-thread-23" com.sequoiadb.exception.BaseException: errorType:SDB_NETWORK,Network error
Exception Detail:
at com.sequoiadb.net.ConnectionTCPImpl.receiveMessage(ConnectionTCPImpl.java:286)
at com.sequoiadb.base.DBCollection._update(DBCollection.java:1721)
at com.sequoiadb.base.DBCollection.upsert(DBCollection.java:594)
at com.cmmobi.seqdb.SeqDBDao.batchUpsertUserInfo(SeqDBDao.java:86)
at com.cmmobi.handle.HandleThread$1.run(HandleThread.java:113)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
我的java代码是这样操作的:
BasicBSONObject query = new BasicBSONObject();
query.put("PRODUCTID", sm.getMsg().getProductID());
query.put("USERID", sm.getMsg().getUserID());
query.put("DEVID", sm.getMsg().getDevID());
BasicBSONObject doc = new BasicBSONObject();
doc.put("PRODUCTID", sm.getMsg().getProductID());
doc.put("USERID", sm.getMsg().getUserID());
doc.put("DEVID", sm.getMsg().getDevID());
doc.put("SESSIONID", sm.getSessionID());
doc.put("SERVERID", sm.getServerID());
doc.put("POI", sm.getMsg().getPOI());
doc.put("OSTYPE", sm.getMsg().getOsType());
doc.put("VERSION", sm.getMsg().getVersion());
doc.put("CHANNEL", sm.getMsg().getChannel());
doc.put("LOGINTS", new Date(sm.getLoginTime()));
doc.put("CREATETS", new Date(System.currentTimeMillis()));
if(!"".equals(sm.getMsg().getTag())) {
doc.put("TAG", sm.getMsg().getTag().split(","));
}
doc.put("LONGITUDEE6", sm.getMsg().getLongitudeE6());
doc.put("LATITUDEE6", sm.getMsg().getLatitudeE6());
//本版本暂时不用的字段
doc.put("LASTHB", sm.getMsg().getNextHB()); //本版本暂时不用
BasicBSONObject modifier = new BasicBSONObject();
modifier.put("$set", doc);
cl_user_info.upsert(query, modifier, null);
而在shell中查看数据库都没有问题:
> db.pushCS.cmmobi_push_userinfo.find({USERID:"zhw123"})
{
"CHANNEL": "pushlistener",
"CREATETS": {
"$date": "2015-05-25"
},
"DEVID": "9db1bc9821c2aa81079dd96712a2fa9f",
"LASTHB": 480000,
"LATITUDEE6": 0,
"LOGINTS": {
"$date": "2015-05-25"
},
"LONGITUDEE6": 0,
"OSTYPE": 1,
"POI": "Wuhan",
"PRODUCTID": 111,
"SERVERID": "172.16.10.71:8669",
"SESSIONID": "9db1bc9821c2aa81079dd96712a2fa9fzhw123111",
"TAG": [
"80",
"60",
"pop",
"music"
],
"USERID": "zhw123",
"VERSION": "1.0",
"_id": {
"$oid": "55629567708b638846dbbc91"
}
}
Return 1 row(s).
Takes 0.2588s.