这是其他人提出的问题,但由于我的Express设置不同,我无法从他们给出的答案中受益.
我已经实现了socket.io并在我的服务器上以一种简单的方式工作.这是它的工作原理:
在bin / www中:
#!/usr/bin/env node var debug = require('debug')('gokibitz'); var app = require('../../server'); app.set('port',process.env.PORT || 3000); var server = app.listen(app.get('port'),function() { debug('Express server listening on port ' + server.address().port); }); var io = require('socket.io').listen(server); io.on('connection',require('../routes/socket.js'));
我的所有路线和其他Express设置都在../../server.js中.
var routes = require('./server/routes/index'); var user = require('./server/routes/user'); ... app.use('/',routes); app.use('/api/user/',user); ... app.use('*',routes);
然后在../routes/socket.js中,我有这个样板:
module.exports = function (socket) { socket.emit('send:news',{ hello: 'world' }); setInterval(function () { socket.emit('send:time',{ time: (new Date()).toString() }); },1000); return socket; };
我可以补充说,这工作得非常好.但是现在我希望能够在我非常普通的Express应用程序中从各种路径发出事件,而且我无法找到正确的方法来获取对我需要的套接字对象的引用.
示例:当用户发表评论时,我想向所有连接的用户发出一个事件,通知他们新的评论.从我的路由文件(./server/routes/user.js),如何访问我需要发出事件的对象?
这是路径文件中相关位的框架:
var express = require('express'); var router = express.Router(); router.post('/',function (req,res) { ... }); module.exports = router;
我可以访问它的唯一地方是../routes/socket.js文件,这是无用的.
在有任何io或socket对象传入之前,所有路由都在app.js中设置.
我是否应该能够(‘socket.io’)并以某种方式使用它来发射到所有连接的套接字?
是否有一种明智的方法可以将连接的套接字存储在../routes/socket.js上,以便可以从其他路径中将其连接到需要的位置?
任何人都可以引导我朝着正确的方向前进吗?
解决方法
我最终能够使用这个例子来解决问题:
https://github.com/expressjs/generator/issues/45#issuecomment-53719435
https://github.com/expressjs/generator/issues/45#issuecomment-53719435
我创建了一个名为server / io.js的新文件:
var io = require('socket.io')(); io.on('connection',function (socket) { socket.emit('news',{ hello: 'world' }); socket.on('my other event',function (data) { console.log(data); }); }); module.exports = io;
然后我将server / bin / www更新为:
#!/usr/bin/env node var debug = require('debug')('gokibitz'); var app = require('../../server'); var io = require('../io'); app.set('port',function() { debug('Express server listening on port ' + server.address().port); }); io.attach(server);
然后,在我的路线中,我使用这个:
var io = require('../io'); ... io.emit(...);
至少,我缺少的部分是能够单独创建io对象,返回正确的对象,然后在bin / www中使用io.attach(服务器)在正确的位置启动它.
希望这会帮助其他人追随我的脚步.