Commit d72cfedf by guanghui.cui

增加连接异常处理

parent f39d547f
1:把文件拷贝到POS后,需要给“takeaway”文件赋予可执行权限,命令:chmod +x takeaway
\ No newline at end of file
...@@ -2,9 +2,9 @@ ...@@ -2,9 +2,9 @@
port=24446 port=24446
[ODS] [ODS]
ip=115.234.23.176 ip=10.0.100.70
pushPort=8996 pushPort=30001
recvPort=8997 recvPort=30002
socketTimeout=60 socketTimeout=60
[POS] [POS]
......
File added
...@@ -98,7 +98,7 @@ void* listen_pos_func(void* arg) ...@@ -98,7 +98,7 @@ void* listen_pos_func(void* arg)
} }
else{ else{
LOG(INFO)<<"wait for ods init back data"; LOG(INFO)<<"wait for ods init back data";
sleep(1); sleep(3);
} }
} }
jsonTool.setInitData(posRequestData.data()); //把初始化数据暂存起来 jsonTool.setInitData(posRequestData.data()); //把初始化数据暂存起来
...@@ -317,11 +317,18 @@ int main() ...@@ -317,11 +317,18 @@ int main()
LOG(INFO)<<"wait for init done"; LOG(INFO)<<"wait for init done";
if( !ods.isValid() ){ if( !ods.isValid() ){
LOG(INFO)<<"ods is not valid"; LOG(INFO)<<"ods is not valid";
sleep(1);
break; break;
} }
sleep(1); sleep(1);
} }
//如果连接非法,跳出循环重新连接
if( !ods.isValid() ){
break;
}
//检测是否有发送失败的订单,如果有的话,启动线程,先发送原先失败的订单 //检测是否有发送失败的订单,如果有的话,启动线程,先发送原先失败的订单
sqlite.query("select * from fmOrderFailed",vecFailedOrders); sqlite.query("select * from fmOrderFailed",vecFailedOrders);
LOG(INFO)<<"vecFailedOrders size:"<<vecFailedOrders.size(); LOG(INFO)<<"vecFailedOrders size:"<<vecFailedOrders.size();
...@@ -337,13 +344,13 @@ int main() ...@@ -337,13 +344,13 @@ int main()
else{ else{
LOG(INFO)<<"Haven't receive init data"; LOG(INFO)<<"Haven't receive init data";
} }
sleep(1); sleep(3);
continue; continue;
} }
}else }else
{ {
LOG(INFO) << "connect ODS failed"; LOG(INFO) << "connect ODS failed";
sleep(2); sleep(5);
continue; continue;
} }
} }
...@@ -360,7 +367,7 @@ int main() ...@@ -360,7 +367,7 @@ int main()
if( ods.receive(odsPushData) ) if( ods.receive(odsPushData) )
{ {
LOG(INFO) << "---------------- ODS ===>> PLUGIN ---------------."; LOG(INFO) << "---------------- ODS ===>> PLUGIN ---------------";
LOG(INFO) << odsPushData; LOG(INFO) << odsPushData;
if(!jsonTool.isHeartbeatData(odsPushData.data())){ if(!jsonTool.isHeartbeatData(odsPushData.data())){
if( jsonTool.convertDataOds2Pos(odsPushData, pushPosData) ) if( jsonTool.convertDataOds2Pos(odsPushData, pushPosData) )
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment