()
| 2501 | |
| 2502 | // 开始批量任务心跳 |
| 2503 | function startBatchWebSocketHeartbeat() { |
| 2504 | stopBatchWebSocketHeartbeat(); |
| 2505 | batchWsHeartbeatInterval = setInterval(() => { |
| 2506 | if (batchWebSocket && batchWebSocket.readyState === WebSocket.OPEN) { |
| 2507 | batchWebSocket.send(JSON.stringify({ type: 'ping' })); |
| 2508 | } |
| 2509 | }, 25000); // 每 25 秒发送一次心跳 |
| 2510 | } |
| 2511 | |
| 2512 | // 停止批量任务心跳 |
| 2513 | function stopBatchWebSocketHeartbeat() { |
no test coverage detected