如何在Express路线处理程序中插入.broadcast.emit

Question

所需行为

我目前通过jQuery.ajax((请求更新Node/Express/MongoDB应用程序。

服务器响应被发送回ajax请求的成功处理程序，并且在发送方的客户端上进行各种接口更改。

客户端

function update_database(parameters) {
$.ajax({
method: "POST",
url: "/api/v1/my_path",
data: parameters,
dataType: 'json',
cache: false,
headers: headers,
success: function(results) {
// perform interface changes
},
statusCode: {
500: function() {
console.log("that didn't work");
}
}
});
}

当然，这只是更新发件人的客户端。

我想更新所有连接的客户端。

我尝试了什么

官方的socket.io备忘单显示，相关方法是：

// send to all clients except sender
socket.broadcast.emit('broadcast', 'hello friends!');

在上下文中，官方教程的Broadcasting部分显示：

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
io.on('connection', function(socket){
socket.broadcast.emit('hi');
});

问题

如何从路由处理程序的函数中socket.broadcast.emit？

是否需要将每个broadcase.emit封装在io.on('connection')回调函数中？

以下内容不起作用，因为变量socket尚未声明，但每次想要socket.broadcast.emit时都必须使用io.on('connection')包装器，这似乎有些"不正确"。

服务器端

// app setup
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
// the route handler
app.route("/api/:api_version/my_path")
.post(api_my_post);
// the function
const api_my_post = (req, res) => {
// define the filter and update
var filter = { _id: o_id };
var update = { $set: { key: value } };
// perform the required database update
collection.findOneAndUpdate(filter, update, function(err, result) {
if (err) {
res.send(err);
} else {
// create an object to return
var response_json = { key: value, key_2: value_2 };
// return the object to the ajax success handler
res.json(response_json);
// return the object to all other connected clients
socket.broadcast.emit("ajax_response", response_json);
}
});
}

编辑：

下面的答案看起来很有希望，也相对简单，但似乎只适用于io.emit场景，而不是socket.broadcast.emit场景。

是否可以在路由内以某种方式访问socket以允许使用socket.broadcast.emit？：

https://stackoverflow.com/a/31277123

基本配置：

var app = require('express')();
var server = app.listen(process.env.PORT || 3000);
var io = require('socket.io')(server);
// next line is the money
app.set('socketio', io);

内部路由或中间件：

exports.foo = function(req,res){
// now use socket.io in your routes file
var io = req.app.get('socketio');
io.emit('hi!');
}

Answer 1

不，您只需要像这样实现一次套接字连接，并将套接字对象传递给您的控制器

锅炉铭牌代码

socket_object = require('./controllers/myapp/socket.js');
io.on('connection', function(socket) {
socket_object(socket);
});

其中socket.js将具有类似的功能

module.exports = function(socket) {
socket.on('getevent', function(data) { 
});