Authored by qinchao

支持tcp探测

... ... @@ -51,6 +51,7 @@ public class JavaApiTask implements Callable<JavaApiStatics> {
apiStatics.setMObjectDetails(this.mObjectInfo);
String socketPath=null;
Socket s = null;
try{
socketPath = createReqTcpPath();
if(StringUtils.isBlank(socketPath)){
... ... @@ -69,7 +70,7 @@ public class JavaApiTask implements Callable<JavaApiStatics> {
log.warn("socketPath {} port is not valid ", socketPath);
return null;
}
Socket s = new Socket(host, port);
s = new Socket(host, port);
s.close();
}catch(Exception e){
log.warn("socketPath {} exception {} ", socketPath, e);
... ... @@ -78,6 +79,13 @@ public class JavaApiTask implements Callable<JavaApiStatics> {
} finally {
apiStatics.setEndTime(System.currentTimeMillis());
apiStatics.setResponse(null);//没有错误
if(s!=null&&s.isConnected()&&!s.isClosed()){
try{
s.close();
}catch (Exception ee){
log.warn("socketPath {} close exception {} ", socketPath, ee);
}
}
}
return apiStatics;
... ...