WebSocket 连接可能会遇到不同的错误，如连接断开、消息传输失败、超时等。有效的错误处理和恢复机制对于保持连接的稳定性和可靠性至关重要。下面是有关 WebSocket 错误处理和恢复的一些关键点。

19.1 常见 WebSocket 错误

在 WebSocket 编程中，以下是几种常见的错误类型：

• 连接错误：由于服务器宕机、网络问题等导致无法建立连接。
• 断开连接：客户端或服务器因超时、断电等原因关闭连接。
• 数据传输错误：数据在传输过程中丢失、损坏或无法正确解析。
• 协议错误：例如，客户端和服务器之间的协议不兼容或传输的消息格式不符合规范。
• 超时错误：长时间没有收到消息或回应，导致连接超时。

---

19.2 WebSocket 错误处理机制

在处理 WebSocket 错误时，客户端和服务端都应该设计合适的策略来恢复连接或处理错误。

19.2.1 客户端错误处理

客户端应对以下情况进行错误处理：

1. 连接失败：如果 WebSocket 连接建立失败，客户端应该进行重试。可以设置重试次数或重试间隔。
2. 断开连接：当连接意外断开时，客户端应尝试重新连接。如果 WebSocket 连接断开，可以尝试在短时间内进行多次重连，或者提供重连按钮。
3. 数据传输错误：处理 WebSocket 错误事件（onerror）并输出错误日志。可以对异常消息进行格式检查。

客户端错误处理示例：

let socket;

function createWebSocket() {
  socket = new WebSocket('wss://localhost:8765');

  socket.onopen = () => {
    console.log('WebSocket connected!');
  };

  socket.onmessage = (event) => {
    console.log('Message received: ', event.data);
  };

  socket.onerror = (error) => {
    console.error('WebSocket Error: ', error);
    // 尝试重新连接
    setTimeout(createWebSocket, 5000);  // 5秒后重试连接
  };

  socket.onclose = (event) => {
    if (!event.wasClean) {
      console.log(`Connection closed unexpectedly: ${event.code}`);
    }
    // 尝试重连
    setTimeout(createWebSocket, 5000);  // 5秒后重试连接
  };
}

createWebSocket();

在这个示例中，如果 WebSocket 连接失败或断开，客户端会每隔 5 秒重新尝试建立连接。

---

19.2.2 服务端错误处理

服务端也需要处理客户端的错误请求或异常情况。以下是常见的服务端错误处理方式：

1. 连接错误：检查客户端是否提供了正确的请求。若连接失败，可以记录日志并通知客户端重试。
2. 断开连接：客户端断开连接时，服务端应及时关闭连接并清理相关资源。
3. 消息传输错误：服务端应对消息的格式、大小等进行验证，并处理不合法或无效的消息。
4. 协议错误：如果客户端发送了不符合协议的消息，服务端应关闭连接，并返回适当的错误消息。

服务端错误处理示例（Python）：

import asyncio
import websockets

async def handler(websocket, path):
    try:
        message = await websocket.recv()
        print(f"Received message: {message}")
    except websockets.exceptions.ConnectionClosedError:
        print("Connection closed unexpectedly!")
    except Exception as e:
        print(f"Error occurred: {e}")
    finally:
        await websocket.close()

start_server = websockets.serve(handler, "localhost", 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

在这个示例中，服务端处理了 WebSocket 的连接关闭错误以及其他异常，并确保在错误发生时关闭连接。

---

19.3 自动重连策略

WebSocket 连接可能会由于网络波动或其他原因而中断。为了提升系统的可靠性，客户端应实现自动重连机制。可以采用以下策略：

• 指数退避重连：通过逐步增加重试的时间间隔来避免频繁的重试操作，这样可以减少负载。
• 最大重试次数：为了避免死循环或无限重试，可以设定最大重试次数，超出次数后停止重试。
• 重连间隔：可以设置固定的重连间隔或动态调整。

指数退避重连示例：

let socket;
let reconnectAttempts = 0;
const maxReconnectAttempts = 5;
const reconnectDelay = 1000; // 初始重连延迟为1秒

function createWebSocket() {
  socket = new WebSocket('wss://localhost:8765');

  socket.onopen = () => {
    console.log('WebSocket connected!');
    reconnectAttempts = 0; // 连接成功，重置重试次数
  };

  socket.onmessage = (event) => {
    console.log('Message received: ', event.data);
  };

  socket.onerror = (error) => {
    console.error('WebSocket Error: ', error);
  };

  socket.onclose = (event) => {
    if (!event.wasClean && reconnectAttempts < maxReconnectAttempts) {
      reconnectAttempts++;
      console.log(`Reconnecting attempt ${reconnectAttempts}...`);
      setTimeout(createWebSocket, reconnectDelay * Math.pow(2, reconnectAttempts)); // 指数退避
    } else if (reconnectAttempts >= maxReconnectAttempts) {
      console.log('Max reconnect attempts reached.');
    }
  };
}

createWebSocket();

在此示例中，客户端会根据重连次数逐步增加重试间隔，并且最多重试 5 次。如果重连次数达到上限，则不再尝试。

---

19.4 消息队列与缓存机制

在某些情况下，客户端和服务端可能无法即时发送或接收消息。为了避免消息丢失，可以在 WebSocket 连接断开时使用消息队列或缓存机制来保存消息，并在连接恢复时进行处理。

• 客户端缓存消息：客户端可以在连接断开时将消息缓存在本地，连接恢复后再将消息发送到服务端。
• 服务端缓存消息：服务端可以通过队列（如 Redis）保存消息，等待连接恢复时推送给客户端。

---

19.5 监控与日志记录

为了确保 WebSocket 连接的稳定性，可以添加日志记录和监控机制。日志可以帮助开发者在错误发生时快速定位问题。

• 日志记录：记录 WebSocket 连接的建立、断开、错误等信息。
• 性能监控：监控 WebSocket 连接的数量、传输的消息数量等，以便于及时发现和解决性能瓶颈。

---

19.6 总结

WebSocket 的错误处理和恢复机制至关重要，确保客户端和服务器在遭遇异常情况时能够及时恢复并保持服务的可用性。通过实现自动重连、消息缓存、指数退避等策略，可以显著提高系统的稳定性和用户体验。

---

下一步：深入了解 WebSocket 的性能优化！