如何在Hapi.js中全局使用Socket对象？

针对你的Hapi.js + Socket.io场景，有两种简单可靠的方式实现全局访问socket对象，方便在项目任意文件中发射事件：

方案一：挂载到Hapi Server的app属性 + 导出获取方法 #

修改你的socket.js文件，把Socket.io的io实例挂载到Hapi server的自定义存储属性app上，同时导出一个获取方法供非Hapi上下文的文件调用：

import Emitter from '../config/emitter'

let io; // 存储全局io实例

exports.register = (server, options, next) => {
  io = require('socket.io')(server.listener)
  
  io.on('connection', (socket) => {
    // 可选：如果需要给特定客户端发消息，可把socket实例存储起来
    // 比如：server.app.sockets = server.app.sockets || new Map();
    // server.app.sockets.set(socket.id, socket);
    
    socket.emit('action', action)
  })
  
  // 把io实例挂载到server.app，供Hapi路由/插件内访问
  server.app.io = io;
  next()
}

exports.register.attributes = {
  name: 'socket'
}

// 导出获取方法，供非Hapi上下文的模块调用
exports.getIO = () => io;

不同场景下的调用方式 #

1. 在Hapi路由处理函数中：

exports.route = {
  method: 'POST',
  path: '/notify-all',
  handler: (request, h) => {
    // 通过request.server.app.io拿到io实例
    request.server.app.io.emit('global-notification', { content: '新消息' });
    return { status: 'success' };
  }
};

2. 在普通Node.js模块中（如业务逻辑层）：

const { getIO } = require('../path/to/socket.js');

// 获取io实例后发射事件
const io = getIO();
io.emit('user-updated', { userId: 123, data: { name: '新名字' } });

方案二：独立的Socket管理模块 #

创建一个单独的模块专门管理Socket.io实例，把初始化和实例获取分离，更符合模块化设计：

1. 新建socket-manager.js #

let io;

module.exports = {
  // 初始化Socket.io，传入Hapi的server listener
  init: (serverListener) => {
    io = require('socket.io')(serverListener);
    return io;
  },
  // 获取已初始化的io实例
  getIO: () => {
    if (!io) {
      throw new Error('Socket.io 尚未初始化，请先调用init方法');
    }
    return io;
  }
};

2. 修改原socket.js #

import Emitter from '../config/emitter'
const socketManager = require('./socket-manager.js');

exports.register = (server, options, next) => {
  const io = socketManager.init(server.listener);
  
  io.on('connection', (socket) => {
    socket.emit('action', action)
  })
  
  next()
}

exports.register.attributes = {
  name: 'socket'
}

3. 全局调用 #

在项目任意文件中，只需引入socket-manager.js即可获取io实例：

const socketManager = require('../path/to/socket-manager.js');
const io = socketManager.getIO();

io.emit('system-alert', { message: '系统维护通知' });

注意事项 #

• 确保在调用getIO()之前，Hapi已经完成了socket插件的注册，否则会抛出未初始化的错误。
• 如果需要给单个客户端发送消息，记得在connection事件中把socket实例存储到全局容器（如Map或对象），后续通过客户端ID查找对应的socket即可。

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