在 Deno 中使用 WebSocket 实现可扩展架构-JavaScript中文网-JavaScript教程资源分享门户

在 Deno 中使用 WebSocket 实现可扩展架构

WebSocket 已成为了现代前端开发中重要的一环，它是一种在客户端和服务器之间进行实时双向数据传输的协议。Deno 是一个基于 JavaScript 和 TypeScript 的运行时环境，它提供了类似 Node.js 的 API，但是它内置了 TypeScript，具有更好的性能和更安全的特性。本文将介绍如何在 Deno 中使用 WebSocket 实现可扩展架构。

WebSocket协议

WebSocket 协议是基于 HTTP 协议的一种长连接协议，它在客户端和服务器之间建立了一条双向的通信通道。在 WebSocket 协议中，客户端和服务器分别发送一个握手请求和握手响应，握手成功后，客户端和服务器之间建立了一条双向的通信通道，数据可以任意地在这条通道中传输。

WebSocket 协议支持的特性包括：

实时双向通信，可以支持实时聊天、视频会议等应用。
支持自定义数据格式，开发者可以自定义协议格式，方便与服务器端通信。
无需频繁建立新的连接，相比传统的 HTTP 请求，WebSocket 可以节省大量的网络开销。
支持多路复用，可以在同一连接上传输多个数据流，提高了网络资源的利用率。

使用 WebSocket 实现可扩展架构

在实际的开发中，我们可以将 WebSocket 作为底层通信协议，构建可扩展的架构。具体实现过程如下：

启动 WebSocket 服务器

首先，我们需要启动一个 WebSocket 服务器。使用 Deno 提供的 WebSocket 模块，可以轻松地创建 WebSocket 服务器。

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

const port = 8080

console.log(`WebSocket server is running on :${port}\n`)

for await (const req of serve(`:${port}`)) {
  const { socket, response } = await acceptWebSocket(req)
}

在上面的代码中，我们使用 serve 函数创建了一个 HTTP 服务器，然后使用 acceptWebSocket 函数来处理握手请求。握手成功后，我们可以得到一个 WebSocket 对象，用于进行进一步的数据传输。

处理 WebSocket 请求

在得到 WebSocket 对象后，我们可以通过 receive 函数监听客户端发送的数据，并通过 send 函数向客户端发送数据。例如，我们可以在服务器中处理一个简单的聊天室：

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

const port = 8080

console.log(`WebSocket server is running on :${port}\n`)

const users: WebSocket[] = []

async function chat(ws: WebSocket) {
  console.log('New user connected.')

  users.push(ws)

  for await (const event of ws) {
    if (typeof event === 'string') {
      console.log(`Message from user: ${event}`)

      users.forEach(async user => {
        await user.send(event)
      })
    }
  }

  console.log('User disconnected.')

  users.splice(users.indexOf(ws), 1)
}

for await (const req of serve(`:${port}`)) {
  const { socket, response } = await acceptWebSocket(req)

  chat(socket)
}

在上面的代码中，我们首先创建了一个 users 数组，用于保存所有连接到聊天室的用户。当有新用户连接时，我们将其加入到 users 数组中，并通过 for await…of 循环监听该用户的消息。当该用户发送消息时，我们将消息广播给所有的用户。如果该用户断开连接，我们从 users 数组中移除该用户。

搭建可扩展架构

使用 WebSocket 实现可扩展架构的关键是要将服务器分为多个部分，每个部分负责处理特定的请求。这样可以提高系统的处理性能，同时也可以避免单点故障。例如，我们可以将一个大型的网站分为多个功能模块，每个模块都运行在不同的服务器上，通过 WebSocket 在模块之间进行通信。

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

const port = 8080

console.log(`WebSocket server is running on :${port}\n`)

const modules = [
  'module1',
  'module2',
  'module3'
]

const users: WebSocket[] = []

async function onRequest(request: string, ws: WebSocket) {
  console.log(`${request} request from user.`)

  switch (request) {
    case 'module1':
      // 处理来自 module1 的请求
      break
    case 'module2':
      // 处理来自 module2 的请求
      break
    case 'module3':
      // 处理来自 module3 的请求
      break
    default:
      break
  }
}

async function onConn(ws: WebSocket): Promise<void> {
  console.log('New user connected.')

  users.push(ws)

  for await (const event of ws) {
    if (typeof event === 'string') {
      onRequest(event, ws)
    }
  }

  console.log('User disconnected.')

  users.splice(users.indexOf(ws), 1)
}

for await (const req of serve(`:${port}`)) {
  const { socket, response } = await acceptWebSocket(req)

  onConn(socket)
}

在上面的代码中，我们首先创建了一个 modules 数组，用于保存所有需要单独处理的模块名称。当有新的 WebSocket 连接时，我们将其加入到 users 数组中，并通过 for await…of 循环监听该用户的请求。当该用户向服务器发送请求时，我们通过 onRequest 函数处理请求，并根据请求的不同调用不同的处理函数。每个功能模块代码可以运行在不同的服务器上，通过 WebSocket 在模块之间进行通信。

结语

本文介绍了如何在 Deno 中使用 WebSocket 实现可扩展架构。WebSocket 协议作为一种实时双向通信协议，可以方便地实现前端的实时通信功能。使用 WebSocket 可以将服务器划分为多个部分，分别运行在不同的服务器上，从而提高了系统的处理性能，并且避免了单点故障。

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

在 Deno 中使用 WebSocket 实现可扩展架构

接着读