Node.js中如何使ws库的ws对象在全脚本范围内可用？

你遇到的问题本质是变量作用域限制——ws对象只在wss.on('connection')的回调函数内部可用，外部的MySQL事件监听函数没法直接访问它。下面给你两种实用的解决方案，根据你的实际场景选择：

方案1：维护活跃连接集合（推荐，支持多客户端） #

如果你的服务需要同时处理多个WebSocket客户端连接，最好用一个集合来跟踪所有活跃的连接。这样MySQL事件触发时，你可以给所有在线客户端推送消息：

var MySQLEvents = require('mysql-events');
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

// 用Set存储所有活跃的WebSocket连接
const activeConnections = new Set();

wss.on('connection', function (ws) {
  // 新连接加入集合
  activeConnections.add(ws);
  
  ws.on('message', function (message) {
    console.log('received: %s', message)
  });
  
  ws.send("hey mane");

  // 连接断开时从集合移除，避免内存泄漏
  ws.on('close', () => {
    activeConnections.delete(ws);
  });

  // 处理连接错误
  ws.on('error', (err) => {
    console.error('WebSocket error:', err);
    activeConnections.delete(ws);
  });
});

// 初始化MySQL事件监听
var dsn = { host: 'localhost', user: 'root', password: '' };
var mysqlEventWatcher = MySQLEvents(dsn);

var watcher = mysqlEventWatcher.add(
  'experimental.test',
  function (oldRow, newRow, event) {
    console.log(event);
    let message = '';
    
    // 根据事件类型生成推送消息
    if (oldRow === null) {
      message = "Row inserted";
      console.log(message);
    } else if (newRow === null) {
      message = "Row deleted";
      console.log(message);
    } else if (oldRow !== null && newRow !== null) {
      message = "Row updated";
      console.log(message);
    }

    // 给所有活跃连接推送消息
    activeConnections.forEach((ws) => {
      // 检查连接状态是否可用
      if (ws.readyState === WebSocket.OPEN) {
        ws.send(message);
      }
    });
  },
);

方案2：全局存储单个连接（仅单客户端场景） #

如果你的服务只需要处理一个客户端连接，可以把ws对象存储在全局变量中，但一定要注意处理连接断开的情况：

var MySQLEvents = require('mysql-events');
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

// 全局变量存储WebSocket连接
let globalWs = null;

wss.on('connection', function (ws) {
  globalWs = ws;
  
  ws.on('message', function (message) {
    console.log('received: %s', message)
  });
  
  ws.send("hey mane");

  // 连接断开时清空全局变量
  ws.on('close', () => {
    globalWs = null;
  });
});

// 初始化MySQL事件监听
var dsn = { host: 'localhost', user: 'root', password: '' };
var mysqlEventWatcher = MySQLEvents(dsn);

var watcher = mysqlEventWatcher.add(
  'experimental.test',
  function (oldRow, newRow, event) {
    console.log(event);
    let message = '';
    
    if (oldRow === null) {
      message = "Row inserted";
      console.log(message);
    } else if (newRow === null) {
      message = "Row deleted";
      console.log(message);
    } else if (oldRow !== null && newRow !== null) {
      message = "Row updated";
      console.log(message);
    }

    // 检查全局连接是否存在且可用
    if (globalWs && globalWs.readyState === WebSocket.OPEN) {
      globalWs.send(message);
    }
  },
);

额外注意点 #

• 你原来的代码里重复引入了MySQLEvents，我已经帮你修正了，避免不必要的模块重复加载。
• 无论哪种方案，都要检查WebSocket的readyState是否为OPEN，否则直接调用send会抛出错误。
• 多客户端场景下，方案1的Set比数组更适合，因为它自动处理重复项，删除操作也更高效。

内容的提问来源于stack exchange，提问作者Alexander Jovric