如何使用(socket.io)发出socket函数之外的函数 - nodejs,express

Question

我有以下代码

var app = require('express')();
var http = require('http');
var server = http.createServer();
var socket = require('socket.io');
var io = socket.listen( server );

io.sockets.on('connection', function(socket) {
  console.log('socket connected');
  socket.broadcast.emit('newUser', 'New User Joined, Say Hi :D');

  socket.on('serverEmit',function(msg) {
    console.log('works');
  });

  socket.on('chatMessage', function(msg) {
    io.emit('server_emit', msg);
    console.log(msg);
  });
});

server.listen(3500, function() {
  console.log('listening on *:3500');
});

所以我的问题是如何在这个套接字连接之外添加一个emit函数.例如,如果我有如下的获取请求

app.get('/link',function(req,res) {
  io.sockets.emit('trigger','triggered'); // Process I want to make
});

提前致谢.

Answer 1

您需要先导出 io，以便可以重复使用。

socket-setup.js

const socket = require("socket.io")

let _io;

const setIO = (server) => {
    _io = socket(server, {
        cors : {
          origin : "*",
          headers : {
            "Access-Control-Allow-Origin" : "*"
          }
        }
      })
      return _io
}

const getIO = () => {
    return _io
}

module.exports = {
    getIO,
    setIO
}

然后在您的应用程序入口文件 ( index.js) 中，设置您的 io.

const app = express()
const server = http.createServer(app)

let io = setIO(server)
io.on("connection", socket => {
 //Your job
})

然后无论message.js你想在哪里发出事件。你可以像这样使用io。

const onMessageRecieved = () => {
    try {
        getIO().emit("hello", "Bye")
    } catch (error) {
        console.log(error);
    }
}

就是这样。享受。

Answer 2

你几乎已经拥有了：

它是io.emit('trigger','triggered');

如果您需要发送到名称空间，您可以执行以下操作：

const namespace = io.of("name_of_your_namespace");
namespace.emit('trigger','triggered');