This commit is contained in:
caozehui
2025-06-03 11:31:56 +08:00
parent da7015fd89
commit b0dde94314

View File

@@ -122,6 +122,7 @@ public class WebSocketHandler extends SimpleChannelInboundHandler<TextWebSocketF
PreDetectionParam preDetectionParam = WebServiceManager.getPreDetectionParam(); PreDetectionParam preDetectionParam = WebServiceManager.getPreDetectionParam();
if (ObjectUtil.isNotNull(preDetectionParam)) { if (ObjectUtil.isNotNull(preDetectionParam)) {
CnSocketUtil.quitSendSource(preDetectionParam); // 能否在这里关闭源socket连接 CnSocketUtil.quitSendSource(preDetectionParam); // 能否在这里关闭源socket连接
CnSocketUtil.quitSend(preDetectionParam);
} else { } else {
preDetectionParam = new PreDetectionParam(); preDetectionParam = new PreDetectionParam();
preDetectionParam.setUserPageId("cdf"); preDetectionParam.setUserPageId("cdf");