昆船连接失败时,关掉旧有连接

chongqing-yashichuangneng
LAPTOP-S9HJSOEB\昊天 2 years ago
parent a6511d2069
commit bbdb00b4e7

@ -41,9 +41,9 @@ public class HikLoginModuleImpl implements CameraControlLoginModule {
Boolean ok = hcNetsdk.NET_DVR_Init(); Boolean ok = hcNetsdk.NET_DVR_Init();
HCNetSDK.NET_DVR_LOCAL_TCP_PORT_BIND_CFG strLocalTcpBind = new HCNetSDK.NET_DVR_LOCAL_TCP_PORT_BIND_CFG(); HCNetSDK.NET_DVR_LOCAL_TCP_PORT_BIND_CFG strLocalTcpBind = new HCNetSDK.NET_DVR_LOCAL_TCP_PORT_BIND_CFG();
strLocalTcpBind.read(); strLocalTcpBind.read();
strLocalTcpBind.wLocalBindTcpMinPort = (short) 3000; //strLocalTcpBind.wLocalBindTcpMinPort = (short) 3000;
strLocalTcpBind.wLocalBindTcpMaxPort = (short) 3000; //strLocalTcpBind.wLocalBindTcpMaxPort = (short) 3000;
strLocalTcpBind.write(); //strLocalTcpBind.write();
Pointer pStrLocalTcoBind = strLocalTcpBind.getPointer(); Pointer pStrLocalTcoBind = strLocalTcpBind.getPointer();
if (hcNetsdk.NET_DVR_SetSDKLocalCfg(0, pStrLocalTcoBind) == false) { if (hcNetsdk.NET_DVR_SetSDKLocalCfg(0, pStrLocalTcoBind) == false) {
System.out.println("绑定失败,错误码为" + hcNetsdk.NET_DVR_GetLastError()); System.out.println("绑定失败,错误码为" + hcNetsdk.NET_DVR_GetLastError());

@ -319,7 +319,7 @@ public class CameraService {
public void cameraLogin(Camera camera){ public void cameraLogin(Camera camera){
NetSDKLib.LLong lLong = cameraControlLoginModule.login(camera.getIp(),camera.getPort(),camera.getUser(),camera.getPassword()); NetSDKLib.LLong lLong = cameraControlLoginModule.login(camera.getIp(),camera.getPort(),camera.getUser(),camera.getPassword());
if(lLong != null){ if(lLong != null){
log.info("camera login success,cameraId:{},ip:{}",camera.getId(),camera.getIp()); log.info("camera login success,cameraId:{},ip:{},long{}",camera.getId(),camera.getIp(),lLong.intValue());
CameraConnMap.conn(camera.getId(),lLong); CameraConnMap.conn(camera.getId(),lLong);
} }
} }

@ -71,6 +71,9 @@ public class KsecNettyClient {
try { try {
createClient(ksec); createClient(ksec);
} catch (Exception e) { } catch (Exception e) {
if(channel!= null){
channel.close();
}
//没连上 继续 //没连上 继续
log.error("reconnect error num:{}", num); log.error("reconnect error num:{}", num);
num++; num++;

Loading…
Cancel
Save