我是faye web套接字的新手,我试着设置一个服务器和一个客户端来交换信息。不幸的是,我遗漏了一些东西,并且我无法在客户端获取从服务器发送的消息。这是我的server.js:
var faye = require('faye');
var Router = require('node-simple-router');
var router = new Router();
var server = require('http').createServer(router);
var port = 5000;
var bayeux = new faye.NodeAdapter({mount: '/faye/calls'});
bayeux.attach(server);
// Launch the server
server.listen(port, function() {
console.log('Listening on ' + port);
setInterval(function(){
bayeux.getClient().publish('/faye/calls', {text: 'Hello'});
},3000);
并且是我的client.js
var faye = require('faye');
var client = new faye.Client('http://localhost:5000/faye', {
timeout: 600,
retry: 5
});
var sub = client.subscribe('/calls', function(message) {
console.log('message:' + message);
});
sub.then(function() {
console.log('overall Subscription is now active!');
});
有人能告诉我我错过了什么吗?非常感谢
祝你今天愉快
发布于 2015-08-25 08:47:02
看起来你的道路是罪魁祸首:
var bayeux = new faye.NodeAdapter({mount: '/faye/calls'});
应挂载到/faye
var bayeux = new faye.NodeAdapter({mount: '/faye'});
和
bayeux.getClient().publish('/faye/calls', {text: 'Hello'});
实际上应该发布到/calls
bayeux.getClient().publish('/calls', {text: 'Hello'});
这似乎为我解决了这个问题:
overall Subscription is now active!
message:[object Object]
message:[object Object]
message:[object Object]
https://stackoverflow.com/questions/32190472
复制相似问题