Spaces:
Running
Running
Update index.js
Browse files
index.js
CHANGED
@@ -185,7 +185,7 @@ class WebSocketUtils {
|
|
185 |
static async createWebSocketClient(requestPayload) {
|
186 |
// 检查当前连接数是否达到上限
|
187 |
if (this.activeConnections.size >= this.MAX_CONNECTIONS) {
|
188 |
-
throw new Error(`当前连接数已达到上限 (${this.MAX_CONNECTIONS})
|
189 |
}
|
190 |
|
191 |
let timeoutId;
|
@@ -234,7 +234,6 @@ class WebSocketUtils {
|
|
234 |
ws.on('message', async (data) => {
|
235 |
const message = data.toString();
|
236 |
const parsedMessage = JSON.parse(message);
|
237 |
-
console.log(JSON.stringify(parsedMessage,null,2));
|
238 |
|
239 |
switch (parsedMessage.type) {
|
240 |
case 'connection_ack':
|
@@ -259,8 +258,7 @@ class WebSocketUtils {
|
|
259 |
case 'error':
|
260 |
console.error('WebSocket错误:', parsedMessage.payload[0].message);
|
261 |
ws.close();
|
262 |
-
|
263 |
-
break;
|
264 |
}
|
265 |
});
|
266 |
|
@@ -272,7 +270,7 @@ class WebSocketUtils {
|
|
272 |
if (ws.readyState === WebSocket.OPEN) {
|
273 |
ws.close();
|
274 |
}
|
275 |
-
|
276 |
});
|
277 |
|
278 |
ws.on('close', (code, reason) => {
|
@@ -281,7 +279,7 @@ class WebSocketUtils {
|
|
281 |
this.activeConnections.delete(ws);
|
282 |
console.log(`连接关闭,当前活跃连接数: ${this.activeConnections.size}/${this.MAX_CONNECTIONS}`);
|
283 |
if (!isComplete) {
|
284 |
-
|
285 |
}
|
286 |
});
|
287 |
});
|
|
|
185 |
static async createWebSocketClient(requestPayload) {
|
186 |
// 检查当前连接数是否达到上限
|
187 |
if (this.activeConnections.size >= this.MAX_CONNECTIONS) {
|
188 |
+
throw new Error(`当前连接数已达到上限 (${this.MAX_CONNECTIONS}),请稍后重试!`);
|
189 |
}
|
190 |
|
191 |
let timeoutId;
|
|
|
234 |
ws.on('message', async (data) => {
|
235 |
const message = data.toString();
|
236 |
const parsedMessage = JSON.parse(message);
|
|
|
237 |
|
238 |
switch (parsedMessage.type) {
|
239 |
case 'connection_ack':
|
|
|
258 |
case 'error':
|
259 |
console.error('WebSocket错误:', parsedMessage.payload[0].message);
|
260 |
ws.close();
|
261 |
+
throw new Error(`WebSocket错误: ${parsedMessage.payload[0].message}`);
|
|
|
262 |
}
|
263 |
});
|
264 |
|
|
|
270 |
if (ws.readyState === WebSocket.OPEN) {
|
271 |
ws.close();
|
272 |
}
|
273 |
+
throw new Error(`WebSocket错误: ${err}`);
|
274 |
});
|
275 |
|
276 |
ws.on('close', (code, reason) => {
|
|
|
279 |
this.activeConnections.delete(ws);
|
280 |
console.log(`连接关闭,当前活跃连接数: ${this.activeConnections.size}/${this.MAX_CONNECTIONS}`);
|
281 |
if (!isComplete) {
|
282 |
+
throw new Error('WebSocket closed unexpectedly');
|
283 |
}
|
284 |
});
|
285 |
});
|