Deno 中如何使用 WebSocket 进行实时告警？-JavaScript中文网-JavaScript教程资源分享门户

前言

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，它可以在客户端和服务器之间建立实时通信，用于实现实时告警、聊天、在线游戏等场景。Deno 是一种新的 JavaScript 运行时，它提供了一种安全、现代化的方式来编写服务器端应用程序。本文将介绍如何在 Deno 中使用 WebSocket 进行实时告警。

WebSocket 的基本概念

在介绍如何在 Deno 中使用 WebSocket 进行实时告警之前，我们先来了解一下 WebSocket 的基本概念。

WebSocket 的建立过程

WebSocket 的建立过程如下图所示：

客户端发送 WebSocket 握手请求。
服务器响应 WebSocket 握手请求。
握手成功后，客户端和服务器之间建立了一个全双工通信的连接，可以进行实时通信。

WebSocket 的消息格式

WebSocket 的消息格式如下图所示：

FIN：表示消息是否已经结束。
RSV1、RSV2、RSV3：保留字段，暂时没有使用。
Opcode：表示消息类型，常用的有文本消息（Opcode 为 1）和二进制消息（Opcode 为 2）。
Mask：表示是否对消息进行掩码处理。
Payload length：表示消息的长度，如果长度小于 126，则 Payload length 的值就是消息的长度；如果长度大于等于 126 小于等于 65535，则 Payload length 的值为 126，并且后面的 16 个比特位表示消息的长度；如果长度大于 65535，则 Payload length 的值为 127，并且后面的 64 个比特位表示消息的长度。
Masking-key：表示掩码密钥，如果 Mask 为 1，则需要使用掩码密钥对消息进行掩码处理。
Payload data：表示消息的内容，如果 Mask 为 1，则需要使用掩码密钥对 Payload data 进行掩码处理。

WebSocket 的 API

WebSocket 的 API 包括以下几个方法和事件：

WebSocket(url: string, protocols?: string | string[]): 构造函数，用于创建 WebSocket 对象。
WebSocket.readyState: 只读属性，表示 WebSocket 对象的当前状态。
WebSocket.send(data: string | ArrayBuffer | Blob | ArrayBufferView): 方法，用于发送消息。
WebSocket.close(code?: number, reason?: string): 方法，用于关闭 WebSocket 连接。
WebSocket.onopen: 事件，表示 WebSocket 连接已经建立。
WebSocket.onmessage: 事件，表示收到了 WebSocket 消息。
WebSocket.onclose: 事件，表示 WebSocket 连接已经关闭。
WebSocket.onerror: 事件，表示 WebSocket 发生了错误。

在 Deno 中使用 WebSocket 进行实时告警

了解了 WebSocket 的基本概念和 API 后，我们来看一下如何在 Deno 中使用 WebSocket 进行实时告警。

安装 Deno

首先，我们需要安装 Deno，可以通过以下命令安装：

$ curl -fsSL https://deno.land/x/install/install.sh | sh

安装完成后，可以通过以下命令验证是否安装成功：

$ deno --version

创建 WebSocket 服务器

接下来，我们需要创建一个 WebSocket 服务器，代码如下：

// www.javascriptcn.com code example
import { serve } from "https://deno.land/std/http/server.ts";
import { acceptWebSocket, isWebSocketCloseEvent } from "https://deno.land/std/ws/mod.ts";

const server = serve({ port: 3000 });

console.log("WebSocket server is running on port 3000");

for await (const req of server) {
  if (req.url === "/ws") {
    const { conn, r: bufReader, w: bufWriter, headers } = req;
    acceptWebSocket({
      conn,
      bufReader,
      bufWriter,
      headers,
    }).then(handleWebSocket);
  } else {
    req.respond({ status: 404, body: "Not found" });
  }
}

async function handleWebSocket(websocket: WebSocket): Promise<void> {
  console.log("WebSocket connected");

  for await (const event of websocket) {
    if (typeof event === "string") {
      console.log(`Received message: ${event}`);
    } else if (event instanceof Uint8Array) {
      console.log(`Received binary message: ${event}`);
    } else if (isWebSocketCloseEvent(event)) {
      console.log("WebSocket closed");
    }
  }
}

代码中，我们使用 Deno 标准库中的 HTTP 服务器和 WebSocket 模块来创建一个 WebSocket 服务器，监听 3000 端口。当客户端连接到 /ws 路径时，会创建一个 WebSocket 连接，并调用 handleWebSocket 函数来处理 WebSocket 事件。

连接 WebSocket 服务器

接下来，我们需要在客户端中连接到 WebSocket 服务器，代码如下：

// www.javascriptcn.com code example
const websocket = new WebSocket("ws://localhost:3000/ws");

websocket.addEventListener("open", () => {
  console.log("WebSocket connected");

  websocket.send("Hello, WebSocket!");
});

websocket.addEventListener("message", (event) => {
  console.log(`Received message: ${event.data}`);
});

websocket.addEventListener("close", () => {
  console.log("WebSocket closed");
});

websocket.addEventListener("error", (event) => {
  console.error(`WebSocket error: ${event}`);
});

代码中，我们创建了一个 WebSocket 对象，连接到了 WebSocket 服务器。当 WebSocket 连接成功时，会发送一条消息并打印日志；当收到消息时，会打印消息并回复一条消息；当 WebSocket 连接关闭时，会打印日志；当 WebSocket 发生错误时，会打印错误信息。

发送实时告警

最后，我们可以通过 WebSocket 发送实时告警，代码如下：

setInterval(() => {
  const message = `Alert: ${new Date().toISOString()}`;
  console.log(`Sending message: ${message}`);
  websocket.send(message);
}, 1000);

代码中，我们使用 setInterval 来定时发送实时告警，每隔 1 秒钟发送一条消息。

结语

本文介绍了如何在 Deno 中使用 WebSocket 进行实时告警，包括 WebSocket 的基本概念、API、创建 WebSocket 服务器、连接 WebSocket 服务器和发送实时告警。通过学习本文，读者可以了解 WebSocket 的基本原理和使用方法，掌握在 Deno 中使用 WebSocket 进行实时通信的技能。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/67d169eda941bf7134304228

Deno 中如何使用 WebSocket 进行实时告警？

前言