这就是我到目前为止所得到的,我正在努力找到一个解决方案,以便:
- 连接始终保持活动状态,因此我可以处理状态更新
- 我可以用POST请求中的数据向客户端发送websocket消息
此处为ws-api
router.post('/', function (req, res) {
// Need to send ws.send() with post data
})
wss.on('connection', function(ws) {
ws.on('message', function(message) {
console.log('r : %s', message);
});
// ws is only defined under this callback as an object of type ws
});
您可以使用这样的事件:
//Create an event
var event = require('events').EventEmitter();
router.post('/', function (req, res) {
// fire an event
event.emit('homePage')
})
wss.on('connection', function(ws) {
ws.on('message', function(message) {
console.log('r : %s', message);
});
// listen the event
event.on('homePage', function(){
ws.emit('someEvent');
});
});
我得到一个错误:
TypeError:无法读取未定义的属性"emit">
我想我可能会误解或错过一些对其他人来说显而易见的东西。请求发出调用时出现错误:
router.post('/', function (req, res) {
// fire an event
event.emit('homePage') <----------- HERE
})
我在开头添加:
var event = require('events').EventEmitter();
更新我通过以下2:解决了更改需要事件的行的问题
var events = require('events');
var eventEmitter = new events.EventEmitter();
之后它就开始工作了。