Socket.io 全局发送功能 - Node.js

Question

我构建一个简单的节点.js/socket.io 应用程序。 我需要发出事件一个模块，该模块可以通过其他模块访问，以便我可以在有新的数据库条目时发送套接字消息。

像这样：

function sendWebsocketEvent (whereToSend, EventName, Payload) {
io.in(whereToSend).emit(EventName, Payload)
}

我该如何处理？

我试过了：

--应用程序.js --

// Websockets
var http = require('http').createServer(app)
var io = require('socket.io')(http)
http.listen(3000, function () {
console.log('listening on Port *:3000')
})
require('./WebSockets/socketInit')(io)

--套接字初始化.js --

module.exports = (ioInput) => {
const io = ioInput
return io
}

--发送套接字.js --

const io = require('./socketInit')
module.exports = {
sendWebsocketEvent (whereToSend, EventName, Payload) {
io.in(whereToSend).emit(EventName, Payload)
}
}

我尝试在另一个模块中调用此函数：

const sendSockets = require('../WebSockets/sendSockets')
.
.
.
sendSockets.sendWebsocketEvent('user', 'databaseUpdate', 'dataToSend')
.
.
.

但这行不通。

有没有其他方法可以完成这项工作？

• 克里斯

Answer 1

InsideServer.js

const express = require('express');
const app = express();
const server = require('http').createServer(app)
const io = socket.listen(server);
global.io = io;
const port = process.env.PORT || 5500;
server.listen(port, () => console.log(`%s 🚀 Server is listening on port ${port}`, chalk.green('✓')));
// socket io connection 
let interval;
io.on("connection", socket => {
console.log("New client connected");
if (interval) {
clearInterval(interval);
}
});

并像那样在您想要的地方发射

global.io.emit('EventName', data);