0

0

如何在 Socket.IO 中正确获取所有活跃连接的 Socket 实例

心靈之曲

心靈之曲

发布时间:2026-03-12 19:07:02

|

442人浏览过

|

来源于php中文网

原创

如何在 Socket.IO 中正确获取所有活跃连接的 Socket 实例

本文详解 io.fetchSockets() 报错“is not a function”的根本原因与解决方案,涵盖版本兼容性检查、服务端/客户端升级步骤及安全调用实践,助你稳定获取全部在线 Socket 连接。

本文详解 `io.fetchsockets()` 报错“is not a function”的根本原因与解决方案,涵盖版本兼容性检查、服务端/客户端升级步骤及安全调用实践,助你稳定获取全部在线 socket 连接。

io.fetchSockets() 是 Socket.IO v4 引入的核心服务端 API,用于异步获取当前命名空间下所有活跃的 Socket 实例(返回 Promise<Socket[]>),常用于广播控制、连接统计或会话管理。但如示例中所示,调用时抛出 TypeError: io.fetchSockets is not a function,根本原因并非代码逻辑错误,而是 Socket.IO 版本不匹配——该方法仅在 v4.0.0 及以上版本中可用,而项目很可能仍在使用 v3.x 或更早版本。

✅ 正确升级与验证步骤

首先确认当前版本:

npm list socket.io socket.io-client

若输出类似 socket.io@3.1.2,则需统一升级服务端与客户端至 v4+:

Bolt.new
Bolt.new

Bolt.new是一个免费的AI全栈开发工具

下载
# 升级服务端(Node.js)
npm install socket.io@latest

# 升级客户端(确保 HTML 中加载的也是 v4+)
npm install socket.io-client@latest
# 或直接使用 CDN(推荐用于快速验证):
# <script src="https://cdn.socket.io/4.7.2/socket.io.min.js"></script>

⚠️ 关键注意:必须同时升级服务端和客户端。即使服务端为 v4,若前端仍通过 /socket.io/socket.io.js 加载旧版静态资源(例如由 v3 的 socket.io 包自动托管),浏览器实际运行的仍是 v3 客户端,这虽不影响连接,但会导致服务端某些 v4 新特性(如 fetchSockets)因内部协议/类型系统差异而不可用或行为异常。

✅ 修复后的服务端代码(含健壮性增强)

const express = require("express");
const { Server } = require("socket.io"); // 推荐解构导入,更清晰

const app = express();
app.use(express.static(__dirname + "/public"));

const webserver = app.listen(9001, () => {
  console.log("✅ Server running on http://localhost:9001");
});

// 初始化 Socket.IO 服务器(自动挂载到 HTTP server)
const io = new Server(webserver, {
  cors: {
    origin: "http://localhost:9001", // 根据实际前端地址调整
    methods: ["GET", "POST"]
  }
});

io.on("connection", async (socket) => {
  console.log(`? Client connected: ${socket.id}`);

  try {
    // ✅ v4+ 正确调用方式:返回 Promise<Socket[]>
    const allSockets = await io.fetchSockets();
    console.log(`? Total active sockets: ${allSockets.length}`);

    // 示例:向除当前客户端外的所有人广播新用户加入
    socket.broadcast.emit("user_joined", { id: socket.id, count: allSockets.length });

  } catch (err) {
    console.error("❌ Failed to fetch sockets:", err);
  }
});

// ? 额外建议:提供 HTTP 端点供运维查询(避免在 connection 中高频调用)
app.get("/api/sockets/count", async (req, res) => {
  try {
    const sockets = await io.fetchSockets();
    res.json({ count: sockets.length, timestamp: new Date().toISOString() });
  } catch (err) {
    res.status(500).json({ error: err.message });
  }
});

✅ 客户端 HTML(确保加载 v4+ 客户端)

<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8" />
  <title>Socket.IO v4 Demo</title>
</head>
<body>
  <!-- 使用明确的 v4 CDN 地址,避免缓存旧版 -->
  <script src="https://cdn.socket.io/4.7.2/socket.io.min.js"></script>
  <script>
    const socket = io("http://localhost:9001", {
      transports: ["websocket"] // 强制 WebSocket,排除降级干扰
    });

    socket.on("connect", () => {
      console.log("? Connected to Socket.IO v4 server");
    });

    socket.on("user_joined", (data) => {
      console.log(`? New user joined! Total: ${data.count}`);
    });
  </script>
</body>
</html>

? 常见误区排查清单

  • ❌ 错误:io 对象被意外覆盖(如 const io = ...; io = somethingElse;)→ 检查是否 const 声明且未重赋值;
  • ❌ 错误:使用了 socket.io 的旧版 Express 中间件(如 app.use(require('socket.io')(server)))→ v4 必须使用 new Server() 构造函数;
  • ❌ 错误:NPM 缓存导致升级未生效 → 执行 npm cache clean --force && rm -rf node_modules package-lock.json && npm install;
  • ⚠️ 提示:fetchSockets() 返回的是 所有命名空间下的 Socket(默认 "/")。如需指定命名空间,请使用 io.of("/custom").fetchSockets()。

掌握版本一致性是使用 Socket.IO 新特性的前提。fetchSockets() 不仅是一个便利方法,更是构建可观察、可管理实时系统的基石——请始终将服务端与客户端版本对齐,并通过 try/catch 和日志保障其生产环境稳定性。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

182

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

226

2025.12.18

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

456

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

546

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

335

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

82

2025.09.10

Node.js后端开发与Express框架实践
Node.js后端开发与Express框架实践

本专题针对初中级 Node.js 开发者,系统讲解如何使用 Express 框架搭建高性能后端服务。内容包括路由设计、中间件开发、数据库集成、API 安全与异常处理,以及 RESTful API 的设计与优化。通过实际项目演示,帮助开发者快速掌握 Node.js 后端开发流程。

418

2026.02.10

require的用法
require的用法

require的用法有引入模块、导入类或方法、执行特定任务。想了解更多require的相关内容,可以阅读本专题下面的文章。

510

2023.11.27

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

76

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号