mih*_*lzi 1 javascript websocket node.js express
我想发送一个 websocket,使用 express-ws 从不同的控制器发送出去,而不是通过路由,我在 server.js 中有以下代码:
var SocketController = require('./routes/ws.routes');
var app = express();
var server = require('http').createServer(app);
var expressWs = require('express-ws')(app);
app.ws('/', SocketController.socketFunction);
Run Code Online (Sandbox Code Playgroud)
SocketController 看起来像这样:
exports.socketFunction = function (ws, req) {
ws.on('message', function(msg) {
console.log(msg);
ws.send("hello");
});
}
Run Code Online (Sandbox Code Playgroud)
是否可以调用
ws.send()
来自另一个控制器的事件?我如何获得“ws”对象?
谢谢!
您必须将套接字存储在内存中。要从不同的模块访问存储的套接字,您可以将这些套接字的引用存储在单独的模块中。
例如,您可以创建一个模块 socketCollection 来存储所有活动的套接字。
socketCollection.js:
exports.socketCollection = [];
Run Code Online (Sandbox Code Playgroud)
您可以在定义 Web 套接字服务器的位置导入此模块:
var socketCollection = require('./socketCollection');
var SocketController = require('./routes/ws.routes');
var app = express();
var server = require('http').createServer(app);
var expressWs = require('express-ws')(app);
expressWs.getWss().on('connection', function(ws) {
socketCollection.push({
id: 'someRandomSocketId',
socket: ws,
});
});
app.ws('/', SocketController.socketFunction);
Run Code Online (Sandbox Code Playgroud)
现在,每次新客户端连接到服务器时,它的引用都会保存到 'socketCollection' 您可以通过导入此数组从任何模块访问这些客户端
var socketCollection = require('./socketCollection');
var ws = findSocket('someRandomSocketId', socketCollection);
var findSocket = function(id, socketCollection) {
var result = socketCollection.filter(function(x){return x.id == id;} );
return result ? result[0].socket : null;
};
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1082 次 |
| 最近记录: |